From 7c70a430f9c708be2fcce8c9a0d8cecde7f75fc0 Mon Sep 17 00:00:00 2001 From: Uros Majstorovic Date: Tue, 23 May 2017 03:49:54 +0200 Subject: changes for proxy --- code/msgq.h | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'code/msgq.h') 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 -- cgit v1.2.3