changes for proxy

1 files changed, 7 insertions, 7 deletions

diff --git a/code/msgq.h b/code/msgq.h
index 0bf47b3..9d16f63 100644
--- a/code/msgq.h
+++ b/code/msgq.h
@@ -9,24 +9,24 @@
 struct ECPConnection;
 
 typedef struct ECPMessage {
-    unsigned char payload[ECP_MAX_PKT];
+    unsigned char msg[ECP_MAX_MSG];
     ssize_t size;
 } ECPMessage;
 
 typedef struct ECPConnMsgQ {
     unsigned short empty_idx;
     unsigned short occupied[ECP_MAX_CONN_MSG];
-    unsigned short w_idx[ECP_MAX_PTYPE];
-    unsigned short r_idx[ECP_MAX_PTYPE];
-    unsigned short msg_idx[ECP_MAX_PTYPE][ECP_MAX_CONN_MSG+1];
+    unsigned short w_idx[ECP_MAX_MTYPE];
+    unsigned short r_idx[ECP_MAX_MTYPE];
+    unsigned short msg_idx[ECP_MAX_MTYPE][ECP_MAX_CONN_MSG+1];
     ECPMessage msg[ECP_MAX_CONN_MSG];
     pthread_mutex_t mutex;
-    pthread_cond_t cond[ECP_MAX_PTYPE];
+    pthread_cond_t cond[ECP_MAX_MTYPE];
 } ECPConnMsgQ;
 
 int ecp_conn_msgq_create(struct ECPConnection *conn);
 void ecp_conn_msgq_destroy(struct ECPConnection *conn);
-ssize_t ecp_conn_msgq_push(struct ECPConnection *conn, unsigned char *payload, size_t payload_size);
-ssize_t ecp_conn_msgq_pop(struct ECPConnection *conn, unsigned char ptype, unsigned char *payload, size_t payload_size, unsigned int timeout);
+ssize_t ecp_conn_msgq_push(struct ECPConnection *conn, unsigned char *msg, size_t msg_size);
+ssize_t ecp_conn_msgq_pop(struct ECPConnection *conn, unsigned char mtype, unsigned char *msg, size_t msg_size, unsigned int timeout);
 
 #endif  /* ECP_WITH_PTHREAD */
\ No newline at end of file