| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/test/ |
| H A D | HTTPTransactionMocks.h | 70 size_t sendBody(HTTPTransaction* txn, in sendBody()
76 size_t sendBody(HTTPTransaction* txn, in sendBody()
90 (HTTPTransaction*, size_t),
104 (HTTPTransaction*, HTTPPriority),
110 (HTTPTransaction*, uint32_t),
118 MOCK_METHOD((HTTPTransaction*),
124 MOCK_METHOD((HTTPTransaction*),
126 (HTTPTransaction::Handler * handler,
164 HTTPTransaction*(HTTPTransaction::Handler* handler,
364 : HTTPTransaction(direction, in HTTPTransaction() function
[all …]
|
| H A D | MockByteEventTracker.h | 25 void(uint64_t, HTTPTransaction*, ByteEvent::Callback));
27 void(uint64_t, HTTPTransaction*, ByteEvent::Callback));
35 void(HTTPTransaction*, uint64_t, ByteEvent::Callback));
40 void(HTTPTransaction*, uint64_t, ByteEvent::Callback));
47 HTTPTransaction*,
55 HTTPTransaction*,
|
| H A D | HQSessionMocks.h | 161 void(const HTTPTransaction* /* txn */,
167 void(const HTTPTransaction* /* txn */,
176 void(const HTTPTransaction* /* txn */));
197 using PushedTxnF = std::function<void(const HTTPTransaction*,
204 std::function<void(const HTTPTransaction*)>;
335 txn_->HTTPTransaction::setHandler(handler);
388 HTTPTransaction::Handler*(HTTPTransaction*));
398 MOCK_METHOD1(newTransaction, HTTPTransaction*(HTTPTransaction::Handler*));
420 txn->HTTPTransaction::setHandler(hdlr); in makeMockTransaction()
425 return txn->HTTPTransaction::canSendHeaders(); in makeMockTransaction()
[all …]
|
| H A D | HTTPSessionMocks.h | 26 HTTPHandlerBase(HTTPTransaction* txn, HTTPMessage* msg) in HTTPHandlerBase()
146 HTTPTransaction* txn_{nullptr};
147 HTTPTransaction* pushedTxn_{nullptr};
154 , public HTTPTransaction::Handler {
159 MockHTTPHandler(HTTPTransaction& txn, in MockHTTPHandler()
230 GMOCK_NOEXCEPT_METHOD1(onExTransaction, void(HTTPTransaction*));
240 void expectTransaction(HTTPTransaction** pTxn = nullptr) {
400 , public HTTPTransaction::PushHandler {
404 MockHTTPPushHandler(HTTPTransaction& txn, in MockHTTPPushHandler()
443 HTTPTransactionHandler*(HTTPTransaction*,
[all …]
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/session/ |
| H A D | HTTPTransaction.cpp | 60 HTTPTransaction::HTTPTransaction( in HTTPTransaction() function in proxygen::HTTPTransaction
166 HTTPTransaction::~HTTPTransaction() { in ~HTTPTransaction()
461 void HTTPTransaction::onIngressEOM() { in onIngressEOM()
1221 size_t HTTPTransaction::sendEOMNow() { in sendEOMNow()
1291 void HTTPTransaction::sendEOM() { in sendEOM()
1336 void HTTPTransaction::sendAbort() { in sendAbort()
1389 void HTTPTransaction::pauseIngress() { in pauseIngress()
1471 void HTTPTransaction::pauseEgress() { in pauseEgress()
1587 bool HTTPTransaction::onPushedTransaction(HTTPTransaction* pushTxn) { in onPushedTransaction()
1609 bool HTTPTransaction::onExTransaction(HTTPTransaction* exTxn) { in onExTransaction()
[all …]
|
| H A D | HTTPSession.h | 50 , public HTTPTransaction::Transport
386 HTTPTransaction* txn) = 0;
502 void sendHeaders(HTTPTransaction* txn,
506 size_t sendBody(HTTPTransaction* txn,
510 size_t sendBody(HTTPTransaction*, in sendBody() argument
517 size_t sendEOM(HTTPTransaction* txn,
519 size_t sendAbort(HTTPTransaction* txn,
535 HTTPTransaction* newExTransaction(
642 HTTPTransaction* createTransaction(
853 void commonEom(HTTPTransaction* txn,
[all …]
|
| H A D | HTTPTransaction.h | 144 class HTTPTransaction; variable
403 class HTTPTransaction
478 HTTPTransaction*, in sendHeadersWithDelegate() argument
488 virtual size_t sendBody(HTTPTransaction*,
553 HTTPTransaction::PushHandler* handler,
556 virtual HTTPTransaction* newExTransaction(HTTPTransaction::Handler* handler,
622 HTTPTransaction(
641 ~HTTPTransaction() override;
1553 HTTPTransaction(const HTTPTransaction&) = delete;
1554 HTTPTransaction& operator=(const HTTPTransaction&) = delete;
[all …]
|
| H A D | HTTPSessionController.h | 24 class HTTPTransaction; variable
43 virtual HTTPTransactionHandler* getRequestHandler(HTTPTransaction& txn,
53 HTTPTransaction* txn,
61 HTTPTransaction* txn, const folly::SocketAddress& localAddress) = 0;
115 HTTPTransactionHandler* getRequestHandler(HTTPTransaction& /*txn*/, in getRequestHandler() argument
128 HTTPTransaction* /*txn*/, in getParseErrorHandler() argument
139 HTTPTransaction* /*txn*/, in getTransactionTimeoutHandler() argument
|
| H A D | HQDownstreamSession.h | 35 HTTPTransaction::Handler* getTransactionTimeoutHandler( in getTransactionTimeoutHandler()
36 HTTPTransaction* txn) override { in getTransactionTimeoutHandler()
41 void setupOnHeadersComplete(HTTPTransaction* txn, HTTPMessage* msg) override;
63 HTTPTransaction* newPushedTransaction(
65 HTTPTransaction::PushHandler*, /* handler */
131 void transactionTimeout(HTTPTransaction* txn) noexcept override { in transactionTimeout()
136 void sendPushPromise(HTTPTransaction* /* txn */,
148 void pauseIngress(HTTPTransaction* /* txn */) noexcept override { in pauseIngress() argument
154 void resumeIngress(HTTPTransaction* /* txn */) noexcept override { in resumeIngress() argument
|
| H A D | ByteEventTracker.h | 85 HTTPTransaction* txn,
89 HTTPTransaction* txn,
93 HTTPTransaction* txn,
97 HTTPTransaction* txn,
115 HTTPTransaction* /*txn*/,
122 HTTPTransaction* /*txn*/,
|
| H A D | HTTP2PriorityQueue.h | 23 class HTTPTransaction; variable
43 HTTPTransaction* txn,
120 HTTPTransaction* txn,
147 bool(HTTPCodec::StreamID, HTTPTransaction*, double)>& fn, in iterate() argument
162 using NextEgressResult = std::vector<std::pair<HTTPTransaction*, double>>;
208 HTTPTransaction* txn,
226 HTTPTransaction* txn);
249 HTTPTransaction* getTransaction() const { in getTransaction()
339 HTTPTransaction*,
349 void convertVirtualNode(HTTPTransaction* txn);
[all …]
|
| H A D | ServerPushLifecycle.h | 18 class HTTPTransaction; variable
122 virtual void onHalfOpenPushedTxn(const HTTPTransaction* /* txn */,
131 virtual void onPushedTxn(const HTTPTransaction* /* txn */,
140 virtual void onPushedTxnTimeout(const HTTPTransaction* /* txn */) = 0;
146 const HTTPTransaction* /* txn */) = 0;
|
| H A D | HTTPUpstreamSession.h | 108 HTTPTransaction* newTransaction(HTTPTransaction::Handler* handler) override;
143 folly::Expected<HTTPTransaction*, NewTransactionError>
144 newTransactionWithError(HTTPTransaction::Handler* handler);
152 void setupOnHeadersComplete(HTTPTransaction* /* txn */, in setupOnHeadersComplete() argument
159 HTTPTransaction::Handler* getTransactionTimeoutHandler(
160 HTTPTransaction* txn) override;
|
| H A D | HTTPSession.cpp | 582 HTTPTransaction* HTTPSession::newPushedTransaction( in newPushedTransaction()
584 HTTPTransaction::PushHandler* handler, in newPushedTransaction()
622 HTTPTransaction* FOLLY_NULLABLE
643 HTTPTransaction* txn = in newExTransaction()
692 HTTPTransaction* txn = findTransaction(streamID); in onMessageBegin()
855 HTTPTransaction::DestructorGuard dg(txn); in onHeadersComplete()
1609 void HTTPSession::commonEom(HTTPTransaction* txn, in commonEom()
1620 size_t HTTPSession::sendBody(HTTPTransaction* txn, in sendBody()
1719 size_t HTTPSession::sendEOM(HTTPTransaction* txn, in sendEOM()
2639 HTTPTransaction* HTTPSession::createTransaction( in createTransaction()
[all …]
|
| H A D | HTTPDownstreamSession.h | 73 void setupOnHeadersComplete(HTTPTransaction* txn, HTTPMessage* msg) override;
79 HTTPTransaction::Handler* getTransactionTimeoutHandler(
80 HTTPTransaction* txn) override;
115 HTTPTransaction* newTransaction(HTTPTransaction::Handler*) override { in newTransaction()
|
| H A D | HTTPSessionBase.h | 25 class HTTPTransaction; variable
176 virtual HTTPTransaction::Transport::Type getType() const noexcept = 0;
188 HTTPTransaction::Handler* getParseErrorHandler(HTTPTransaction* txn,
467 virtual HTTPTransaction* newTransaction(
468 HTTPTransaction::Handler* handler) = 0;
505 const HTTPTransaction::ConnectionToken& token) noexcept { in setConnectionToken()
536 void handleErrorDirectly(HTTPTransaction* txn, const HTTPException& error);
541 HTTPTransaction* txn);
580 HTTPTransaction* txn,
655 folly::Optional<HTTPTransaction::ConnectionToken> connectionToken_;
|
| H A D | TransactionByteEvents.h | 20 HTTPTransaction* txn,
30 HTTPTransaction* getTransaction() const override { in getTransaction()
34 HTTPTransaction* txn_;
66 HTTPTransaction* txn,
|
| H A D | HQSession.h | 269 HTTPTransaction* newTransaction(HTTPTransaction::Handler* handler) override;
736 HTTPTransaction* txn) = 0;
1100 , public HTTPTransaction::Transport
1329 HTTPTransaction* txn,
1336 size_t sendBody(HTTPTransaction* txn,
1341 size_t sendBody(HTTPTransaction* txn,
1350 size_t sendEOM(HTTPTransaction* txn,
1359 HTTPTransaction* /* txn */,
1452 HTTPTransaction* newExTransaction( in newExTransaction()
1683 HTTPTransaction txn_;
[all …]
|
| H A D | HTTPUpstreamSession.cpp | 79 HTTPTransaction* HTTPUpstreamSession::newTransaction( in newTransaction()
80 HTTPTransaction::Handler* handler) { in newTransaction()
88 folly::Expected<HTTPTransaction*, HTTPUpstreamSession::NewTransactionError>
90 HTTPTransaction::Handler* handler) { in newTransactionWithError()
129 HTTPTransaction::Handler* HTTPUpstreamSession::getTransactionTimeoutHandler( in getTransactionTimeoutHandler()
130 HTTPTransaction* /*txn*/) { in getTransactionTimeoutHandler() argument
|
| H A D | SimpleController.h | 32 HTTPTransactionHandler* getRequestHandler(HTTPTransaction& txn,
42 HTTPTransaction* txn,
50 HTTPTransaction* txn, const folly::SocketAddress& localAddress) override;
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/ |
| H A D | HTTPMessageFilters.h | 20 : public HTTPTransaction::Handler
23 void setNextTransactionHandler(HTTPTransaction::Handler* next) { in setNextTransactionHandler()
29 virtual void setPrevTxn(HTTPTransaction* prev) noexcept { in setPrevTxn()
32 HTTPTransaction::Handler* getNextTransactionHandler() { in getNextTransactionHandler()
74 void setTransaction(HTTPTransaction* txn) noexcept final { in setTransaction()
81 prev_ = static_cast<HTTPTransaction*>(nullptr); in detachTransaction()
96 void onExTransaction(HTTPTransaction* txn) noexcept final { in onExTransaction()
120 auto prev = boost::get<HTTPTransaction*>(prev_); in detachHandlerFromTransaction()
128 prev_ = static_cast<HTTPTransaction*>(nullptr); in detachHandlerFromTransaction()
155 HTTPTransaction::Handler* nextTransactionHandler_{nullptr};
[all …]
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/connpool/ |
| H A D | SessionPool.h | 17 class HTTPTransaction; variable
152 HTTPTransaction* getTransaction(HTTPTransaction::Handler*);
197 HTTPTransaction* attemptOpenTransaction(
198 HTTPTransaction::Handler* upstreamHandler, SessionList& list);
|
| /dports/www/proxygen/proxygen-2021.12.27.00/proxygen/httpclient/samples/curl/ |
| H A D | CurlClient.h | 30 void setTransaction(proxygen::HTTPTransaction* /*txn*/) noexcept override;
60 proxygen::HTTPTransaction* pushedTxn_{nullptr};
97 void setTransaction(proxygen::HTTPTransaction* txn) noexcept override;
110 proxygen::HTTPTransaction* /* pushedTxn */) noexcept override;
112 void sendRequest(proxygen::HTTPTransaction* txn);
147 proxygen::HTTPTransaction* txn_{nullptr};
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/http2/client/ |
| H A D | ThriftTransactionHandler.h | 27 public proxygen::HTTPTransaction::TransportCallback {
38 void setTransaction(proxygen::HTTPTransaction* txn) noexcept override;
80 proxygen::HTTPTransaction* /*txn*/) noexcept override {} in onPushedTransaction() argument
98 proxygen::HTTPTransaction* txn_;
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/http2/common/ |
| H A D | SingleRpcChannel.h | 36 proxygen::HTTPTransaction* toHttp2,
42 folly::Function<proxygen::HTTPTransaction*(SingleRpcChannel*)>
97 folly::Function<proxygen::HTTPTransaction*(SingleRpcChannel*)>
102 proxygen::HTTPTransaction* httpTransaction_;
|