MCPcopy Create free account
hub / github.com/apache/tomcat / SavedRequestStreamInputBuffer

Class SavedRequestStreamInputBuffer

java/org/apache/coyote/http2/Stream.java:1545–1610  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1543
1544
1545 class SavedRequestStreamInputBuffer extends StreamInputBuffer {
1546
1547 private final SavedRequestInputFilter inputFilter;
1548
1549 SavedRequestStreamInputBuffer(SavedRequestInputFilter inputFilter) {
1550 this.inputFilter = inputFilter;
1551 }
1552
1553
1554 @Override
1555 public int doRead(ApplicationBufferHandler handler) throws IOException {
1556 return inputFilter.doRead(handler);
1557 }
1558
1559 @Override
1560 public int available() {
1561 return inputFilter.available();
1562 }
1563
1564 @Override
1565 void receiveReset() {
1566 // NO-OP
1567 }
1568
1569 @Override
1570 void swallowUnread() throws IOException {
1571 // NO-OP
1572 }
1573
1574 @Override
1575 void notifyEof() {
1576 // NO-OP
1577 }
1578
1579 @Override
1580 ByteBuffer getInBuffer(boolean create) {
1581 return null;
1582 }
1583
1584 @Override
1585 void onDataAvailable() throws IOException {
1586 // NO-OP
1587 }
1588
1589 @Override
1590 boolean isReadyForRead() {
1591 return true;
1592 }
1593
1594 @Override
1595 boolean isRequestBodyFullyRead() {
1596 return inputFilter.isFinished();
1597 }
1598
1599 @Override
1600 void insertReplayedBody(ByteChunk body) {
1601 // NO-OP
1602 }

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected