| 383 | } |
| 384 | |
| 385 | const string_ref * |
| 386 | hstcpcli::get_next_row() |
| 387 | { |
| 388 | if (num_flds == 0) { |
| 389 | DBG(fprintf(stderr, "GNR NF 0\n")); |
| 390 | return 0; |
| 391 | } |
| 392 | if (flds.size() < num_flds) { |
| 393 | flds.resize(num_flds); |
| 394 | } |
| 395 | char *start = readbuf.begin() + cur_row_offset; |
| 396 | char *const finish = readbuf.begin() + response_end_offset - 1; |
| 397 | if (start >= finish) { /* start[0] == nl */ |
| 398 | DBG(fprintf(stderr, "GNR FIN 0 %p %p\n", start, finish)); |
| 399 | return 0; |
| 400 | } |
| 401 | for (size_t i = 0; i < num_flds; ++i) { |
| 402 | skip_one(start, finish); |
| 403 | char *const fld_begin = start; |
| 404 | read_token(start, finish); |
| 405 | char *const fld_end = start; |
| 406 | char *wp = fld_begin; |
| 407 | if (is_null_expression(fld_begin, fld_end)) { |
| 408 | /* null */ |
| 409 | flds[i] = string_ref(); |
| 410 | } else { |
| 411 | unescape_string(wp, fld_begin, fld_end); /* in-place */ |
| 412 | flds[i] = string_ref(fld_begin, wp); |
| 413 | } |
| 414 | } |
| 415 | cur_row_offset = start - readbuf.begin(); |
| 416 | return &flds[0]; |
| 417 | } |
| 418 | |
| 419 | void |
| 420 | hstcpcli::response_buf_remove() |
no test coverage detected