Searched refs:inputProtocol_ (Results 1 – 5 of 5) sorted by relevance
| /thrift-3.4.0/lib/cpp/src/thrift/server/ |
| D | TConnectedClient.cpp | 41 inputProtocol_(inputProtocol), in TConnectedClient()
52 opaqueContext_ = eventHandler_->createContext(inputProtocol_, outputProtocol_); in run()
61 if (!processor_->process(inputProtocol_, outputProtocol_, opaqueContext_)) { in run()
96 eventHandler_->deleteContext(opaqueContext_, inputProtocol_, outputProtocol_); in cleanup()
100 inputProtocol_->getTransport()->close(); in cleanup()
|
| D | TNonblockingServer.cpp | 177 std::shared_ptr<TProtocol> inputProtocol_; member in apache::thrift::server::TNonblockingServer::TConnection
397 inputProtocol_ = server_->getInputProtocolFactory()->getProtocol(factoryInputTransport_, in init()
399 outputProtocol_ = inputProtocol_; in init()
401 inputProtocol_ = server_->getInputProtocolFactory()->getProtocol(factoryInputTransport_); in init()
408 connectionContext_ = serverEventHandler_->createContext(inputProtocol_, outputProtocol_); in init()
414 processor_ = server_->getProcessor(inputProtocol_, outputProtocol_, tSocket_); in init()
625 new Task(processor_, inputProtocol_, outputProtocol_, this)); in transition()
654 processor_->process(inputProtocol_, outputProtocol_, connectionContext_); in transition()
855 serverEventHandler_->deleteContext(connectionContext_, inputProtocol_, outputProtocol_); in close()
|
| D | TConnectedClient.h | 96 std::shared_ptr<apache::thrift::protocol::TProtocol> inputProtocol_; variable
|
| /thrift-3.4.0/lib/d/src/thrift/server/ |
| D | threaded.d | 146 inputProtocol_ = inputProtocol; in this()
158 eventHandler_.createContext(inputProtocol_, outputProtocol_); in run()
167 if (!processor_.process(inputProtocol_, outputProtocol_, in run()
168 connectionContext) || !inputProtocol_.transport.peek() in run()
184 eventHandler_.deleteContext(connectionContext, inputProtocol_, in run()
189 inputProtocol_.transport.close(); in run()
207 TProtocol inputProtocol_; variable
|
| D | nonblocking.d | 900 inputProtocol_ = in init()
907 server_.eventHandler.createContext(inputProtocol_, outputProtocol_); in init()
910 auto info = TConnectionInfo(inputProtocol_, outputProtocol_, socket_); in init()
1249 connectionContext_, inputProtocol_, outputProtocol_); in close()
1329 TProtocol inputProtocol_; variable
1354 if (!processor_.process(inputProtocol_, outputProtocol_, in processRequest()
1355 connectionContext_) || !inputProtocol_.transport.peek() in processRequest()
|
