| /external/grpc-grpc/test/http2_test/ |
| D | http2_base_server.py | 31 self._conn = h2.connection.H2Connection(client_side=False)
56 self._conn.initiate_connection()
58 self.transport.write(self._conn.data_to_send())
65 events = self._conn.receive_data(data)
70 if self._conn.data_to_send:
71 self.transport.write(self._conn.data_to_send())
85 self.transport.write(self._conn.data_to_send())
92 self._conn.acknowledge_received_data(len(event.data), event.stream_id)
99 self._conn.send_headers(
108 self.transport.write(self._conn.data_to_send())
[all …]
|
| D | test_max_streams.py | 35 self._base_server._conn.initiate_connection()
36 self._base_server._conn.update_settings(
39 self._base_server.transport.write(self._base_server._conn.data_to_send())
|
| D | test_goaway.py | 48 …self._base_server._conn.close_connection(error_code=0, additional_data=None, last_stream_id=stream…
|
| /external/rust/crates/grpcio-sys/grpc/test/http2_test/ |
| D | http2_base_server.py | 33 self._conn = h2.connection.H2Connection(client_side=False)
58 self._conn.initiate_connection()
60 self.transport.write(self._conn.data_to_send())
67 events = self._conn.receive_data(data)
72 if self._conn.data_to_send:
73 self.transport.write(self._conn.data_to_send())
94 self.transport.write(self._conn.data_to_send())
101 self._conn.acknowledge_received_data(len(event.data), event.stream_id)
108 self._conn.send_headers(
117 self.transport.write(self._conn.data_to_send())
[all …]
|
| D | test_max_streams.py | 37 self._base_server._conn.initiate_connection()
38 self._base_server._conn.update_settings(
42 self._base_server._conn.data_to_send())
|
| D | test_goaway.py | 51 self._base_server._conn.close_connection(error_code=0,
|
| /external/openthread/tools/harness-automation/autothreadharness/ |
| D | rf_shield_controller.py | 64 self._conn = None
75 return self._conn.write('{}\r\n'.format(data))
81 self._conn = serial.Serial(self._port, 9600)
82 if not self._conn.isOpen():
83 self._conn.open()
89 if self._conn:
90 self._conn.close()
91 self._conn = None
|
| /external/python/cpython2/Lib/idlelib/ |
| D | RemoteDebugger.py | 200 self._conn = conn
214 return self._conn.remotecall(self._oid, "frame_attr",
218 cid = self._conn.remotecall(self._oid, "frame_code", (self._fid,), {})
219 return CodeProxy(self._conn, self._oid, cid)
222 did = self._conn.remotecall(self._oid, "frame_globals",
227 did = self._conn.remotecall(self._oid, "frame_locals",
234 dp = DictProxy(self._conn, self._oid, did)
242 self._conn = conn
248 return self._conn.remotecall(self._oid, "code_name",
251 return self._conn.remotecall(self._oid, "code_filename",
[all …]
|
| /external/python/cpython3/Lib/idlelib/ |
| D | debugger_r.py | 204 self._conn = conn
218 return self._conn.remotecall(self._oid, "frame_attr",
222 cid = self._conn.remotecall(self._oid, "frame_code", (self._fid,), {})
223 return CodeProxy(self._conn, self._oid, cid)
226 did = self._conn.remotecall(self._oid, "frame_globals",
231 did = self._conn.remotecall(self._oid, "frame_locals",
238 dp = DictProxy(self._conn, self._oid, did)
246 self._conn = conn
252 return self._conn.remotecall(self._oid, "code_name",
255 return self._conn.remotecall(self._oid, "code_filename",
[all …]
|
| /external/python/mobly/mobly/controllers/android_device_lib/ |
| D | jsonrpc_client_base.py | 123 self._conn = None
206 self._conn = socket.create_connection(('localhost', self.host_port),
214 self._conn = socket.create_connection(('127.0.0.1', self.host_port),
217 self._conn.settimeout(_SOCKET_READ_TIMEOUT)
218 self._client = self._conn.makefile(mode='brw')
246 if self._conn:
247 self._conn.close()
248 self._conn = None
|
| D | snippet_client_v2.py | 127 self._conn = None
155 return self._conn is not None
364 self._conn = socket.create_connection(('localhost', self.host_port),
371 self._conn = socket.create_connection(('127.0.0.1', self.host_port),
374 self._conn.settimeout(_SOCKET_READ_TIMEOUT)
375 self._client = self._conn.makefile(mode='brw')
586 if self._conn:
587 self._conn.close()
588 self._conn = None
|
| D | sl4a_client.py | 106 if self._conn:
|
| D | snippet_client.py | 102 return self._conn is not None
|
| /external/python/mobly/tests/mobly/controllers/android_device_lib/ |
| D | jsonrpc_client_base_test.py | 76 client._conn = mock_conn
78 self.assertIsNone(client._conn)
86 client._conn = mock_conn
343 client._conn = mock_conn
347 self.assertIsNone(client._conn)
351 client._conn = None
354 self.assertIsNone(client._conn)
|
| D | snippet_client_v2_test.py | 160 self.assertIs(self.client._conn, None)
591 self.client._conn = mock_conn
602 self.assertIs(self.client._conn, None)
616 self.client._conn = mock_conn
627 self.assertIs(self.client._conn, None)
640 self.client._conn = None
651 self.assertIs(self.client._conn, None)
665 self.client._conn = mock_conn
677 self.assertIs(self.client._conn, None)
694 self.client._conn = mock_conn
[all …]
|
| D | snippet_client_test.py | 171 client._conn = mock.MagicMock()
175 client._conn.close.side_effect = [Exception('ha'), None]
192 event_client._conn = event_client_conn
198 self.assertIsNone(event_client._conn)
210 event_client._conn = None
215 self.assertIsNone(event_client._conn)
|
| /external/python/cpython2/Lib/ |
| D | httplib.py | 1161 self._conn = conn
1179 (self._conn.host, self._conn.port) = self._conn._get_hostport(host, port)
1180 self._conn.connect()
1196 response = self._conn.getresponse()
1200 response = self._conn.getresponse(buffering)
1207 self.file = self._conn.sock.makefile('rb', 0)
1220 self._conn.close()
|
| /external/tensorflow/tensorflow/python/distribute/ |
| D | multi_process_runner.py | 918 self._conn = {}
926 for conn in self._conn.values():
928 self._conn = {}
959 self._conn[(task_type, task_id)] = conn1
984 for conn in self._conn.values():
988 for (task_type, task_id), conn in self._conn.items():
|
| /external/python/cpython2/Lib/multiprocessing/ |
| D | connection.py | 447 self._conn = conn
455 self._conn.send_bytes(s)
457 s = self._conn.recv_bytes()
|
| /external/python/cpython2/Lib/test/ |
| D | test_httplib.py | 462 c = http._conn
750 self.assertEqual(self.conn._conn.host, HOST)
751 self.assertEqual(self.conn._conn.port, self.port)
758 self.assertNotEqual(self.conn._conn.host, testhost)
759 self.assertNotEqual(self.conn._conn.port, testport)
760 self.assertEqual(self.conn._conn.host, HOST)
761 self.assertEqual(self.conn._conn.port, self.port)
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 772 self._conn = conn
780 self._conn.send_bytes(s)
782 s = self._conn.recv_bytes()
|
| /external/rust/pica/src/bin/server/ |
| D | web.rs | 254 let make_svc = make_service_fn(move |_conn| { in serve()
|
| /external/mesa3d/src/vulkan/wsi/ |
| D | wsi_common_display.c | 102 #define wsi_for_each_display_mode(_mode, _conn) \ argument
104 &(_conn)->display_modes, list)
106 #define wsi_for_each_connector(_conn, _dev) \ argument
107 list_for_each_entry_safe(struct wsi_display_connector, _conn, \
|
| /external/wpa_supplicant_8/src/common/ |
| D | dpp.h | 795 int dpp_tcp_auth(struct dpp_global *dpp, void *_conn,
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | handler.rs | 219 fn set_backend_req_connection(&mut self, _conn: VhostBackendReqConnection) { in set_backend_req_connection()
|