/dports/misc/py-xgboost/xgboost-1.5.1/python-package/xgboost/ |
H A D | tracker.py | 83 def assign_rank(self, rank, wait_conn, tree_map, parent_map, ring_map): argument 117 if r in wait_conn: 122 self.sock.sendstr(wait_conn[r].host) 123 self.sock.sendint(wait_conn[r].port) 132 wait_conn[r].wait_accept -= 1 133 if wait_conn[r].wait_accept == 0: 136 wait_conn.pop(r, None) 274 wait_conn = {} 295 assert s.rank not in wait_conn 326 wait_conn[rank] = s [all …]
|
/dports/misc/xgboost/xgboost-1.5.1/python-package/xgboost/ |
H A D | tracker.py | 83 def assign_rank(self, rank, wait_conn, tree_map, parent_map, ring_map): argument 117 if r in wait_conn: 122 self.sock.sendstr(wait_conn[r].host) 123 self.sock.sendint(wait_conn[r].port) 132 wait_conn[r].wait_accept -= 1 133 if wait_conn[r].wait_accept == 0: 136 wait_conn.pop(r, None) 274 wait_conn = {} 295 assert s.rank not in wait_conn 326 wait_conn[rank] = s [all …]
|
/dports/misc/py-tvm/incubator-tvm-0.6.1/3rdparty/dmlc-core/tracker/dmlc_tracker/ |
H A D | tracker.py | 80 def assign_rank(self, rank, wait_conn, tree_map, parent_map, ring_map): argument 114 if r in wait_conn: 119 self.sock.sendstr(wait_conn[r].host) 120 self.sock.sendint(wait_conn[r].port) 129 wait_conn[r].wait_accept -= 1 130 if wait_conn[r].wait_accept == 0: 133 wait_conn.pop(r, None) 258 wait_conn = {} 275 assert s.rank not in wait_conn 306 wait_conn[rank] = s [all …]
|
/dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/tracker/dmlc_tracker/ |
H A D | tracker.py | 80 def assign_rank(self, rank, wait_conn, tree_map, parent_map, ring_map): argument 114 if r in wait_conn: 119 self.sock.sendstr(wait_conn[r].host) 120 self.sock.sendint(wait_conn[r].port) 129 wait_conn[r].wait_accept -= 1 130 if wait_conn[r].wait_accept == 0: 133 wait_conn.pop(r, None) 258 wait_conn = {} 275 assert s.rank not in wait_conn 306 wait_conn[rank] = s [all …]
|
/dports/sysutils/cluster-glue/Reusable-Cluster-Components-glue--0a7add1d9996/include/clplumbing/ |
H A D | ipc.h | 245 void (* destroy)(IPC_WaitConnection *wait_conn); 260 int (* get_select_fd)(IPC_WaitConnection *wait_conn); 277 (IPC_WaitConnection * wait_conn, IPC_Auth *auth_info);
|
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/deps/rpclib/include/rpc/ |
H A D | client.h | 127 void wait_conn();
|
H A D | client.inl | 21 wait_conn();
|
/dports/devel/rpclib/rpclib-2.2.1/include/rpc/ |
H A D | client.h | 133 void wait_conn();
|
H A D | client.inl | 22 wait_conn();
|
/dports/sysutils/cluster-glue/Reusable-Cluster-Components-glue--0a7add1d9996/lib/clplumbing/ |
H A D | ipcsocket.c | 591 socket_destroy_wait_conn(struct IPC_WAIT_CONNECTION * wait_conn) in socket_destroy_wait_conn() argument 593 struct SOCKET_WAIT_CONN_PRIVATE * wc = wait_conn->ch_private; in socket_destroy_wait_conn() 630 g_free((void*) wait_conn); in socket_destroy_wait_conn() 635 socket_wait_selectfd(struct IPC_WAIT_CONNECTION *wait_conn) in socket_wait_selectfd() argument 637 struct SOCKET_WAIT_CONN_PRIVATE * wc = wait_conn->ch_private; in socket_wait_selectfd() 648 socket_accept_connection(struct IPC_WAIT_CONNECTION * wait_conn in socket_accept_connection() argument 671 s = wait_conn->ops->get_select_fd(wait_conn); in socket_accept_connection() 707 ( wait_conn->ch_private); in socket_accept_connection()
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/plugin/HandlerSocket-Plugin-for-MySQL/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/plugin/HandlerSocket-Plugin-for-MySQL/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/plugin/HandlerSocket-Plugin-for-MySQL/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/libhsclient/HandlerSocket-Plugin-for-MySQL/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/mariadb103-server/mariadb-10.3.34/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/mariadb104-server/mariadb-10.4.24/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/mariadb104-client/mariadb-10.4.24/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/mariadb103-client/mariadb-10.3.34/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; in reset() 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in reset() 152 while (wait_conn != 0 && conn_count < wait_conn) { in reset() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in reset() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in reset()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/plugin/handler_socket/client/ |
H A D | hstest.cpp | 138 long wait_conn; member 145 count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0), in hstest_shared() 152 while (wait_conn != 0 && conn_count < wait_conn) { in increment_conn() 1115 if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) { in test_watch() 1464 shared.wait_conn = shared.conf.get_int("wait_conn", 0); in hstest_main()
|
/dports/databases/py-psycopg/psycopg-3.0.5/psycopg/ |
H A D | waiting.py | 71 def wait_conn(gen: PQGenConn[RV], timeout: Optional[float] = None) -> RV: function
|
H A D | connection.py | 772 return waiting.wait_conn(gen, timeout=timeout)
|
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/deps/rpclib/lib/rpc/ |
H A D | client.cc | 169 void client::wait_conn() { in wait_conn() function in rpc::client
|
/dports/devel/rpclib/rpclib-2.2.1/lib/rpc/ |
H A D | client.cc | 177 void client::wait_conn() { in wait_conn() function in rpc::client
|