|
|
|
@ -89,7 +89,7 @@ typedef struct __connection_t {
|
|
|
|
|
/* Other stuff */
|
|
|
|
|
pthread_t thrd_poll[8];
|
|
|
|
|
volatile uint8_t flags; /** < flags of the connection */
|
|
|
|
|
volatile uint8_t usecount;
|
|
|
|
|
volatile uint8_t usecount; /** < use count for the connection link */
|
|
|
|
|
usrtc_node_t csnode; /** < node to store the connection within list */
|
|
|
|
|
} conn_t;
|
|
|
|
|
|
|
|
|
@ -130,7 +130,7 @@ typedef struct __channel_t {
|
|
|
|
|
typedef struct __message_t {
|
|
|
|
|
chnl_t *pch; /** < channel of the message(if applicable) */
|
|
|
|
|
pthread_mutex_t wait; /** < special wait mutex, used for pending list and sync */
|
|
|
|
|
sntllv2_head_t mhead;
|
|
|
|
|
sntllv2_head_t mhead; /** < last actual head of the message */
|
|
|
|
|
void *payload; /** < payload */
|
|
|
|
|
} sxmsg_t;
|
|
|
|
|
|
|
|
|
@ -203,6 +203,8 @@ extern "C" {
|
|
|
|
|
/* API */
|
|
|
|
|
int sntl_init(void);
|
|
|
|
|
|
|
|
|
|
void sntl_finalize(void);
|
|
|
|
|
|
|
|
|
|
int connections_init(conn_sys_t *ssys);
|
|
|
|
|
|
|
|
|
|
conn_sys_t *connections_create(void);
|
|
|
|
|