| /third_party/vk-gl-cts/execserver/ |
| H A D | xsTcpServer.hpp | 36 class ConnectionHandler;
44 virtual ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) = DE_NULL;
49 virtual void connectionDone (ConnectionHandler* handler);
58 void addLiveConnection (ConnectionHandler* handler);
62 std::vector<ConnectionHandler*> m_liveConnections;
63 std::vector<ConnectionHandler*> m_doneConnections;
66 class ConnectionHandler : public de::Thread class
69 ConnectionHandler (TcpServer* server, de::Socket* socket) : m_server(server), m_socket(socket) {} in ConnectionHandler() function in xs::ConnectionHandler
70 virtual ~ConnectionHandler (void);
|
| H A D | xsTcpServer.cpp | 53 ConnectionHandler* handler = DE_NULL; in runServer()
86 void TcpServer::connectionDone (ConnectionHandler* handler) in connectionDone()
90 std::vector<ConnectionHandler*>::iterator liveListPos = std::find(m_liveConnections.begin(), m_liveConnections.end(), handler); in connectionDone()
98 void TcpServer::addLiveConnection (ConnectionHandler* handler) in addLiveConnection()
108 for (std::vector<ConnectionHandler*>::iterator i = m_doneConnections.begin(); i != m_doneConnections.end(); i++) in deleteDoneConnections()
124 std::vector<ConnectionHandler*> allConnections; in ~TcpServer()
140 for (std::vector<ConnectionHandler*>::const_iterator i = allConnections.begin(); i != allConnections.end(); i++) in ~TcpServer()
152 ConnectionHandler::~ConnectionHandler (void) in ~ConnectionHandler()
157 void ConnectionHandler
[all...] |
| H A D | xsExecutionServer.hpp | 51 ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAddress);
56 void connectionDone (ConnectionHandler* handler);
85 class ExecutionRequestHandler : public ConnectionHandler
|
| H A D | xsExecutionServer.cpp | 127 ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) in createHandler()
133 void ExecutionServer::connectionDone (ConnectionHandler* handler) in connectionDone()
142 : ConnectionHandler (server, socket) in ExecutionRequestHandler()
|
| /third_party/nghttp2/src/ |
| H A D | shrpx_connection_handler.cc | 58 auto h = static_cast<ConnectionHandler *>(w->data); in acceptor_disable_cb()
72 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_cb()
87 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_read_cb()
95 auto h = static_cast<ConnectionHandler *>(w->data); in ocsp_chld_cb()
109 auto h = static_cast<ConnectionHandler *>(w->data); in serial_event_async_cb()
115 ConnectionHandler::ConnectionHandler(struct ev_loop *loop, std::mt19937 &gen) in ConnectionHandler() function in shrpx::ConnectionHandler
156 ConnectionHandler::~ConnectionHandler() { in ~ConnectionHandler()
192 void ConnectionHandler
[all...] |
| H A D | shrpx_accept_handler.h | 34 class ConnectionHandler;
39 AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h);
48 ConnectionHandler *conn_hnr_;
|
| H A D | shrpx_worker_process.cc | 108 void graceful_shutdown(ConnectionHandler *conn_handler) { in graceful_shutdown()
138 void reopen_log(ConnectionHandler *conn_handler) { in reopen_log()
153 auto conn_handler = static_cast<ConnectionHandler *>(w->data); in ipc_readcb()
186 auto conn_handler = static_cast<ConnectionHandler *>(w->data); in quic_ipc_readcb()
223 auto conn_handler = static_cast<ConnectionHandler *>(w->data); in renew_ticket_key_cb()
286 auto conn_handler = static_cast<ConnectionHandler *>(w->data); in memcached_get_ticket_key_cb()
470 auto conn_handler = std::make_unique<ConnectionHandler>(loop, gen); in worker_process_event_loop()
|
| H A D | shrpx_worker.h | 67 class ConnectionHandler;
321 ConnectionHandler *conn_handler,
373 ConnectionHandler *get_connection_handler() const;
434 ConnectionHandler *conn_handler_;
|
| H A D | shrpx_connection_handler.h | 81 // index to ConnectionHandler::all_ssl_ctx_, which points to next
135 class ConnectionHandler { class
137 ConnectionHandler(struct ev_loop *loop, std::mt19937 &gen);
138 ~ConnectionHandler();
|
| H A D | shrpx_worker_process.h | 40 class ConnectionHandler;
|
| H A D | shrpx_accept_handler.cc | 49 AcceptHandler::AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h) in AcceptHandler()
|
| H A D | shrpx_worker.cc | 157 ConnectionHandler *conn_handler, in Worker()
657 ConnectionHandler *Worker::get_connection_handler() const { in get_connection_handler()
|
| /third_party/vk-gl-cts/framework/platform/android/ |
| H A D | tcuAndroidExecService.hpp | 80 xs::ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAddress);
86 class ConnectionHandler : public xs::ExecutionRequestHandler class
89 ConnectionHandler (JavaVM* vm, xs::ExecutionServer* server, de::Socket* socket);
|
| H A D | tcuAndroidExecService.cpp | 297 xs::ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress& clientAddress) in createHandler()
300 return new ConnectionHandler(m_vm, this, socket); in createHandler()
303 // ConnectionHandler
305 ConnectionHandler::ConnectionHandler (JavaVM* vm, xs::ExecutionServer* server, de::Socket* socket) in ConnectionHandler() function in tcu::Android::ConnectionHandler
311 void ConnectionHandler::run (void) in run()
|
| /third_party/python/Lib/test/ |
| H A D | test_ssl.py | 2433 class ConnectionHandler(threading.Thread): class in ThreadedEchoServer
2481 # -> traceback -> self (ConnectionHandler) -> server
2690 handler = self.ConnectionHandler(self, newconn, connaddr)
2719 class ConnectionHandler(asyncore.dispatcher_with_send): class in AsyncoreEchoServer.EchoServer
2780 self.ConnectionHandler(sock_obj, self.certfile)
2810 # make sure that ConnectionHandler is removed from socket_map
|