| 572 | } |
| 573 | |
| 574 | int64_t |
| 575 | TSIOBufferBlockReadAvail(TSIOBufferBlock blockp, TSIOBufferReader readerp) |
| 576 | { |
| 577 | sdk_assert(sdk_sanity_check_iocore_structure(blockp) == TS_SUCCESS); |
| 578 | sdk_assert(sdk_sanity_check_iocore_structure(readerp) == TS_SUCCESS); |
| 579 | |
| 580 | IOBufferBlock *blk = (IOBufferBlock *)blockp; |
| 581 | IOBufferReader *reader = (IOBufferReader *)readerp; |
| 582 | int64_t avail; |
| 583 | |
| 584 | avail = blk->read_avail(); |
| 585 | |
| 586 | if (reader->block.get() == blk) { |
| 587 | avail -= reader->start_offset; |
| 588 | if (avail < 0) { |
| 589 | avail = 0; |
| 590 | } |
| 591 | } |
| 592 | |
| 593 | return avail; |
| 594 | } |
| 595 | |
| 596 | char * |
| 597 | TSIOBufferBlockWriteStart(TSIOBufferBlock blockp, int64_t *avail) |