| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 72 static void CFStreamConnectCleanup(CFStreamConnect* connect) { in CFStreamConnectCleanup() argument
73 grpc_resource_quota_unref_internal(connect->resource_quota); in CFStreamConnectCleanup()
74 CFSTREAM_HANDLE_UNREF(connect->stream_handle, "async connect clean up"); in CFStreamConnectCleanup()
75 CFRelease(connect->read_stream); in CFStreamConnectCleanup()
76 CFRelease(connect->write_stream); in CFStreamConnectCleanup()
77 gpr_mu_destroy(&connect->mu); in CFStreamConnectCleanup()
78 gpr_free(connect->addr_name); in CFStreamConnectCleanup()
79 gpr_free(connect); in CFStreamConnectCleanup()
83 CFStreamConnect* connect = static_cast<CFStreamConnect*>(arg); in OnAlarm() local
85 gpr_log(GPR_DEBUG, "CLIENT_CONNECT :%p OnAlarm, error:%p", connect, error); in OnAlarm()
[all …]
|
| D | tcp_client_custom.cc | 49 static void custom_tcp_connect_cleanup(grpc_custom_tcp_connect* connect) { in custom_tcp_connect_cleanup() argument
50 grpc_custom_socket* socket = connect->socket; in custom_tcp_connect_cleanup()
51 grpc_resource_quota_unref_internal(connect->resource_quota); in custom_tcp_connect_cleanup()
52 gpr_free(connect->addr_name); in custom_tcp_connect_cleanup()
53 gpr_free(connect); in custom_tcp_connect_cleanup()
66 grpc_custom_tcp_connect* connect = socket->connector; in on_alarm() local
70 connect->addr_name, str); in on_alarm()
78 done = (--connect->refs == 0); in on_alarm()
80 custom_tcp_connect_cleanup(connect); in on_alarm()
87 grpc_custom_tcp_connect* connect = socket->connector; in custom_connect_callback() local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_client_cfstream.cc | 72 static void CFStreamConnectCleanup(CFStreamConnect* connect) { in CFStreamConnectCleanup() argument
73 grpc_resource_quota_unref_internal(connect->resource_quota); in CFStreamConnectCleanup()
74 CFSTREAM_HANDLE_UNREF(connect->stream_handle, "async connect clean up"); in CFStreamConnectCleanup()
75 CFRelease(connect->read_stream); in CFStreamConnectCleanup()
76 CFRelease(connect->write_stream); in CFStreamConnectCleanup()
77 gpr_mu_destroy(&connect->mu); in CFStreamConnectCleanup()
78 delete connect; in CFStreamConnectCleanup()
82 CFStreamConnect* connect = static_cast<CFStreamConnect*>(arg); in OnAlarm() local
84 gpr_log(GPR_DEBUG, "CLIENT_CONNECT :%p OnAlarm, error:%p", connect, error); in OnAlarm()
86 gpr_mu_lock(&connect->mu); in OnAlarm()
[all …]
|
| D | tcp_client_custom.cc | 49 static void custom_tcp_connect_cleanup(grpc_custom_tcp_connect* connect) { in custom_tcp_connect_cleanup() argument
50 grpc_custom_socket* socket = connect->socket; in custom_tcp_connect_cleanup()
51 grpc_resource_quota_unref_internal(connect->resource_quota); in custom_tcp_connect_cleanup()
52 delete connect; in custom_tcp_connect_cleanup()
65 grpc_custom_tcp_connect* connect = socket->connector; in on_alarm() local
68 connect->addr_name.c_str(), grpc_error_std_string(error).c_str()); in on_alarm()
76 done = (--connect->refs == 0); in on_alarm()
78 custom_tcp_connect_cleanup(connect); in on_alarm()
84 grpc_custom_tcp_connect* connect = socket->connector; in custom_connect_callback_internal() local
86 grpc_closure* closure = connect->closure; in custom_connect_callback_internal()
[all …]
|
| /external/strace/tests-mx32/ |
| D | net-sockaddr.c | 62 int ret = connect(-1, (void *) un, len); in check_un()
68 ret = connect(-1, (void *) un, len); in check_un()
74 ret = connect(-1, (void *) un, len); in check_un()
83 ret = connect(-1, (void *) un, len); in check_un()
89 ret = connect(-1, (void *) un, len); in check_un()
97 ret = connect(-1, (void *) un, len); in check_un()
103 ret = connect(-1, (void *) un, len); in check_un()
109 ret = connect(-1, (void *) un, len); in check_un()
116 ret = connect(-1, (void *) un, len); in check_un()
122 ret = connect(-1, (void *) un, len); in check_un()
[all …]
|
| /external/strace/tests-m32/ |
| D | net-sockaddr.c | 62 int ret = connect(-1, (void *) un, len); in check_un()
68 ret = connect(-1, (void *) un, len); in check_un()
74 ret = connect(-1, (void *) un, len); in check_un()
83 ret = connect(-1, (void *) un, len); in check_un()
89 ret = connect(-1, (void *) un, len); in check_un()
97 ret = connect(-1, (void *) un, len); in check_un()
103 ret = connect(-1, (void *) un, len); in check_un()
109 ret = connect(-1, (void *) un, len); in check_un()
116 ret = connect(-1, (void *) un, len); in check_un()
122 ret = connect(-1, (void *) un, len); in check_un()
[all …]
|
| /external/strace/tests/ |
| D | net-sockaddr.c | 62 int ret = connect(-1, (void *) un, len); in check_un()
68 ret = connect(-1, (void *) un, len); in check_un()
74 ret = connect(-1, (void *) un, len); in check_un()
83 ret = connect(-1, (void *) un, len); in check_un()
89 ret = connect(-1, (void *) un, len); in check_un()
97 ret = connect(-1, (void *) un, len); in check_un()
103 ret = connect(-1, (void *) un, len); in check_un()
109 ret = connect(-1, (void *) un, len); in check_un()
116 ret = connect(-1, (void *) un, len); in check_un()
122 ret = connect(-1, (void *) un, len); in check_un()
[all …]
|
| /external/mockftpserver/tags/1.1/src/test/java/org/mockftpserver/stub/ |
| D | StubFtpServerIntegrationTest.java | 77 ftpClient.connect(SERVER); in testLogin()
97 ftpClient.connect(SERVER); in testAcct()
120 ftpClient.connect(SERVER); in testHelp()
132 ftpClient.connect(SERVER); in testList()
151 ftpClient.connect(SERVER); in testList_PassiveMode()
169 ftpClient.connect(SERVER); in testNlst()
192 ftpClient.connect(SERVER); in testPwd()
209 ftpClient.connect(SERVER); in testStat()
227 ftpClient.connect(SERVER); in testStat_MultilineReplyText()
239 ftpClient.connect(SERVER); in testSyst()
[all …]
|
| /external/mockftpserver/tags/1.0/src/test/java/org/mockftpserver/stub/ |
| D | StubFtpServerIntegrationTest.java | 77 ftpClient.connect(SERVER); in testLogin()
97 ftpClient.connect(SERVER); in testAcct()
120 ftpClient.connect(SERVER); in testHelp()
132 ftpClient.connect(SERVER); in testList()
151 ftpClient.connect(SERVER); in testList_PassiveMode()
169 ftpClient.connect(SERVER); in testNlst()
192 ftpClient.connect(SERVER); in testPwd()
209 ftpClient.connect(SERVER); in testStat()
227 ftpClient.connect(SERVER); in testStat_MultilineReplyText()
239 ftpClient.connect(SERVER); in testSyst()
[all …]
|
| /external/python/cpython3/Lib/sqlite3/test/ |
| D | backup.py | 7 cx = self.cx = sqlite.connect(":memory:")
35 bck = sqlite.connect(':memory:')
41 bck = sqlite.connect(':memory:')
42 source = sqlite.connect(":memory:")
48 bck = sqlite.connect(':memory:')
58 with sqlite.connect(':memory:') as bck:
62 with sqlite.connect(':memory:') as bck:
72 with sqlite.connect(':memory:') as bck:
86 with sqlite.connect(':memory:') as bck:
99 with sqlite.connect(':memory:') as bck:
[all …]
|
| D | hooks.py | 31 con = sqlite.connect(":memory:")
36 con = sqlite.connect(":memory:")
42 con = sqlite.connect(":memory:")
50 con = sqlite.connect(":memory:")
68 con = sqlite.connect(":memory:")
92 con = sqlite.connect(":memory:")
112 con = sqlite.connect(":memory:")
126 con = sqlite.connect(":memory:")
138 con = sqlite.connect(":memory:")
154 con = sqlite.connect(":memory:")
[all …]
|
| D | regression.py | 32 self.con = sqlite.connect(":memory:")
44 con = sqlite.connect(":memory:", detect_types=sqlite.PARSE_COLNAMES)
56 con = sqlite.connect(":memory:", cached_statements=5)
80 con = sqlite.connect(":memory:")
90 con = sqlite.connect(":memory:")
125 con = sqlite.connect(":memory:",detect_types=sqlite.PARSE_DECLTYPES)
141 con = sqlite.connect(":memory:",detect_types=sqlite.PARSE_DECLTYPES)
170 con = sqlite.connect(":memory:")
201 con = sqlite.connect(":memory:")
257 con = sqlite.connect(":memory:", isolation_level=None)
[all …]
|
| /external/scapy/scapy/contrib/ |
| D | mqtt.uts | 43 connect = MQTT(s)
44 assert(connect.length == 6)
45 assert(connect.protoname == b'MQIsdp')
46 assert(connect.protolevel == 3)
47 assert(connect.usernameflag == 0)
48 assert(connect.passwordflag == 0)
49 assert(connect.willretainflag == 0)
50 assert(connect.willQOSflag == 0)
51 assert(connect.willflag == 0)
52 assert(connect.cleansess == 1)
[all …]
|
| /external/curl/tests/data/ |
| D | test2054 | 30 Connect to specific host: use the first "connect-to" string that matches
34 …connect-to foo::bar: --connect-to :123::456 --next http://www.example.com:%HTTPPORT/%TESTNUMBER --…
|
| /external/python/cpython2/Lib/sqlite3/test/ |
| D | hooks.py | 35 con = sqlite.connect(":memory:")
40 con = sqlite.connect(":memory:")
48 con = sqlite.connect(":memory:")
59 con = sqlite.connect(":memory:")
79 con = sqlite.connect(":memory:")
105 con = sqlite.connect(":memory:")
125 con = sqlite.connect(":memory:")
139 con = sqlite.connect(":memory:")
154 con = sqlite.connect(":memory:")
170 con = sqlite.connect(":memory:")
[all …]
|
| D | regression.py | 32 self.con = sqlite.connect(":memory:")
44 con = sqlite.connect(":memory:", detect_types=sqlite.PARSE_COLNAMES)
56 con = sqlite.connect(":memory:", cached_statements=5)
80 con = sqlite.connect(":memory:")
92 con = sqlite.connect(":memory:")
130 con = sqlite.connect(u":memory:")
139 con = sqlite.connect(":memory:",detect_types=sqlite.PARSE_DECLTYPES)
158 con = sqlite.connect(":memory:")
171 con = sqlite.connect(":memory:")
235 con = sqlite.connect(":memory:", isolation_level=None)
[all …]
|
| /external/autotest/database/ |
| D | database_connection_unittest.py | 66 self._fake_backend.connect.expect_call(**_CONNECT_KWARGS)
68 db.connect(db_type=_DB_TYPE, host=_HOST, username=_USER,
77 self._fake_backend.connect.expect_call(**_CONNECT_KWARGS)
79 db.connect()
87 call = self._fake_backend.connect.expect_call(**_CONNECT_KWARGS)
93 self._fake_backend.connect.expect_call(**_CONNECT_KWARGS).and_raises(
107 db.connect()
112 self.assertRaises(FakeDatabaseError, db.connect,
119 self.assertRaises(FakeDatabaseError, db.connect)
128 self.assertRaises(FakeDatabaseError, db.connect)
[all …]
|
| /external/python/mobly/tests/mobly/controllers/android_device_lib/ |
| D | jsonrpc_client_base_test.py | 44 client.connect()
56 client.connect()
70 client.connect()
117 client.connect()
130 client.connect()
143 client.connect()
160 client.connect()
179 client.connect()
198 client.connect()
217 client.connect()
[all …]
|
| /external/ltp/utils/sctp/func_tests/ |
| D | test_1_to_1_connect.c | 121 error = connect(-1, (const struct sockaddr *) &conn_addr, len); in main()
134 error = connect(fd, (const struct sockaddr *) &conn_addr, len); in main()
146 error = connect(sk, (const struct sockaddr *) -1, len); in main()
154 error = connect(sk, (const struct sockaddr *) &conn_addr, (len - 3)); in main()
163 error = connect(sk, (const struct sockaddr *) &conn_addr, len); in main()
176 error = connect(clnt_sk[i], (const struct sockaddr *)&conn_addr, in main()
188 error = connect(clnt2_sk, (const struct sockaddr *) &conn_addr, len); in main()
201 error = connect(lstn_sk, (const struct sockaddr *) &lstn_addr, len); in main()
210 error = connect(acpt_sk[i], (const struct sockaddr *) &lstn_addr, len); in main()
225 error = connect(sk1, (const struct sockaddr *)&conn_addr, len); in main()
|
| /external/parameter-framework/asio-1.10.6/include/asio/ |
| D | connect.hpp | 61 Iterator connect(basic_socket<Protocol, SocketService>& s, Iterator begin);
98 Iterator connect(basic_socket<Protocol, SocketService>& s,
130 Iterator connect(basic_socket<Protocol, SocketService>& s,
167 Iterator connect(basic_socket<Protocol, SocketService>& s,
231 Iterator connect(basic_socket<Protocol, SocketService>& s,
303 Iterator connect(basic_socket<Protocol, SocketService>& s, Iterator begin,
365 Iterator connect(basic_socket<Protocol, SocketService>& s, Iterator begin,
435 Iterator connect(basic_socket<Protocol, SocketService>& s,
|
| /external/rust/crates/tokio/tests/ |
| D | uds_stream.rs | 25 let connect = UnixStream::connect(&sock_path); in accept_read_write() localVariable
26 let ((mut server, _), mut client) = try_join(accept, connect).await?; in accept_read_write()
52 let connect = UnixStream::connect(&sock_path); in shutdown() localVariable
53 let ((mut server, _), mut client) = try_join(accept, connect).await?; in shutdown()
75 let client = UnixStream::connect(&bind_path).await?; in try_read_write()
198 let connect = UnixStream::connect(&bind_path); in create_pair() localVariable
199 let ((server, _), client) = assert_ok!(try_join(accept, connect).await); in create_pair()
312 let client = UnixStream::connect(&bind_path).await?; in try_read_buf()
394 let connect = UnixStream::connect(&sock_path); in epollhup() localVariable
395 tokio::pin!(connect); in epollhup()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | proxy_server.cc | 35 server_socket_->SignalReadEvent.connect(this, &ProxyServer::OnAcceptEvent); in ProxyServer()
69 int_socket_->SignalConnectRequest.connect(this, in ProxyBinding()
71 int_socket_->SignalReadEvent.connect(this, &ProxyBinding::OnInternalRead); in ProxyBinding()
72 int_socket_->SignalWriteEvent.connect(this, &ProxyBinding::OnInternalWrite); in ProxyBinding()
73 int_socket_->SignalCloseEvent.connect(this, &ProxyBinding::OnInternalClose); in ProxyBinding()
74 ext_socket_->SignalConnectEvent.connect(this, in ProxyBinding()
76 ext_socket_->SignalReadEvent.connect(this, &ProxyBinding::OnExternalRead); in ProxyBinding()
77 ext_socket_->SignalWriteEvent.connect(this, &ProxyBinding::OnExternalWrite); in ProxyBinding()
78 ext_socket_->SignalCloseEvent.connect(this, &ProxyBinding::OnExternalClose); in ProxyBinding()
|
| /external/wpa_supplicant_8/wpa_supplicant/wpa_gui-qt4/ |
| D | wpagui.cpp | 54 connect(fileStartServiceAction, SIGNAL(triggered()), this, in WpaGui()
56 connect(fileStopServiceAction, SIGNAL(triggered()), this, in WpaGui()
63 connect(addInterfaceAction, SIGNAL(triggered()), this, in WpaGui()
76 connect(fileEventHistoryAction, SIGNAL(triggered()), this, in WpaGui()
78 connect(fileSaveConfigAction, SIGNAL(triggered()), this, in WpaGui()
80 connect(actionWPS, SIGNAL(triggered()), this, SLOT(wpsDialog())); in WpaGui()
81 connect(actionPeers, SIGNAL(triggered()), this, SLOT(peersDialog())); in WpaGui()
82 connect(fileExitAction, SIGNAL(triggered()), qApp, SLOT(quit())); in WpaGui()
83 connect(networkAddAction, SIGNAL(triggered()), this, in WpaGui()
85 connect(networkEditAction, SIGNAL(triggered()), this, in WpaGui()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/impl/ |
| D | connect.hpp | 41 Iterator connect(basic_socket<Protocol, SocketService>& s, Iterator begin) in connect() function
44 Iterator result = connect(s, begin, ec); in connect()
50 inline Iterator connect(basic_socket<Protocol, SocketService>& s, in connect() function
53 return connect(s, begin, Iterator(), detail::default_connect_condition(), ec); in connect()
57 Iterator connect(basic_socket<Protocol, SocketService>& s, in connect() function
61 Iterator result = connect(s, begin, end, ec); in connect()
67 inline Iterator connect(basic_socket<Protocol, SocketService>& s, in connect() function
70 return connect(s, begin, end, detail::default_connect_condition(), ec); in connect()
75 Iterator connect(basic_socket<Protocol, SocketService>& s, in connect() function
79 Iterator result = connect(s, begin, connect_condition, ec); in connect()
[all …]
|
| /external/rust/crates/openssl/src/ssl/test/ |
| D | mod.rs | 66 client.connect(); in verify_trusted()
82 client.connect(); in verify_trusted_with_set_cert()
97 client.connect(); in verify_untrusted_callback_override_ok()
127 client.connect(); in verify_trusted_callback_override_ok()
157 client.connect(); in verify_callback_load_certs()
173 client.connect(); in verify_trusted_get_error_ok()
211 client.connect(); in verify_callback()
233 client.connect(); in ssl_verify_callback()
263 let mut s = server.client().connect(); in zero_length_buffers()
272 let s = server.client().connect(); in peer_certificate()
[all …]
|