diff options
Diffstat (limited to 'pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c')
| -rw-r--r-- | pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c b/pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c index bd701655..445c9d7d 100644 --- a/pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c +++ b/pjlib/src/pjlib-test/udp_echo_srv_ioqueue.c @@ -36,7 +36,7 @@ struct op_key int addrlen; }; -static void on_read_complete(pj_ioqueue_key_t *key, +static void on_read_complete(pj_ioqueue_key_t *ioq_key, pj_ioqueue_op_key_t *op_key, pj_ssize_t bytes_received) { @@ -62,7 +62,7 @@ static void on_read_complete(pj_ioqueue_key_t *key, pj_memcpy(send_rec->buffer, recv_rec->buffer, bytes_received); pj_memcpy(&send_rec->addr, &recv_rec->addr, recv_rec->addrlen); send_rec->addrlen = recv_rec->addrlen; - rc = pj_ioqueue_sendto(key, &send_rec->op_key_, + rc = pj_ioqueue_sendto(ioq_key, &send_rec->op_key_, send_rec->buffer, &sent, 0, &send_rec->addr, send_rec->addrlen); send_rec->is_pending = (rc==PJ_EPENDING); @@ -75,7 +75,7 @@ static void on_read_complete(pj_ioqueue_key_t *key, if (!send_rec->is_pending) { bytes_received = recv_rec->size; - rc = pj_ioqueue_recvfrom(key, &recv_rec->op_key_, + rc = pj_ioqueue_recvfrom(ioq_key, &recv_rec->op_key_, recv_rec->buffer, &bytes_received, 0, &recv_rec->addr, &recv_rec->addrlen); recv_rec->is_pending = (rc==PJ_EPENDING); @@ -99,7 +99,7 @@ static void on_read_complete(pj_ioqueue_key_t *key, } } -static void on_write_complete(pj_ioqueue_key_t *key, +static void on_write_complete(pj_ioqueue_key_t *ioq_key, pj_ioqueue_op_key_t *op_key, pj_ssize_t bytes_sent) { @@ -114,7 +114,7 @@ static void on_write_complete(pj_ioqueue_key_t *key, } send_rec->is_pending = 0; - on_read_complete(key, &send_rec->peer->op_key_, 0); + on_read_complete(ioq_key, &send_rec->peer->op_key_, 0); } static int worker_thread(void *arg) |