| 325 | } |
| 326 | |
| 327 | int master_threads::service_on_timeout(void* ctx, ACL_VSTREAM* client) |
| 328 | { |
| 329 | master_threads* mt = (master_threads *) ctx; |
| 330 | acl_assert(mt); |
| 331 | |
| 332 | socket_stream* stream = (socket_stream*) client->context; |
| 333 | if (stream == NULL) { |
| 334 | logger_fatal("client->context is null!"); |
| 335 | } |
| 336 | |
| 337 | acl_assert(mt != NULL); |
| 338 | |
| 339 | return mt->thread_on_timeout(stream) == true ? 0 : -1; |
| 340 | } |
| 341 | |
| 342 | void master_threads::service_on_close(void* ctx, ACL_VSTREAM* client) |
| 343 | { |
nothing calls this directly
no test coverage detected