diff options
Diffstat (limited to 'pjlib')
-rw-r--r-- | pjlib/include/pj/activesock.h | 2 | ||||
-rw-r--r-- | pjlib/src/pj/activesock.c | 9 |
2 files changed, 8 insertions, 3 deletions
diff --git a/pjlib/include/pj/activesock.h b/pjlib/include/pj/activesock.h index e9f4759d..dd5d8270 100644 --- a/pjlib/include/pj/activesock.h +++ b/pjlib/include/pj/activesock.h @@ -413,6 +413,7 @@ PJ_DECL(pj_status_t) pj_activesock_sendto(pj_activesock_t *asock, const pj_sockaddr_t *addr, int addr_len); +#if PJ_HAS_TCP /** * Starts asynchronous socket accept() operations on this active socket. * Application must bind the socket before calling this function. This @@ -457,6 +458,7 @@ PJ_DECL(pj_status_t) pj_activesock_start_connect(pj_activesock_t *asock, const pj_sockaddr_t *remaddr, int addr_len); +#endif /* PJ_HAS_TCP */ /** * @} diff --git a/pjlib/src/pj/activesock.c b/pjlib/src/pj/activesock.c index c4288a2a..45173c5b 100644 --- a/pjlib/src/pj/activesock.c +++ b/pjlib/src/pj/activesock.c @@ -75,13 +75,14 @@ static void ioqueue_on_read_complete(pj_ioqueue_key_t *key, static void ioqueue_on_write_complete(pj_ioqueue_key_t *key, pj_ioqueue_op_key_t *op_key, pj_ssize_t bytes_sent); +#if PJ_HAS_TCP static void ioqueue_on_accept_complete(pj_ioqueue_key_t *key, pj_ioqueue_op_key_t *op_key, pj_sock_t sock, pj_status_t status); static void ioqueue_on_connect_complete(pj_ioqueue_key_t *key, pj_status_t status); - +#endif PJ_DEF(void) pj_activesock_cfg_default(pj_activesock_cfg *cfg) { @@ -121,8 +122,10 @@ PJ_DEF(pj_status_t) pj_activesock_create( pj_pool_t *pool, pj_bzero(&ioq_cb, sizeof(ioq_cb)); ioq_cb.on_read_complete = &ioqueue_on_read_complete; ioq_cb.on_write_complete = &ioqueue_on_write_complete; +#if PJ_HAS_TCP ioq_cb.on_connect_complete = &ioqueue_on_connect_complete; ioq_cb.on_accept_complete = &ioqueue_on_accept_complete; +#endif status = pj_ioqueue_register_sock(pool, ioqueue, sock, asock, &ioq_cb, &asock->key); @@ -487,7 +490,7 @@ static void ioqueue_on_write_complete(pj_ioqueue_key_t *key, } } - +#if PJ_HAS_TCP PJ_DEF(pj_status_t) pj_activesock_start_accept(pj_activesock_t *asock, pj_pool_t *pool) { @@ -577,7 +580,6 @@ PJ_DEF(pj_status_t) pj_activesock_start_connect( pj_activesock_t *asock, return pj_ioqueue_connect(asock->key, remaddr, addr_len); } - static void ioqueue_on_connect_complete(pj_ioqueue_key_t *key, pj_status_t status) { @@ -594,4 +596,5 @@ static void ioqueue_on_connect_complete(pj_ioqueue_key_t *key, } } } +#endif /* PJ_HAS_TCP */ |