Home
last modified time | relevance | path

Searched refs:wait_conn (Results 1 – 24 of 24) sorted by relevance

/dports/misc/py-xgboost/xgboost-1.5.1/python-package/xgboost/
H A Dtracker.py83 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 Dtracker.py83 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 Dtracker.py80 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 Dtracker.py80 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 Dipc.h245 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 Dclient.h127 void wait_conn();
H A Dclient.inl21 wait_conn();
/dports/devel/rpclib/rpclib-2.2.1/include/rpc/
H A Dclient.h133 void wait_conn();
H A Dclient.inl22 wait_conn();
/dports/sysutils/cluster-glue/Reusable-Cluster-Components-glue--0a7add1d9996/lib/clplumbing/
H A Dipcsocket.c591 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dhstest.cpp138 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 Dwaiting.py71 def wait_conn(gen: PQGenConn[RV], timeout: Optional[float] = None) -> RV: function
H A Dconnection.py772 return waiting.wait_conn(gen, timeout=timeout)
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/deps/rpclib/lib/rpc/
H A Dclient.cc169 void client::wait_conn() { in wait_conn() function in rpc::client
/dports/devel/rpclib/rpclib-2.2.1/lib/rpc/
H A Dclient.cc177 void client::wait_conn() { in wait_conn() function in rpc::client