Home
last modified time | relevance | path

Searched refs:onIngress (Results 1 – 25 of 35) sorted by relevance

12

/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/test/
H A DHTTP1xCodecTest.cpp87 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 DSPDYCodecTest.cpp558 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 DDefaultHTTPCodecFactoryTest.cpp64 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 DHQCodecTest.cpp73 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 DHQMultiCodecTest.cpp75 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 DHTTPParallelCodecTest.h58 size_t parsed = codec.onIngress(*ingress); in parseImpl()
H A DTestUtils.h50 return codec->onIngress(*input.front());
66 consumed = codec->onIngress(*input.front());
H A DMockHTTPCodec.h34 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 DQPACKInterop.cpp129 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 DRFC1867.cpp56 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 DRFC1867.h59 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 DHTTPDefaultSessionCodecFactoryTest.cpp159 codec->onIngress(*output.front()); in TEST_P()
169 codec->onIngress( in TEST_P()
H A DHTTPSessionActivityTrackerTest.cpp55 TEST_F(HTTPSessionActivityTrackerTest, onIngress) { in TEST_F() argument
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/
H A DHQMultiCodec.h120 size_t onIngress(const folly::IOBuf& buf) override { in onIngress() function
121 auto res = getCurrentCodec().onIngress(buf); in onIngress()
H A DHTTPCodecFilter.cpp201 size_t PassThroughHTTPCodecFilter::onIngress(const folly::IOBuf& buf) { in onIngress() function in proxygen::PassThroughHTTPCodecFilter
202 return call_->onIngress(buf); in onIngress()
H A DHQControlCodec.h75 size_t onIngress(const folly::IOBuf& /*buf*/) override { in onIngress() function
H A DHQStreamCodec.h71 size_t onIngress(const folly::IOBuf& buf) override { in onIngress() function
H A DHTTP1xCodec.h57 size_t onIngress(const folly::IOBuf& buf) override;
H A DSPDYCodec.h51 size_t onIngress(const folly::IOBuf& buf) override;
H A DHTTPCodecFilter.h140 size_t onIngress(const folly::IOBuf& buf) override;
H A DHTTPCodec.h476 virtual size_t onIngress(const folly::IOBuf& buf) = 0;
H A DHTTP2Codec.h49 size_t onIngress(const folly::IOBuf& buf) override;
H A DHTTP1xCodec.cpp176 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 DRFC1867Test.cpp142 rem = codec_.onIngress(std::move(chunk)); in parse()
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/
H A DHTTPSession.cpp531 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()

12