| 322 | }; // namespace |
| 323 | |
| 324 | void |
| 325 | hstcpsvr_worker::run() |
| 326 | { |
| 327 | thr_init initobj(dbctx, vshared.shutdown); |
| 328 | |
| 329 | #ifdef __linux__ |
| 330 | if (cshared.sockargs.use_epoll) { |
| 331 | while (!vshared.shutdown && dbctx->check_alive()) { |
| 332 | run_one_ep(); |
| 333 | } |
| 334 | } else if (cshared.sockargs.nonblocking) { |
| 335 | while (!vshared.shutdown && dbctx->check_alive()) { |
| 336 | run_one_nb(); |
| 337 | } |
| 338 | } else { |
| 339 | /* UNUSED */ |
| 340 | fatal_abort("run_one"); |
| 341 | } |
| 342 | #else |
| 343 | while (!vshared.shutdown && dbctx->check_alive()) { |
| 344 | run_one_nb(); |
| 345 | } |
| 346 | #endif |
| 347 | } |
| 348 | |
| 349 | int |
| 350 | hstcpsvr_worker::run_one_nb() |
no test coverage detected