| 281 | } |
| 282 | |
| 283 | std::string |
| 284 | utils::internal::consumeFromTSIOBufferReader(TSIOBufferReader reader) |
| 285 | { |
| 286 | std::string str; |
| 287 | int avail = TSIOBufferReaderAvail(reader); |
| 288 | |
| 289 | if (avail != TS_ERROR) { |
| 290 | int consumed = 0; |
| 291 | if (avail > 0) { |
| 292 | str.reserve(avail + 1); |
| 293 | |
| 294 | int64_t data_len; |
| 295 | const char *char_data; |
| 296 | TSIOBufferBlock block = TSIOBufferReaderStart(reader); |
| 297 | while (block != nullptr) { |
| 298 | char_data = TSIOBufferBlockReadStart(block, reader, &data_len); |
| 299 | str.append(char_data, data_len); |
| 300 | consumed += data_len; |
| 301 | block = TSIOBufferBlockNext(block); |
| 302 | } |
| 303 | } |
| 304 | TSIOBufferReaderConsume(reader, consumed); |
| 305 | } else { |
| 306 | LOG_ERROR("TSIOBufferReaderAvail returned error code %d for reader %p", avail, reader); |
| 307 | } |
| 308 | |
| 309 | return str; |
| 310 | } |
| 311 | |
| 312 | HttpVersion |
| 313 | utils::internal::getHttpVersion(TSMBuffer hdr_buf, TSMLoc hdr_loc) |
nothing calls this directly
no test coverage detected