blob: 0bf47b33907538ea12028a3e31d0af935597f891 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
#ifdef ECP_WITH_PTHREAD
#include <pthread.h>
#include <string.h>
#define ECP_MAX_CONN_MSG 8
#define ECP_ERR_MAX_CONN_MSG -100
struct ECPConnection;
typedef struct ECPMessage {
unsigned char payload[ECP_MAX_PKT];
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];
ECPMessage msg[ECP_MAX_CONN_MSG];
pthread_mutex_t mutex;
pthread_cond_t cond[ECP_MAX_PTYPE];
} 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);
#endif /* ECP_WITH_PTHREAD */
|
