diff options
| author | Anton <anton@picapica> | 2016-11-26 02:59:19 +0400 |
|---|---|---|
| committer | Anton <anton@picapica> | 2016-11-26 02:59:19 +0400 |
| commit | 3dbb6dab7b05aa37369ce2d5d3e593e63a158250 (patch) | |
| tree | 79d1b29590088bb03e80c34e970d5ca07e5ea771 | |
| parent | 3a069e4c0b317793936d7d5cdd1aa67376c3cf82 (diff) | |
| download | pica-pica-3dbb6dab7b05aa37369ce2d5d3e593e63a158250.tar.gz pica-pica-3dbb6dab7b05aa37369ce2d5d3e593e63a158250.zip | |
renamed PICA_listener_conn to PICA_c2c_direct, use same struct for incoming and outgoing direct connections
| -rw-r--r-- | PICA_client.c | 16 | ||||
| -rw-r--r-- | PICA_client.h | 21 |
2 files changed, 18 insertions, 19 deletions
diff --git a/PICA_client.c b/PICA_client.c index 3567a91..57f9877 100644 --- a/PICA_client.c +++ b/PICA_client.c @@ -1890,10 +1890,10 @@ static int process_c2c(struct PICA_c2c *c2c, fd_set *rfds, fd_set *wfds) static void listener_add_connection(struct PICA_listener *lst, SOCKET *s) { - struct PICA_listener_conn *nc; + struct PICA_c2c_direct *nc; int ret; - nc = calloc(1, sizeof(struct PICA_listener_conn)); + nc = calloc(1, sizeof(struct PICA_c2c_direct)); nc->sck = s; nc->ssl = SSL_new(lst->acc->ctx); @@ -1923,7 +1923,7 @@ static void listener_add_connection(struct PICA_listener *lst, SOCKET *s) lst->accepted_connections = nc; } -static int process_listener_conn(struct PICA_listener_conn *conn, fd_set *rfds, fd_set *wfds) +static int process_listener_conn(struct PICA_c2c_direct *conn, fd_set *rfds, fd_set *wfds) { if (conn->peer_cert == NULL) { @@ -1960,7 +1960,7 @@ static int process_listener_conn(struct PICA_listener_conn *conn, fd_set *rfds, static int process_listener(struct PICA_listener *lst, fd_set *rfds, fd_set *wfds) { - struct PICA_listener_conn *conn; + struct PICA_c2c_direct *conn; if (FD_ISSET(lst->sck_listener, rfds)) { @@ -1980,7 +1980,7 @@ static int process_listener(struct PICA_listener *lst, fd_set *rfds, fd_set *wfd while(conn) { - struct PICA_listener_conn *kill_ptr = NULL; + struct PICA_c2c_direct *kill_ptr = NULL; if (process_listener_conn(conn, rfds, wfds) != PICA_OK) { @@ -2025,7 +2025,7 @@ int PICA_event_loop(struct PICA_c2n **connections, int timeout) while(ic2n && *ic2n) { struct PICA_c2c *ic2c; - struct PICA_listener_conn *ilstcon; + struct PICA_c2c_direct *ilstcon; //printf("event_loop: adding c2n %p\n", *ic2n);//debug @@ -2790,7 +2790,7 @@ void PICA_close_acc(struct PICA_acc *a) free(a); } -void listener_close_conn(struct PICA_listener_conn *c) +void listener_close_conn(struct PICA_c2c_direct *c) { SSL_free(c->ssl); SHUTDOWN(c->sck); @@ -2807,7 +2807,7 @@ void PICA_close_listener(struct PICA_listener *l) while(l->accepted_connections) { - struct PICA_listener_conn *c = l->accepted_connections; + struct PICA_c2c_direct *c = l->accepted_connections; l->accepted_connections = c->next; listener_close_conn(c); } diff --git a/PICA_client.h b/PICA_client.h index 764b9dd..c63d106 100644 --- a/PICA_client.h +++ b/PICA_client.h @@ -189,6 +189,14 @@ enum PICA_directc2c_state PICA_DIRECTC2C_STATE_ACTIVE }; +struct PICA_c2c_direct +{ + SOCKET sck; + SSL *ssl; + X509 *peer_cert; + struct PICA_c2c_direct *next; +}; + struct PICA_c2c { const struct PICA_acc *acc; @@ -196,8 +204,7 @@ struct PICA_c2c unsigned char peer_id[PICA_ID_SIZE]; SOCKET sck_data; SSL *ssl; - SOCKET direct_sck; - SSL *direct_ssl; + struct PICA_c2c_direct *direct; int outgoing;//1 если создание канала инициировано локальным клиентом, 0 - если собеседником X509 *peer_cert; //unsigned char msgbuf[PICA_CHNMSGBUFLEN]; @@ -227,14 +234,6 @@ struct PICA_c2c int disconnect_on_empty_write_buf; }; -struct PICA_listener_conn -{ - SOCKET sck; - SSL *ssl; - X509 *peer_cert; - struct PICA_listener_conn *next; -}; - struct PICA_listener { const struct PICA_acc *acc; @@ -246,7 +245,7 @@ struct PICA_listener in_addr_t public_addr_ipv4; const char *public_addr_dns; - struct PICA_listener_conn *accepted_connections; + struct PICA_c2c_direct *accepted_connections; }; struct PICA_client_callbacks |
