/dports/devel/ORBit2/ORBit2-2.14.19/linc2/src/ |
H A D | linc-connection.c | 65 return cnx; in link_connection_ref() 96 cmd->cnx = cnx; in link_connection_unref_unlock() 174 if (cnx) { in link_connection_broken_idle() 457 cmd->cnx = link_connection_ref_T (cnx); in queue_flattened_T_R() 716 while (cnx && cnx->status == LINK_CONNECTING) in link_connection_wait_connected_T() 719 return cnx ? cnx->status : LINK_DISCONNECTED; in link_connection_wait_connected_T() 732 cnx, cnx->inhibit_reconnect); in link_connection_try_reconnect() 748 (cnx, cnx->proto->name, cnx->remote_host_info, in link_connection_try_reconnect() 749 cnx->remote_serv_info, cnx->options); in link_connection_try_reconnect() 811 cnx = link_connection_ref_T (cnx); in link_connection_initiate() [all …]
|
/dports/databases/py-mysql-connector-python/mysql-connector-python-8.0.27/tests/ |
H A D | test_connection.py | 2688 cnx = self.cnx.__class__(**conn_args) 2696 cnx = self.cnx.__class__(**conn_args) 2712 cnx = self.cnx.__class__(**conn_args) 2843 cnx = self.cnx.__class__(**conn_args) 2879 cnx = self.cnx.__class__(**conn_args) 2997 cnx = self.cnx.__class__(**conn_args) 3005 cnx = self.cnx.__class__(**conn_args) 3021 cnx = self.cnx.__class__(**conn_args) 3275 cnx = self.cnx.__class__(**conn_args) 3283 cnx = self.cnx.__class__(**conn_args) [all …]
|
H A D | test_abstracts.py | 112 self.cnx.sql_mode = '' 121 self.cnx.sql_mode = '' 140 self.cnx.disconnect() 147 self.cnx.disconnect() 188 self.assertEqual(exp, [self.cnx.autocommit, self.cnx.sql_mode, 189 self.cnx.time_zone, self.cnx._charset_id]) 225 self.cnx.cmd_quit() 240 self.cnx = self.cnx.__class__(**self.config) 241 self.cnx.cmd_shutdown() 289 self.cnx.rollback() [all …]
|
H A D | test_bugs.py | 187 self.cnx = self.cnx.__class__(**self.config) 381 cnx = self.cnx.__class__(**config) 541 self.cnx = self.cnx.__class__(**config) 701 cnx = self.cnx.__class__() 989 cnx = self.cnx.__class__(**config) 1040 cnx = self.cnx.__class__(**config) 2064 self.cnx = self.cnx.__class__(**config) 2606 self.cnx = self.cnx.__class__(**config) 3958 self.cnx = self.cnx.__class__(**config) 5604 cnx = self.cnx.__class__(**config) [all …]
|
H A D | test_network.py | 74 self.cnx.close_connection() 103 self.cnx._packet_number = 255 116 self.cnx.shutdown() 121 self.cnx.close_connection() 146 self.cnx.sock.reset() 165 self.cnx.sock.reset() 177 self.cnx.sock.reset() 193 self.cnx.sock.reset() 220 self.cnx.sock.reset() 325 self.cnx.sock = sock [all …]
|
/dports/net/sslh/sslh-1.21c/ |
H A D | sslh-select.c | 73 init_cnx(cnx); in tidy_connection() 116 new = realloc(*cnx, (*cnx_size + cnx_num_alloc) * sizeof((*cnx)[0])); in accept_new_connection() 122 *cnx = new; in accept_new_connection() 144 q->fd = connect_addr(cnx, cnx->q[0].fd); in connect_queue() 198 int max_fd = MAX(cnx->q[0].fd, cnx->q[1].fd) + 1; in shovel_single() 232 res = fd2fd(&cnx->q[1-i], &cnx->q[i]); in shovel_single() 255 close(cnx->q[0].fd); in connect_proxy() 267 shovel_single(cnx); in connect_proxy() 306 struct connection *cnx; in main_loop() local 327 init_cnx(&cnx[i]); in main_loop() [all …]
|
H A D | sslh-fork.c | 41 int max_fd = MAX(cnx->q[0].fd, cnx->q[1].fd) + 1; in shovel() 45 FD_SET(cnx->q[0].fd, &fds); in shovel() 46 FD_SET(cnx->q[1].fd, &fds); in shovel() 59 res = fd2fd(&cnx->q[1-i], &cnx->q[i]); in shovel() 78 struct connection cnx; in start_shoveler() local 81 init_cnx(&cnx); in start_shoveler() 82 cnx.q[0].fd = in_socket; in start_shoveler() 108 if (cnx.proto->service && in start_shoveler() 117 cnx.q[1].fd = out_socket; in start_shoveler() 123 flush_deferred(&cnx.q[1]); in start_shoveler() [all …]
|
/dports/security/libprelude/libprelude-1.2.6/src/ |
H A D | prelude-connection.c | 154 (cnx->sa->sa_family == AF_UNIX) ? "<manager address>" : cnx->daddr, in auth_error() 296 ret = tls_auth_connection(cp, cnx->fd, crypt, &cnx->peer_analyzerid, &cnx->permission); in handle_authentication() 350 sock = generic_connect(cnx->sa, cnx->salen); in start_inet_connection() 396 sock = generic_connect(cnx->sa, cnx->salen); in start_unix_connection() 572 if ( ! cnx->sa ) { in resolve_addr() 673 cnx->fd = fd; in prelude_connection_set_fd_ref() 685 cnx->fd = fd; in prelude_connection_set_fd_nodup() 839 return cnx->fd; in prelude_connection_get_fd() 854 return cnx->saddr; in prelude_connection_get_local_addr() 869 return cnx->sport; in prelude_connection_get_local_port() [all …]
|
H A D | prelude-connection-pool.c | 197 *conn = cnx->cnx; in check_connection_event() 201 ret = prelude_connection_recv(cnx->cnx, &cnx->msg); in check_connection_event() 303 for ( cnx = or->and; cnx != NULL; cnx = cnx->and ) { in connection_pool_check_event() 404 prelude_connection_destroy(cnx->cnx); in destroy_connection_single() 420 for ( cnx = clist->and; cnx != NULL; cnx = bkp ) { in connection_list_destroy() 452 ret = do_send(cnx->cnx, msg); in broadcast_message() 570 prelude_connection_close(cnx->cnx); in set_state_dead() 699 nc->cnx = cnx; in new_connection() 844 cnx = &(*cnx)->and; in parse_config_line() 860 if ( c->cnx == cnx ) in search_cnx() [all …]
|
/dports/databases/py-mysql-connector-python/mysql-connector-python-8.0.27/tests/qa/ |
H A D | test_qa_wl7228.py | 43 with cnx.cursor() as cur: 52 cnx.commit() 57 with cnx.cursor() as cur: 77 with cnx.cursor() as _: 102 with cls(**config) as cnx: 103 with cnx.cursor() as _: 126 with cls(**config) as cnx: 127 with cnx.cursor() as _: 139 with cnx.cursor() as _: 151 with cls(**config) as cnx: [all …]
|
H A D | test_qa_wl6573.py | 43 with self.cnx.cursor() as cur: 44 self.cnx.start_transaction() 65 with self.cnx.cursor() as cur: 77 self.cnx.commit() 101 self.cnx.start_transaction, 115 with self.cnx.cursor() as cur: 125 self.cnx.commit() 134 self.cnx.commit() 148 with self.cnx.cursor() as cur: 170 with self.cnx.cursor() as cur: [all …]
|
H A D | test_qa_caching_sha2_password.py | 68 with mysql.connector.connect(**config) as cnx: 69 cnx.cmd_query("DROP USER IF EXISTS 'sham'@'%'") 70 cnx.cmd_query( 74 cnx.cmd_query("GRANT ALL ON *.* TO 'sham'@'%'") 79 with mysql.connector.connect(**config) as cnx: 80 with cnx.cursor() as cur: 105 with mysql.connector.connect(**config) as cnx: 107 cnx.cmd_query( 112 cnx.cmd_query("FLUSH PRIVILEGES") 117 with mysql.connector.connect(**config) as cnx: [all …]
|
H A D | test_qa_wl6080.py | 46 with mysql.connector.connect(pool_name=pool_name) as cnx: 47 cur = cnx.cursor() 59 with cnx.cursor() as _: 114 with cnx.cursor() as _: 139 with cnx.cursor() as _: 162 cur = cnx.cursor() 166 cur = cnx.cursor() 173 with mysql.connector.connect(**config) as cnx: 174 cur = cnx.cursor() 190 for cnx in cnx_list: [all …]
|
H A D | test_qa_wl6149.py | 51 with self.cnx.cursor(raw=True) as cur: 55 self.cnx.commit() 62 self.cnx.commit() 66 with self.cnx.cursor(raw=True) as cur: 82 self.cnx.commit() 99 self.cnx.commit() 106 self.cnx.commit() 121 self.cnx.commit() 134 self.cnx.commit() 144 self.cnx.commit() [all …]
|
/dports/databases/py-mysql-connector-python/mysql-connector-python-8.0.27/tests/cext/ |
H A D | test_cext_connection.py | 70 self.cnx.cmd_query(query) 74 self.cnx.free_result() 76 self.cnx.cmd_query(query) 80 self.cnx.free_result() 84 self.cnx.cmd_init_db('mysql') 87 self.cnx.cmd_init_db('myconnpy') 110 rows = self.cnx.get_rows()[0] 123 self.cnx.free_result() 138 self.cnx.cmd_reset_connection() 150 self.cnx.close() [all …]
|
H A D | test_cext_cursor.py | 65 if not cnx: 270 cur = cnx.cursor() 286 cur = cnx.cursor() 305 cur = self.cnx.cursor() 349 cur = self.cnx.cursor() 371 cur = self.cnx.cursor() 521 self.cnx.rollback() 547 self.cnx.rollback() 573 if not cnx: 613 if not cnx: [all …]
|
/dports/www/trac-devel/Trac-1.5.3/trac/db/ |
H A D | pool.py | 45 if self.cnx: 46 cnx = self.cnx 47 self.cnx = None 69 cnx = None 89 if cnx: 96 op, cnx = cnx 106 cnx = None 111 cnx = None 113 if cnx and not isinstance(cnx, tuple): 147 return cnx [all …]
|
/dports/net-im/sendxmpp/sendxmpp-1.24/ |
H A D | sendxmpp | 74 my $cnx = xmpp_login ( 112 $main::CNX = $cnx; 122 xmpp_logout($cnx); 330 unless ($cnx); 390 return $cnx; 436 $cnx->Send($packet); 470 $cnx->Send($pres); 495 my $cnx = shift; 496 $cnx->Disconnect(); 552 xmpp_logout ($cnx) [all …]
|
/dports/security/libprelude/libprelude-1.2.6/src/include/ |
H A D | prelude-connection.h | 57 int prelude_connection_send(prelude_connection_t *cnx, prelude_msg_t *msg); 63 int prelude_connection_connect(prelude_connection_t *cnx, 69 const char *prelude_connection_get_local_addr(prelude_connection_t *cnx); 71 unsigned int prelude_connection_get_local_port(prelude_connection_t *cnx); 73 const char *prelude_connection_get_peer_addr(prelude_connection_t *cnx); 75 unsigned int prelude_connection_get_peer_port(prelude_connection_t *cnx); 77 prelude_bool_t prelude_connection_is_alive(prelude_connection_t *cnx); 79 prelude_io_t *prelude_connection_get_fd(prelude_connection_t *cnx); 81 int prelude_connection_close(prelude_connection_t *cnx); 91 void prelude_connection_set_data(prelude_connection_t *cnx, void *data); [all …]
|
/dports/devel/ORBit2/ORBit2-2.14.19/src/orb/GIOP/ |
H A D | giop-connection.c | 22 GIOPConnection *gcnx = GIOP_CONNECTION (cnx); in giop_connection_real_state_changed() 25 parent_class->state_changed (cnx, status); in giop_connection_real_state_changed() 41 giop_connection_close (GIOPConnection *cnx) in giop_connection_close() argument 47 if (cnx->parent.status == LINK_CONNECTED && in giop_connection_close() 48 (!cnx->parent.was_initiated || in giop_connection_close() 49 cnx->giop_version == GIOP_1_2)) { in giop_connection_close() 53 cnx->giop_version); in giop_connection_close() 54 giop_send_buffer_write (buf, cnx, TRUE); in giop_connection_close() 68 giop_connection_close (cnx); in giop_connection_dispose() 70 giop_connection_destroy_frags (cnx); in giop_connection_dispose() [all …]
|
/dports/databases/py-mysql-connector-python/mysql-connector-python-8.0.27/lib/mysql/connector/ |
H A D | pooling.py | 99 def __init__(self, pool, cnx): argument 112 self._cnx = cnx 135 cnx = self._cnx 137 cnx.reset_session() 249 def _queue_connection(self, cnx): argument 267 def add_connection(self, cnx=None): argument 289 if not cnx: 310 self._queue_connection(cnx) 333 if not cnx.is_connected() \ 337 cnx.reconnect() [all …]
|
/dports/databases/py-pymssql/pymssql-2.1.4/tests/ |
H A D | test_user_msghandler.py | 36 cnx = mssqlconn() 48 cnx.close() 51 cnx = mssqlconn() 53 cnx.set_msghandler(None) 60 cnx.close() 63 cnx = mssqlconn() 85 cnx.close() 123 cnx = mssqlconn() 134 cnx.close() 137 cnx = mssqlconn() [all …]
|
/dports/databases/py-PyGreSQL/PyGreSQL-5.2/ |
H A D | pgconn.c | 15 if (self->cnx) { in conn_dealloc() 17 PQfinish(self->cnx); in conn_dealloc() 221 if (!self->cnx) { in _conn_query() 464 if (!self->cnx) { in conn_prepare() 506 if (!self->cnx) { in conn_describe_prepared() 554 if (!self->cnx) { in conn_putline() 585 if (!self->cnx) { in conn_getline() 615 if (!self->cnx) { in conn_endcopy() 638 if (!self->cnx) { in conn_set_non_blocking() 665 if (!self->cnx) { in conn_is_non_blocking() [all …]
|
/dports/devel/ORBit2/ORBit2-2.14.19/linc2/include/linc/ |
H A D | linc-connection.h | 76 void (* state_changed) (LinkConnection *cnx, 78 gboolean (* handle_input) (LinkConnection *cnx); 81 void (* broken) (LinkConnection *cnx); 86 void (* blocking) (LinkConnection *cnx, 92 void link_connection_from_fd (LinkConnection *cnx, 110 LinkConnection *link_connection_ref (LinkConnection *cnx); 111 void link_connection_unref (LinkConnection *cnx); 119 glong link_connection_read (LinkConnection *cnx, 126 LinkIOStatus link_connection_write (LinkConnection *cnx, 131 LinkIOStatus link_connection_writev (LinkConnection *cnx, [all …]
|
/dports/mail/milter-greylist/milter-greylist-4.6.4/ |
H A D | urlcheck.c | 509 cnx = &uc[i]; 517 if (cnx == NULL) { 520 cnx = &uc[oldest_cnx]; 534 return cnx; 625 cnx = get_cnx(ue); 678 if (cnx->uc_pid == -1) { 874 if (cnx->uc_pid == -1) 887 cnx->uc_pid = -1; 914 ch = cnx->uc_hdl; 1031 if (cnx->uc_hdl) [all …]
|