| /third_party/nghttp2/src/ |
| 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::set_ticket_keys_to_worker( in set_ticket_keys_to_worker()
199 void ConnectionHandler::worker_reopen_log_files() { in worker_reopen_log_files()
209 void ConnectionHandler::worker_replace_downstream( in worker_replace_downstream()
[all …]
|
| D | shrpx_accept_handler.h | 34 class ConnectionHandler; variable
39 AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h);
48 ConnectionHandler *conn_hnr_;
|
| 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()
447 auto conn_handler = std::make_unique<ConnectionHandler>(loop, gen); in worker_process_event_loop()
|
| D | shrpx_worker.h | 67 class ConnectionHandler; variable
321 ConnectionHandler *conn_handler,
373 ConnectionHandler *get_connection_handler() const;
434 ConnectionHandler *conn_handler_;
|
| D | shrpx_connection_handler.h | 135 class ConnectionHandler {
137 ConnectionHandler(struct ev_loop *loop, std::mt19937 &gen);
138 ~ConnectionHandler();
|
| D | shrpx_worker_process.h | 40 class ConnectionHandler; variable
|
| D | shrpx_accept_handler.cc | 49 AcceptHandler::AcceptHandler(const UpstreamAddr *faddr, ConnectionHandler *h) in AcceptHandler()
|
| D | shrpx_worker.cc | 156 ConnectionHandler *conn_handler, in Worker()
656 ConnectionHandler *Worker::get_connection_handler() const { in get_connection_handler()
|
| /third_party/vk-gl-cts/execserver/ |
| D | xsTcpServer.hpp | 36 class ConnectionHandler;
44 …virtual ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAd…
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);
|
| 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_liv… in connectionDone()
98 void TcpServer::addLiveConnection (ConnectionHandler* handler) in addLiveConnection()
108 …for (std::vector<ConnectionHandler*>::iterator i = m_doneConnections.begin(); i != m_doneConnectio… in deleteDoneConnections()
124 std::vector<ConnectionHandler*> allConnections; in ~TcpServer()
140 …for (std::vector<ConnectionHandler*>::const_iterator i = allConnections.begin(); i != allConnectio… in ~TcpServer()
152 ConnectionHandler::~ConnectionHandler (void) in ~ConnectionHandler()
157 void ConnectionHandler::run (void) in run()
|
| D | xsExecutionServer.hpp | 51 ConnectionHandler* createHandler (de::Socket* socket, const de::SocketAddress& clientAddress);
56 void connectionDone (ConnectionHandler* handler);
85 class ExecutionRequestHandler : public ConnectionHandler
|
| D | xsExecutionServer.cpp | 127 ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress& cli… in createHandler()
133 void ExecutionServer::connectionDone (ConnectionHandler* handler) in connectionDone()
142 : ConnectionHandler (server, socket) in ExecutionRequestHandler()
|
| /third_party/vk-gl-cts/framework/platform/android/ |
| 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);
|
| D | tcuAndroidExecService.cpp | 297 xs::ConnectionHandler* ExecutionServer::createHandler (de::Socket* socket, const de::SocketAddress&… in createHandler()
300 return new ConnectionHandler(m_vm, this, socket); in createHandler()
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/ |
| D | test_ssl.py | 2402 class ConnectionHandler(threading.Thread): class in ThreadedEchoServer
2659 handler = self.ConnectionHandler(self, newconn, connaddr)
2688 class ConnectionHandler(asyncore.dispatcher_with_send): class in AsyncoreEchoServer.EchoServer
2749 self.ConnectionHandler(sock_obj, self.certfile)
|