| 417 | } |
| 418 | |
| 419 | void |
| 420 | hstcpcli::response_buf_remove() |
| 421 | { |
| 422 | if (response_end_offset == 0) { |
| 423 | close(); |
| 424 | set_error(-1, "response_buf_remove: protocol out of sync"); |
| 425 | return; |
| 426 | } |
| 427 | readbuf.erase_front(response_end_offset); |
| 428 | response_end_offset = 0; |
| 429 | --num_req_rcvd; |
| 430 | cur_row_offset = 0; |
| 431 | num_flds = 0; |
| 432 | flds.clear(); |
| 433 | } |
| 434 | |
| 435 | hstcpcli_ptr |
| 436 | hstcpcli_i::create(const socket_args& args) |