/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/test/ |
H A D | HTTP1xCodecTest.cpp | 87 codec.onIngress(*buffer); in TEST() 89 codec.onIngress(*buffer); in TEST() 100 codec.onIngress(*buffer); in TEST() 106 codec.onIngress(*buffer); in TEST() 117 codec.onIngress(*buffer); in TEST() 137 codec.onIngress(*buffer); in TEST() 735 codec.onIngress(*resp); in TEST() 905 codec.onIngress(*buf); in TEST() 922 codec.onIngress(*buf); in TEST() 1102 codec.onIngress( in TEST() [all …]
|
H A D | SPDYCodecTest.cpp | 558 ingressCodec.onIngress(*syn); in TEST() 658 ingressCodec.onIngress(*syn); in TEST() 677 ingressCodec.onIngress(*syn); in TEST() 697 ingressCodec.onIngress(*syn); in TEST() 730 ingressCodec.onIngress(*syn); in TEST() 764 ingressCodec.onIngress(*syn); in TEST() 798 ingressCodec.onIngress(*syn); in TEST() 832 ingressCodec.onIngress(*syn); in TEST() 850 ingressCodec.onIngress(*syn); in TEST() 863 ingressCodec.onIngress(*syn); in TEST() [all …]
|
H A D | DefaultHTTPCodecFactoryTest.cpp | 64 codec->onIngress(*output.front()); in TEST_P() 73 codec->onIngress(*folly::IOBuf::copyBuffer("GET /foo\xff HTTP/1.1\r\n\r\n")); in TEST_P()
|
H A D | HQCodecTest.cpp | 73 auto consumed = downstreamCodec_->onIngress(*queue_.front()); in parse() 78 auto consumed = upstreamCodec_->onIngress(*queue_.front()); in parseUpstream() 371 auto consumed = downstreamCodec_->onIngress(*queue_.front()); in qpackTest() 387 consumed = downstreamCodec_->onIngress(*queue_.front()); in qpackTest() 436 downstreamCodec_->onIngress(*queue_.front()); in TEST_F() 444 downstreamCodec_->onIngress(*queue_.front()); in TEST_F() 456 downstreamCodec_->onIngress(*queue_.front()); in TEST_F() 458 downstreamCodec_->onIngress(*queue_.front()); in TEST_F() 468 upstreamCodec_->onIngress(*queue_.front()); in TEST_F() 470 upstreamCodec_->onIngress(*queue_.front()); in TEST_F() [all …]
|
H A D | HQMultiCodecTest.cpp | 75 EXPECT_EQ(codec_.onIngress(*writeBuf_.front()), writeBuf_.chainLength()); in TEST_F() 90 EXPECT_EQ(codec_.onIngress(*writeBuf_.front()), writeBuf_.chainLength()); in TEST_F()
|
H A D | HTTPParallelCodecTest.h | 58 size_t parsed = codec.onIngress(*ingress); in parseImpl()
|
H A D | TestUtils.h | 50 return codec->onIngress(*input.front()); 66 consumed = codec->onIngress(*input.front());
|
H A D | MockHTTPCodec.h | 34 MOCK_METHOD1(onIngress, size_t(const folly::IOBuf&));
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/compress/experimental/interop/ |
H A D | QPACKInterop.cpp | 129 onIngress(inbuf); in read() 139 virtual void onIngress(folly::IOBufQueue& inbuf) = 0; 155 void onIngress(folly::IOBufQueue& inbuf) override { in onIngress() function in __anon4a26e5930111::CompressedReader 319 void onIngress(folly::IOBufQueue& input) override { in onIngress() function
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/experimental/ |
H A D | RFC1867.cpp | 56 std::unique_ptr<IOBuf> RFC1867Codec::onIngress(std::unique_ptr<IOBuf> data) { in onIngress() function in proxygen::RFC1867Codec 117 headerParser_.onIngress(*dummyBuf); in onIngress() 125 size_t bytesParsed = headerParser_.onIngress(*input_.front()); in onIngress()
|
H A D | RFC1867.h | 59 std::unique_ptr<folly::IOBuf> onIngress(std::unique_ptr<folly::IOBuf> data);
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/ |
H A D | HTTPDefaultSessionCodecFactoryTest.cpp | 159 codec->onIngress(*output.front()); in TEST_P() 169 codec->onIngress( in TEST_P()
|
H A D | HTTPSessionActivityTrackerTest.cpp | 55 TEST_F(HTTPSessionActivityTrackerTest, onIngress) { in TEST_F() argument
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/ |
H A D | HQMultiCodec.h | 120 size_t onIngress(const folly::IOBuf& buf) override { in onIngress() function 121 auto res = getCurrentCodec().onIngress(buf); in onIngress()
|
H A D | HTTPCodecFilter.cpp | 201 size_t PassThroughHTTPCodecFilter::onIngress(const folly::IOBuf& buf) { in onIngress() function in proxygen::PassThroughHTTPCodecFilter 202 return call_->onIngress(buf); in onIngress()
|
H A D | HQControlCodec.h | 75 size_t onIngress(const folly::IOBuf& /*buf*/) override { in onIngress() function
|
H A D | HQStreamCodec.h | 71 size_t onIngress(const folly::IOBuf& buf) override { in onIngress() function
|
H A D | HTTP1xCodec.h | 57 size_t onIngress(const folly::IOBuf& buf) override;
|
H A D | SPDYCodec.h | 51 size_t onIngress(const folly::IOBuf& buf) override;
|
H A D | HTTPCodecFilter.h | 140 size_t onIngress(const folly::IOBuf& buf) override;
|
H A D | HTTPCodec.h | 476 virtual size_t onIngress(const folly::IOBuf& buf) = 0;
|
H A D | HTTP2Codec.h | 49 size_t onIngress(const folly::IOBuf& buf) override;
|
H A D | HTTP1xCodec.cpp | 176 size_t HTTP1xCodec::onIngress(const IOBuf& buf) { in onIngress() function in proxygen::HTTP1xCodec 197 return onIngress(buf); in onIngress()
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/experimental/test/ |
H A D | RFC1867Test.cpp | 142 rem = codec_.onIngress(std::move(chunk)); in parse()
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/ |
H A D | HTTPSession.cpp | 531 size_t bytesParsed = codec_->onIngress(*readBuf_.front()); in processReadData() 2561 void HTTPSession::PingProber::refreshTimeout(bool onIngress) { in refreshTimeout() argument 2562 if (!pingVal_ && (!onIngress || extendIntervalOnIngress_)) { in refreshTimeout()
|