blob: 54319e026e929784eba934139732c382f34c2da6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
#ifdef ECP_WITH_PTHREAD
#include <pthread.h>
#include <string.h>
#define ECP_MAX_CONN_MSG 32
#define ECP_ERR_MAX_CONN_MSG -100
typedef struct ECPConnMsgQ {
unsigned short idx_w[ECP_MAX_MTYPE];
unsigned short idx_r[ECP_MAX_MTYPE];
ecp_seq_t seq_msg[ECP_MAX_MTYPE][ECP_MAX_CONN_MSG];
pthread_cond_t cond[ECP_MAX_MTYPE];
pthread_mutex_t mutex;
} ECPConnMsgQ;
int ecp_conn_msgq_create(struct ECPConnection *conn);
void ecp_conn_msgq_destroy(struct ECPConnection *conn);
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, unsigned int timeout);
#endif /* ECP_WITH_PTHREAD */
|
