Searched refs:TConnectedClient (Results 1 – 13 of 13) sorted by relevance
34 TConnectedClient::TConnectedClient(const shared_ptr<TProcessor>& processor, in TConnectedClient() function in apache::thrift::server::TConnectedClient48 TConnectedClient::~TConnectedClient() = default;50 void TConnectedClient::run() { in run()94 void TConnectedClient::cleanup() { in cleanup()
40 class TConnectedClient : public apache::thrift::concurrency::Runnable {51 TConnectedClient(61 ~TConnectedClient() override;
98 void onClientConnected(const std::shared_ptr<TConnectedClient>& pClient) override /* override */;103 void onClientDisconnected(TConnectedClient *pClient) override /* override */;117 TConnectedClientRunner(const std::shared_ptr<TConnectedClient>& pClient);121 std::shared_ptr<TConnectedClient> pClient_;126 …typedef std::map<TConnectedClient *, std::shared_ptr<apache::thrift::concurrency::Thread> > Client…
133 virtual void onClientConnected(const std::shared_ptr<TConnectedClient>& pClient) = 0;144 virtual void onClientDisconnected(TConnectedClient* pClient) = 0;152 void newlyConnectedClient(const std::shared_ptr<TConnectedClient>& pClient);158 void disposeConnectedClient(TConnectedClient* pClient);
158 newlyConnectedClient(shared_ptr<TConnectedClient>( in serve()159 new TConnectedClient(getProcessor(inputProtocol, outputProtocol, client), in serve()224 void TServerFramework::newlyConnectedClient(const shared_ptr<TConnectedClient>& pClient) { in newlyConnectedClient()234 void TServerFramework::disposeConnectedClient(TConnectedClient* pClient) { in disposeConnectedClient()
115 void TThreadedServer::onClientConnected(const shared_ptr<TConnectedClient>& pClient) { in onClientConnected()124 void TThreadedServer::onClientDisconnected(TConnectedClient* pClient) { in onClientDisconnected()138 TThreadedServer::TConnectedClientRunner::TConnectedClientRunner(const shared_ptr<TConnectedClient>&… in TConnectedClientRunner()
88 void TSimpleServer::onClientConnected(const shared_ptr<TConnectedClient>& pClient) { in onClientConnected()95 void TSimpleServer::onClientDisconnected(TConnectedClient*) { in onClientDisconnected() argument
67 void onClientConnected(const std::shared_ptr<TConnectedClient>& pClient) override /* override */;68 void onClientDisconnected(TConnectedClient* pClient) override /* override */;
122 void TThreadPoolServer::onClientConnected(const shared_ptr<TConnectedClient>& pClient) { in onClientConnected()126 void TThreadPoolServer::onClientDisconnected(TConnectedClient*) { in onClientDisconnected() argument
89 void onClientConnected(const std::shared_ptr<TConnectedClient>& pClient) override /* override */;90 void onClientDisconnected(TConnectedClient* pClient) override /* override */;
92 src/thrift/server/TConnectedClient.cpp \217 src/thrift/server/TConnectedClient.h \
58 src/thrift/server/TConnectedClient.cpp
1649 - [THRIFT-3704](https://issues.apache.org/jira/browse/THRIFT-3704) - "TConnectedClient died: Could …1937 - [THRIFT-3961](https://issues.apache.org/jira/browse/THRIFT-3961) - TConnectedClient does not term…1949 - [THRIFT-3957](https://issues.apache.org/jira/browse/THRIFT-3957) - TConnectedClient does not disc…
