diff --git a/dap_stream_ch.c b/dap_stream_ch.c
index bf3ecf568259204d84729ecdab1c5d880fd5bd76..da0f5c055feb8e74b9c78702c4c385b5fb46ee67 100644
--- a/dap_stream_ch.c
+++ b/dap_stream_ch.c
@@ -23,7 +23,7 @@
 #include "dap_client_remote.h"
 #include "dap_http_client.h"
 
-#include "stream.h"
+#include "dap_stream.h"
 #include "dap_stream_ch.h"
 #include "dap_stream_ch_proc.h"
 #include "dap_stream_ch_pkt.h"
diff --git a/dap_stream_ch_pkt.c b/dap_stream_ch_pkt.c
index 7f41fec5a54da5fc0d8c8ffb66aead6dbe34ed72..16bb083727bb7c63ff60d3dea250d28fb0daf08b 100644
--- a/dap_stream_ch_pkt.c
+++ b/dap_stream_ch_pkt.c
@@ -26,11 +26,11 @@
 #include "dap_enc_key.h"
 
 #include "dap_client_remote.h"
-#include "stream.h"
+#include "dap_stream.h"
 #include "dap_stream_ch.h"
 #include "dap_stream_ch_pkt.h"
 #include "dap_stream_ch_proc.h"
-#include "stream_pkt.h"
+#include "dap_stream_pkt.h"
 
 #define LOG_TAG "dap_stream_ch_pkt"
 
