| 87 | } |
| 88 | |
| 89 | void tcp_start(CLIENT_ENTRY *entry) |
| 90 | { |
| 91 | if (entry->client == NULL || entry->server == NULL) |
| 92 | return; |
| 93 | acl_aio_ctl(entry->client, |
| 94 | ACL_AIO_CTL_READ_HOOK_ADD, read_callback, entry, |
| 95 | ACL_AIO_CTL_CLOSE_HOOK_ADD, io_close_fn, entry, |
| 96 | ACL_AIO_CTL_TIMEO_HOOK_ADD, io_timeout_fn, entry, |
| 97 | ACL_AIO_CTL_TIMEOUT, entry->service->rw_timeout, |
| 98 | ACL_AIO_CTL_CTX, entry, |
| 99 | ACL_AIO_CTL_END); |
| 100 | |
| 101 | acl_aio_ctl(entry->server, |
| 102 | ACL_AIO_CTL_READ_HOOK_ADD, read_callback, entry, |
| 103 | ACL_AIO_CTL_CLOSE_HOOK_ADD, io_close_fn, entry, |
| 104 | ACL_AIO_CTL_TIMEO_HOOK_ADD, io_timeout_fn, entry, |
| 105 | ACL_AIO_CTL_TIMEOUT, entry->service->rw_timeout, |
| 106 | ACL_AIO_CTL_CTX, entry, |
| 107 | ACL_AIO_CTL_END); |
| 108 | |
| 109 | acl_aio_read(entry->client); |
| 110 | acl_aio_read(entry->server); |
| 111 | } |
no test coverage detected
searching dependent graphs…