| /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
69 connect->addr_name.c_str(), str); in on_alarm()
77 done = (--connect->refs == 0); in on_alarm()
79 custom_tcp_connect_cleanup(connect); in on_alarm()
85 grpc_custom_tcp_connect* connect = socket->connector; in custom_connect_callback_internal() local
87 grpc_closure* closure = connect->closure; in custom_connect_callback_internal()
[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/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/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 | 8 cx = self.cx = sqlite.connect(":memory:")
34 bck = sqlite.connect(':memory:')
40 bck = sqlite.connect(':memory:')
41 source = sqlite.connect(":memory:")
47 bck = sqlite.connect(':memory:')
57 with sqlite.connect(':memory:') as bck:
61 with sqlite.connect(':memory:') as bck:
71 with sqlite.connect(':memory:') as bck:
85 with sqlite.connect(':memory:') as bck:
98 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:")
70 con = sqlite.connect(":memory:")
94 con = sqlite.connect(":memory:")
114 con = sqlite.connect(":memory:")
128 con = sqlite.connect(":memory:")
140 con = sqlite.connect(":memory:")
156 con = sqlite.connect(":memory:")
[all …]
|
| D | regression.py | 33 self.con = sqlite.connect(":memory:")
45 con = sqlite.connect(":memory:", detect_types=sqlite.PARSE_COLNAMES)
57 con = sqlite.connect(":memory:", cached_statements=5)
81 con = sqlite.connect(":memory:")
92 con = sqlite.connect(":memory:")
127 con = sqlite.connect(":memory:",detect_types=sqlite.PARSE_DECLTYPES)
143 con = sqlite.connect(":memory:",detect_types=sqlite.PARSE_DECLTYPES)
172 con = sqlite.connect(":memory:")
203 con = sqlite.connect(":memory:")
259 con = sqlite.connect(":memory:", isolation_level=None)
[all …]
|
| /external/llvm-project/llvm/unittests/ADT/ |
| D | DirectedGraphTest.cpp | 108 EXPECT_TRUE(DG.connect(N1, N2, E2)); in TEST()
109 EXPECT_TRUE(DG.connect(N2, N3, E3)); in TEST()
110 EXPECT_TRUE(DG.connect(N3, N1, E1)); in TEST()
120 EXPECT_FALSE(DG.connect(N3, N1, E1)); in TEST()
146 DG.connect(N1, N2, E2); in TEST()
147 DG.connect(N2, N3, E3); in TEST()
148 DG.connect(N3, N1, E1); in TEST()
192 DG.connect(N1, N2, E2); in TEST()
193 DG.connect(N2, N3, E3); in TEST()
194 DG.connect(N3, N1, E1); in TEST()
[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/2054 --connect…
|
| D | test2050 | 16 <connect>
19 </connect>
54 http://www.example.com.2050/2050 --connect-to ::connect.example.com.2050:%HTTPPORT -x %HOSTIP:%PROX…
65 CONNECT connect.example.com.2050:%HTTPPORT HTTP/1.1
66 Host: connect.example.com.2050:%HTTPPORT
|
| /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/ltp/utils/sctp/func_tests/ |
| D | test_1_to_1_connect.c | 117 error = connect(-1, (const struct sockaddr *) &conn_addr, len); in main()
130 error = connect(fd, (const struct sockaddr *) &conn_addr, len); in main()
142 error = connect(sk, (const struct sockaddr *) -1, len); in main()
150 error = connect(sk, (const struct sockaddr *) &conn_addr, (len - 3)); in main()
159 error = connect(sk, (const struct sockaddr *) &conn_addr, len); in main()
172 error = connect(clnt_sk[i], (const struct sockaddr *)&conn_addr, in main()
184 error = connect(clnt2_sk, (const struct sockaddr *) &conn_addr, len); in main()
197 error = connect(lstn_sk, (const struct sockaddr *) &lstn_addr, len); in main()
206 error = connect(acpt_sk[i], (const struct sockaddr *) &lstn_addr, len); in main()
221 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/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/pigweed/pw_web_ui/src/transport/ |
| D | web_serial_transport_test.ts | 33 await transport.connect();
40 await transport.connect();
53 await transport.connect();
64 await transport.connect();
82 await transport.connect();
95 await expectAsync(transport.connect()).toBeRejectedWith(connectError);
100 await transport.connect();
|