@@ -63,7 +63,7 @@ size_t stream_ch_pkt_write_seq_id(struct dap_stream_ch * ch, uint8_t type, uint6
 
     //log_it(L_DEBUG,"Output: Has %u bytes of %c type for %c channel id",data_size, (char)type, (char) ch->proc->id );
 
-    stream_ch_pkt_hdr_t hdr;
+    dap_stream_ch_pkt_hdr_t hdr;
 
     memset(&hdr,0,sizeof(hdr));
     hdr.id = ch->proc->id;
@@ -79,7 +79,7 @@ size_t stream_ch_pkt_write_seq_id(struct dap_stream_ch * ch, uint8_t type, uint6
     memcpy(ch->buf,&hdr,sizeof(hdr) );
     memcpy(ch->buf+sizeof(hdr),data,data_size );
 
-    size_t ret=stream_pkt_write(ch->stream,ch->buf,data_size+sizeof(hdr));
+    size_t ret=dap_stream_pkt_write(ch->stream,ch->buf,data_size+sizeof(hdr));
     ch->stat.bytes_write+=data_size;
     pthread_mutex_unlock( &ch->mutex);
     return ret;
@@ -123,7 +123,7 @@ size_t stream_ch_pkt_write_f(struct dap_stream_ch * ch, uint8_t type, const char
 size_t stream_ch_send_keepalive(struct dap_stream_ch * ch){
     pthread_mutex_lock( &ch->mutex);
 
-    stream_ch_pkt_hdr_t hdr;
+    dap_stream_ch_pkt_hdr_t hdr;
 
     memset(&hdr,0,sizeof(hdr));
     hdr.id = ch->proc->id;
@@ -134,7 +134,7 @@ size_t stream_ch_send_keepalive(struct dap_stream_ch * ch){
 
     memcpy(ch->buf,&hdr,sizeof(hdr) );
 
-    size_t ret=stream_pkt_write(ch->stream,ch->buf,sizeof(hdr));
+    size_t ret=dap_stream_pkt_write(ch->stream,ch->buf,sizeof(hdr));
     pthread_mutex_unlock( &ch->mutex);
     return ret;
 }
diff --git a/dap_stream_ch_pkt.h b/dap_stream_ch_pkt.h
index 1502e4700244dd70a2d1108dbfbe7b4018c9ef05..95bdb24dd8597d1a8ad88fb2dc82f88196908b21 100644
--- a/dap_stream_ch_pkt.h
+++ b/dap_stream_ch_pkt.h
@@ -19,15 +19,14 @@
 */
 
 
-#ifndef _STREAM_CH_PKT_H_
-#define _STREAM_CH_PKT_H_
+#pragma once
 
 #define KEEPALIVE_PACKET 0x11
 
 #include <stdint.h>
 #include <stddef.h>
 struct dap_stream_ch;
-typedef struct stream_ch_pkt_hdr{
+typedef struct dap_stream_ch_pkt_hdr{
     uint8_t id;   // Channel id
     uint8_t enc_type; // Zero if not encrypted
     uint8_t type; // general, command, info, signal and etc
@@ -35,20 +34,18 @@ typedef struct stream_ch_pkt_hdr{
     uint64_t seq_id; // Sequence id or position id
 //    uint64_t seq
     uint32_t size;
-}  __attribute__((packed)) stream_ch_pkt_hdr_t;
+}  __attribute__((packed)) dap_stream_ch_pkt_hdr_t;
 
-typedef struct stream_ch_pkt{
-    stream_ch_pkt_hdr_t hdr;
+typedef struct dap_stream_ch_pkt{
+    dap_stream_ch_pkt_hdr_t hdr;
     uint8_t data[];
-} __attribute__((packed)) stream_ch_pkt_t;
+} __attribute__((packed)) dap_stream_ch_pkt_t;
 
-extern int stream_ch_pkt_init();
-extern void stream_ch_pkt_deinit();
+int stream_ch_pkt_init();
+void stream_ch_pkt_deinit();
 
-extern size_t stream_ch_pkt_write_f(struct dap_stream_ch * ch, uint8_t type, const char * str,...);
-extern size_t stream_ch_pkt_write(struct dap_stream_ch * ch,  uint8_t type, const void * data, uint32_t data_size);
-extern size_t stream_ch_pkt_write_seq_id(struct dap_stream_ch * ch,  uint8_t type, uint64_t seq_id, const void * data, uint32_t data_size);
+size_t stream_ch_pkt_write_f(struct dap_stream_ch * ch, uint8_t type, const char * str,...);
+size_t stream_ch_pkt_write(struct dap_stream_ch * ch,  uint8_t type, const void * data, uint32_t data_size);
+size_t stream_ch_pkt_write_seq_id(struct dap_stream_ch * ch,  uint8_t type, uint64_t seq_id, const void * data, uint32_t data_size);
 
-extern size_t stream_ch_send_keepalive(struct dap_stream_ch * ch);
-
-#endif
+size_t stream_ch_send_keepalive(struct dap_stream_ch * ch);
diff --git a/dap_stream_ch_proc.c b/dap_stream_ch_proc.c
index c88684507582579e0f521fae369c8f4be4ecc75e..48df97a8db060c3a45eba102e843810be7ce05fb 100644
--- a/dap_stream_ch_proc.c
+++ b/dap_stream_ch_proc.c
@@ -49,7 +49,7 @@ void stream_ch_proc_deinit()
  * @param packet_in_callback
  * @param packet_out_callback
  */
-void stream_ch_proc_add(uint8_t id,dap_stream_ch_callback_t new_callback,dap_stream_ch_callback_t delete_callback,
+void dap_stream_ch_proc_add(uint8_t id,dap_stream_ch_callback_t new_callback,dap_stream_ch_callback_t delete_callback,
                           dap_stream_ch_callback_t packet_in_callback,
                           dap_stream_ch_callback_t packet_out_callback
                           )
diff --git a/dap_stream_ch_proc.h b/dap_stream_ch_proc.h
index 041ffb25bb8703bdd81b68ceade0a4371f22cd45..1847aa42bfd323b28cf39bf550a1c448958856dd 100644
--- a/dap_stream_ch_proc.h
+++ b/dap_stream_ch_proc.h
@@ -40,7 +40,7 @@ typedef struct dap_stream_ch_proc{
 extern int stream_ch_proc_init();
 extern void stream_ch_proc_deinit();
 
-extern void stream_ch_proc_add(uint8_t id,
+extern void dap_stream_ch_proc_add(uint8_t id,
                           dap_stream_ch_callback_t new_callback, dap_stream_ch_callback_t delete_callback,
                           dap_stream_ch_callback_t packet_in_callback,
                           dap_stream_ch_callback_t packet_out_callback