summaryrefslogtreecommitdiff
path: root/ecp/src/msgq.h
blob: 394209fccfa820ca8baff2e9116d803a0af29f43 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
#ifdef ECP_WITH_MSGQ

#define ECP_MSGQ_MAX_MSG        32

typedef struct ECPConnMsgQ {
    unsigned short idx_w[ECP_MAX_MTYPE];
    unsigned short idx_r[ECP_MAX_MTYPE];
    ecp_seq_t seq_start;
    ecp_seq_t seq_max;
    ecp_seq_t seq_msg[ECP_MAX_MTYPE][ECP_MSGQ_MAX_MSG];
    pthread_cond_t cond[ECP_MAX_MTYPE];
    pthread_mutex_t mutex;
} ECPConnMsgQ;

int ecp_conn_msgq_create(ECPConnMsgQ *msgq);
void ecp_conn_msgq_destroy(ECPConnMsgQ *msgq);
int ecp_conn_msgq_start(ECPConnMsgQ *msgq, ecp_seq_t seq);

int ecp_conn_msgq_push(struct ECPConnection *conn, ecp_seq_t seq, unsigned char mtype);
ssize_t ecp_conn_msgq_pop(struct ECPConnection *conn, unsigned char mtype, unsigned char *msg, size_t msg_size, ecp_cts_t timeout);

#endif  /* ECP_WITH_MSGQ */