| /dports/devel/hpx/hpx-1.2.1/hpx/plugins/parcelport/tcp/ |
| H A D | connection_handler.hpp | 41 class HPX_EXPORT connection_handler; variable
45 struct connection_handler_traits<policies::tcp::connection_handler>
72 class HPX_EXPORT connection_handler class
73 : public parcelport_impl<connection_handler>
75 typedef parcelport_impl<connection_handler> base_type;
85 connection_handler(util::runtime_configuration const& ini,
91 ~connection_handler();
|
| /dports/devel/hpx/hpx-1.2.1/plugins/parcelport/tcp/ |
| H A D | connection_handler_tcp.cpp | 63 connection_handler::connection_handler( in connection_handler() function in hpx::parcelset::policies::tcp::connection_handler
79 connection_handler::~connection_handler() in ~connection_handler()
84 bool connection_handler::do_run() in do_run()
109 util::bind(&connection_handler::handle_accept, in do_run()
128 void connection_handler::do_stop() in do_stop()
152 std::shared_ptr<sender> connection_handler::create_connection( in create_connection()
251 parcelset::locality connection_handler::agas_locality( in agas_locality()
277 parcelset::locality connection_handler::create_locality() const in create_locality()
295 util::bind(&connection_handler::handle_accept, in handle_accept()
313 util::bind(&connection_handler::handle_read_completion, in handle_accept()
[all …]
|
| H A D | parcelport_tcp.cpp | 26 struct plugin_config_data<hpx::parcelset::policies::tcp::connection_handler>
44 hpx::parcelset::policies::tcp::connection_handler,
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/spec/support/database/ |
| H A D | multiple_databases.rb | 35 …connection_classes = ActiveRecord::Base.connection_handler.connection_pool_names.map(&:constantize…
39 original_handler = ActiveRecord::Base.connection_handler
41 ActiveRecord::Base.connection_handler = new_handler
49 ActiveRecord::Base.connection_handler = original_handler
78 …if connected? && connection&.transaction_open? && ActiveRecord::Base.connection_handler == ActiveR…
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 153 Connection_handler *connection_handler= NULL; in init() local
157 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
160 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
166 if (connection_handler == NULL) in init()
173 m_instance= new (std::nothrow) Connection_handler_manager(connection_handler); in init()
177 delete connection_handler; in init()
195 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 150 Connection_handler *connection_handler = nullptr; in init() local
153 connection_handler = new (std::nothrow) Per_thread_connection_handler(); in init()
156 connection_handler = new (std::nothrow) One_thread_connection_handler(); in init()
162 if (connection_handler == nullptr) { in init()
169 new (std::nothrow) Connection_handler_manager(connection_handler); in init()
172 delete connection_handler; in init()
191 max_threads = connection_handler->get_max_threads(); in init()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 153 Connection_handler *connection_handler= NULL; in init() local
157 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
160 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
166 if (connection_handler == NULL) in init()
173 m_instance= new (std::nothrow) Connection_handler_manager(connection_handler); in init()
177 delete connection_handler; in init()
195 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/databases/mysql57-client/mysql-5.7.36/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 153 Connection_handler *connection_handler= NULL; in init() local
157 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
160 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
166 if (connection_handler == NULL) in init()
173 m_instance= new (std::nothrow) Connection_handler_manager(connection_handler); in init()
177 delete connection_handler; in init()
195 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 187 Connection_handler *connection_handler= NULL; in init() local
191 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
194 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
197 connection_handler= new (std::nothrow) Thread_pool_connection_handler(); in init()
206 if (connection_handler == NULL || extra_connection_handler == NULL) in init()
214 Connection_handler_manager(connection_handler, extra_connection_handler); in init()
218 delete connection_handler; in init()
236 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 187 Connection_handler *connection_handler= NULL; in init() local
191 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
194 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
197 connection_handler= new (std::nothrow) Thread_pool_connection_handler(); in init()
206 if (connection_handler == NULL || extra_connection_handler == NULL) in init()
214 Connection_handler_manager(connection_handler, extra_connection_handler); in init()
218 delete connection_handler; in init()
236 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/conn_handler/ |
| H A D | connection_handler_manager.cc | 187 Connection_handler *connection_handler= NULL; in init() local
191 connection_handler= new (std::nothrow) Per_thread_connection_handler(); in init()
194 connection_handler= new (std::nothrow) One_thread_connection_handler(); in init()
197 connection_handler= new (std::nothrow) Thread_pool_connection_handler(); in init()
206 if (connection_handler == NULL || extra_connection_handler == NULL) in init()
214 Connection_handler_manager(connection_handler, extra_connection_handler); in init()
218 delete connection_handler; in init()
236 max_threads= connection_handler->get_max_threads(); in init()
|
| /dports/devel/cpp-netlib/cpp-netlib-cpp-netlib-0.13.0-final/libs/network/example/http/ |
| H A D | fileserver.cpp | 101 struct connection_handler : std::enable_shared_from_this<connection_handler> { struct
102 explicit connection_handler(file_cache &cache) : file_cache_(cache) {} in connection_handler() argument
160 explicit input_consumer(std::shared_ptr<connection_handler> h, in input_consumer() argument
205 std::shared_ptr<connection_handler> handler_;
215 std::shared_ptr<connection_handler> h(new connection_handler(cache_)); in operator ()()
218 std::shared_ptr<connection_handler> h(new connection_handler(cache_)); in operator ()()
221 auto h = std::make_shared<connection_handler>(cache_); in operator ()()
|
| /dports/devel/plasma/plasma-5bb07b3/tests/ |
| H A D | server.c | 15 void *connection_handler(void *);
59 if( pthread_create( &sniffer_thread , NULL , connection_handler , (void*) new_sock) < 0) in main()
82 void *connection_handler(void *socket_desc) in connection_handler() function
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/google_apis/gcm/engine/ |
| H A D | connection_handler_impl_unittest.cc | 164 ConnectionHandlerImpl* connection_handler() { in connection_handler() function in gcm::__anone0b6ac340111::GCMConnectionHandlerImplTest
286 EXPECT_FALSE(connection_handler()->CanSendMessage()); in Connect()
331 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
336 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
360 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
380 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
405 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
442 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
705 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
736 connection_handler()->SendMessage(data_message); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/google_apis/gcm/engine/ |
| H A D | connection_handler_impl_unittest.cc | 166 ConnectionHandlerImpl* connection_handler() { in connection_handler() function in gcm::__anona85c76990111::GCMConnectionHandlerImplTest
292 EXPECT_FALSE(connection_handler()->CanSendMessage()); in Connect()
337 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
342 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
366 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
386 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
411 EXPECT_FALSE(connection_handler()->CanSendMessage()); in TEST_F()
448 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
711 EXPECT_TRUE(connection_handler()->CanSendMessage()); in TEST_F()
742 connection_handler()->SendMessage(data_message); in TEST_F()
[all …]
|
| /dports/net/socketapi/socketapi-2.2.19/socket_programs/ |
| H A D | combined_server_1to1.c | 71 void * (* connection_handler)(void *); member
304 pthread_create(&tid, NULL, data.connection_handler, fdp); in start_server()
310 init_server(struct sockaddr_in local_addr, int port, void *(connection_handler (void*))) in init_server()
329 server_data_p->connection_handler = connection_handler; in init_server()
|
| /dports/devel/caf/actor-framework-0.18.5/libcaf_io/caf/io/ |
| H A D | typed_broker.hpp | 44 using connection_handler = typed_actor<reacts_to<new_data_msg>, typedef
108 connection_handler in fork()
128 static_assert(std::is_convertible<actor_hdl, connection_handler>::value, in add_tcp_scribe()
134 static_assert(std::is_convertible<actor_hdl, connection_handler>::value, in add_tcp_scribe()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/common/channel/ |
| H A D | namespace_router_unittest.cc | 46 MockCastMessageHandler connection_handler; in TEST_F() local
50 router_.AddNamespaceHandler("connection", &connection_handler); in TEST_F()
58 EXPECT_CALL(connection_handler, OnMessage(_, _, _)) in TEST_F()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/common/channel/ |
| H A D | namespace_router_unittest.cc | 46 MockCastMessageHandler connection_handler; in TEST_F() local
50 router_.AddNamespaceHandler("connection", &connection_handler); in TEST_F()
58 EXPECT_CALL(connection_handler, OnMessage(_, _, _)) in TEST_F()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/llvm/clang-tools-extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 49 void connection_handler(xpc_connection_t clientConnection);
91 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
148 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
202 xpc_main(xpcClosure::connection_handler); in loop()
|
| /dports/devel/tinygo/tinygo-0.14.1/llvm-project/clang-tools-extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 48 void connection_handler(xpc_connection_t clientConnection);
90 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
147 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
201 xpc_main(xpcClosure::connection_handler); in loop()
|
| /dports/devel/wasi-libcxx/llvm-project-13.0.1.src/clang-tools-extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 49 void connection_handler(xpc_connection_t clientConnection);
91 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
148 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
202 xpc_main(xpcClosure::connection_handler); in loop()
|
| /dports/devel/llvm11/llvm-11.0.1.src/tools/clang/tools/extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 49 void connection_handler(xpc_connection_t clientConnection);
91 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
148 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
202 xpc_main(xpcClosure::connection_handler); in loop()
|
| /dports/devel/llvm-cheri/llvm-project-37c49ff00e3eadce5d8703fdc4497f28458c64a8/clang-tools-extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 49 void connection_handler(xpc_connection_t clientConnection);
91 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
148 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
202 xpc_main(xpcClosure::connection_handler); in loop()
|
| /dports/devel/llvm12/llvm-project-12.0.1.src/clang-tools-extra/clangd/xpc/ |
| H A D | XPCTransport.cpp | 49 void connection_handler(xpc_connection_t clientConnection);
91 friend void xpcClosure::connection_handler(xpc_connection_t clientConnection);
148 void connection_handler(xpc_connection_t clientConnection) { in connection_handler() function
202 xpc_main(xpcClosure::connection_handler); in loop()
|