| 285 | return 0; |
| 286 | } |
| 287 | int serve_request() |
| 288 | { |
| 289 | sk->m_serving_count++; |
| 290 | ResponseSender sender(this, &Context::response_sender); |
| 291 | int ret = func(&request, sender, stream); |
| 292 | sk->m_serving_count--; |
| 293 | sk->m_cond_served.notify_all(); |
| 294 | return ret; |
| 295 | } |
| 296 | int response_sender(iovector* resp) |
| 297 | { |
| 298 | assert(w_lock); |
no test coverage detected