Home
last modified time | relevance | path

Searched refs:transport (Results 1 - 25 of 88) sorted by relevance

1234

/third_party/python/Lib/test/test_asyncio/
H A Dtest_transports.py19 transport = asyncio.Transport()
20 self.assertEqual(transport._extra, {})
23 transport = asyncio.Transport({'extra': 'info'})
24 self.assertEqual('info', transport.get_extra_info('extra'))
25 self.assertIsNone(transport.get_extra_info('unknown'))
28 self.assertIs(default, transport.get_extra_info('unknown', default))
37 transport = MyTransport()
39 transport.writelines([b'line1',
46 transport = asyncio.Transport()
49 transport
[all...]
H A Dtest_selector_events.py43 def close_transport(transport):
44 # Don't call transport.close() because the event loop and the selector
46 if transport._sock is None:
48 transport._sock.close()
49 transport._sock = None
64 transport = self.loop._make_socket_transport(m, asyncio.Protocol())
65 self.assertIsInstance(transport, _SelectorSocketTransport)
69 repr(transport)
71 close_transport(transport)
369 transport
[all...]
H A Dtest_sendfile.py31 self.transport = None
44 def connection_made(self, transport):
45 self.transport = transport
67 self.transport.close()
77 self.transport = None
79 def connection_made(self, transport):
81 self.transport = transport
128 # just in case if we have transport clos
[all...]
H A Dtest_proactor_events.py24 def close_transport(transport):
25 # Don't call transport.close() because the event loop and the IOCP proactor
27 if transport._sock is None:
29 transport._sock.close()
30 transport._sock = None
46 transport = _ProactorSocketTransport(self.loop, self.sock,
48 self.addCleanup(close_transport, transport)
49 return transport
103 'Fatal read error on pipe transport')
141 'Fatal read error on pipe transport')
[all...]
H A Dtest_subprocess.py54 transport = TestSubprocessTransport(
57 return (transport, protocol)
61 transport, protocol = self.create_transport(waiter)
62 transport._process_exited(6)
65 self.assertEqual(transport.get_returncode(), 6)
72 self.assertFalse(transport.is_closing())
73 self.assertIsNone(transport._loop)
74 self.assertIsNone(transport._proc)
75 self.assertIsNone(transport._protocol)
79 transport
[all...]
H A Dtest_events.py84 self.transport = None
95 def connection_made(self, transport):
96 self.transport = transport
118 def connection_made(self, transport):
119 super().connection_made(transport)
120 transport.write(b'GET / HTTP/1.0\r\nHost: example.com\r\n\r\n')
136 def connection_made(self, transport):
137 self.transport = transport
[all...]
H A Dtest_base_events.py1015 def connection_made(self, transport):
1016 self.transport = transport
1019 transport.write(b'GET / HTTP/1.0\r\nHost: example.com\r\n\r\n')
1049 def connection_made(self, transport):
1050 self.transport = transport
1299 test_utils.run_briefly(self.loop) # allow transport to close
1318 test_utils.run_briefly(self.loop) # allow transport to close
1341 test_utils.run_briefly(self.loop) # allow transport t
[all...]
/third_party/python/Lib/asyncio/
H A Dsubprocess.py40 def connection_made(self, transport):
41 self._transport = transport
43 stdout_transport = transport.get_pipe_transport(1)
50 stderr_transport = transport.get_pipe_transport(2)
57 stdin_transport = transport.get_pipe_transport(0)
119 def __init__(self, transport, protocol, loop):
120 self._transport = transport
126 self.pid = transport.get_pid()
169 transport = self._transport.get_pipe_transport(fd)
182 transport
[all...]
H A Dstreams.py48 transport, _ = await loop.create_connection(
50 writer = StreamWriter(transport, protocol, reader, loop)
98 transport, _ = await loop.create_unix_connection(
100 writer = StreamWriter(transport, protocol, reader, loop)
220 transport = writer.transport
222 self._transport = transport
223 self._over_ssl = transport.get_extra_info('sslcontext') is not None
225 def connection_made(self, transport):
235 transport
328 def transport(self): global() member in StreamWriter
[all...]
H A Dbase_events.py209 raise TypeError("transport should be _FlowControlMixin instance")
229 def connection_made(self, transport):
470 """Create socket transport."""
480 """Create SSL transport."""
485 """Create datagram transport."""
490 """Create read pipe transport."""
495 """Create write pipe transport."""
501 """Create subprocess transport."""
997 Create a streaming transport connection to a given internet host and
1004 (transport, protoco
[all...]
/third_party/pulseaudio/src/modules/bluetooth/
H A Dmodule-bluez5-device.c121 pa_bluetooth_transport *transport; member
338 pa_assert(u->transport); in bt_write_buffer()
341 written = u->transport->write(u->transport, u->stream_fd, u->encoder_buffer, u->encoder_buffer_used, u->write_link_mtu); in bt_write_buffer()
514 pa_assert(u->transport); in bt_process_push()
518 received = bt_transport_read(u->transport, u->stream_fd, u->decoder_buffer, u->decoder_buffer_size, &tstamp); in bt_process_push()
626 pa_assert(u->transport); in transport_acquire()
631 pa_log_debug("Acquiring transport %s", u->transport->path); in transport_acquire()
633 u->stream_fd = u->transport in transport_acquire()
1887 pa_bluetooth_transport *transport; get_port_availability() local
[all...]
H A Dbackend-ofono.c72 pa_bluetooth_transport *transport; member
160 pa_bluetooth_transport *t = card->transport; in card_send()
225 pa_bluetooth_transport_reconfigure(card->transport, pa_bluetooth_get_hf_codec("CVSD"), sco_transport_write, NULL); in card_acquire()
228 pa_bluetooth_transport_reconfigure(card->transport, pa_bluetooth_get_hf_codec("mSBC"), sco_transport_write, NULL); in card_acquire()
253 if (d != card->transport->device) in device_unlink_cb()
281 if (card->transport) in hf_audio_card_free()
282 pa_bluetooth_transport_free(card->transport); in hf_audio_card_free()
424 card->transport = pa_bluetooth_transport_new(d, backend->ofono_bus_id, path, p, NULL, 0); in hf_audio_agent_card_found()
425 card->transport->acquire = hf_audio_agent_transport_acquire; in hf_audio_agent_card_found()
426 card->transport in hf_audio_agent_card_found()
[all...]
/third_party/node/deps/openssl/openssl/crypto/rand/
H A Drand_egd.c73 char* transport) in hpns_socket()
81 if (!_arg_present(transport) || transport == NULL || transport[0] == '\0') in hpns_socket()
86 if (strcmp(current_transport,transport) == 0) in hpns_socket()
89 /* set the requested socket transport */ in hpns_socket()
90 if (socket_transport_name_set(AF_UNIX, transport)) in hpns_socket()
70 hpns_socket(int family, int type, int protocol, char* transport) hpns_socket() argument
/third_party/openssl/crypto/rand/
H A Drand_egd.c73 char* transport) in hpns_socket()
81 if (!_arg_present(transport) || transport == NULL || transport[0] == '\0') in hpns_socket()
86 if (strcmp(current_transport,transport) == 0) in hpns_socket()
89 /* set the requested socket transport */ in hpns_socket()
90 if (socket_transport_name_set(AF_UNIX, transport)) in hpns_socket()
70 hpns_socket(int family, int type, int protocol, char* transport) hpns_socket() argument
/third_party/curl/lib/
H A Dcf-socket.h67 int transport,
90 * set the transport used.
94 int transport);
107 int transport);
120 int transport);
133 int transport);
H A Dconnect.c366 int transport; member
465 ctx->transport); in baller_initiate()
596 * If transport is QUIC, we need to shutdown the ongoing 'other' in is_connected()
1075 int transport) in cf_happy_eyeballs_create()
1088 ctx->transport = transport; in cf_happy_eyeballs_create()
1103 int transport; member
1124 static cf_ip_connect_create *get_cf_create(int transport) in get_cf_create() argument
1128 if(transport == transport_providers[i].transport) in get_cf_create()
1070 cf_happy_eyeballs_create(struct Curl_cfilter **pcf, struct Curl_easy *data, struct connectdata *conn, cf_ip_connect_create *cf_create, const struct Curl_dns_entry *remotehost, int transport) cf_happy_eyeballs_create() argument
1134 cf_he_insert_after(struct Curl_cfilter *cf_at, struct Curl_easy *data, const struct Curl_dns_entry *remotehost, int transport) cf_he_insert_after() argument
1174 int transport; global() member
1323 cf_setup_create(struct Curl_cfilter **pcf, struct Curl_easy *data, const struct Curl_dns_entry *remotehost, int transport, int ssl_mode) cf_setup_create() argument
1355 cf_setup_add(struct Curl_easy *data, struct connectdata *conn, int sockindex, const struct Curl_dns_entry *remotehost, int transport, int ssl_mode) cf_setup_add() argument
1376 Curl_debug_set_transport_provider(int transport, cf_ip_connect_create *cf_create) Curl_debug_set_transport_provider() argument
1389 Curl_cf_setup_insert_after(struct Curl_cfilter *cf_at, struct Curl_easy *data, const struct Curl_dns_entry *remotehost, int transport, int ssl_mode) Curl_cf_setup_insert_after() argument
[all...]
H A Dconnect.h105 int transport);
110 int transport,
128 void Curl_debug_set_transport_provider(int transport,
H A Dcf-socket.c224 * set the transport used.
228 int transport) in Curl_sock_assign_addr()
238 switch(transport) { in Curl_sock_assign_addr()
311 int transport, in Curl_socket_open()
320 Curl_sock_assign_addr(addr, ai, transport); in Curl_socket_open()
775 int transport; member
802 int transport) in cf_socket_ctx_init()
806 ctx->transport = transport; in cf_socket_ctx_init()
807 Curl_sock_assign_addr(&ctx->addr, ai, transport); in cf_socket_ctx_init()
226 Curl_sock_assign_addr(struct Curl_sockaddr_ex *dest, const struct Curl_addrinfo *ai, int transport) Curl_sock_assign_addr() argument
308 Curl_socket_open(struct Curl_easy *data, const struct Curl_addrinfo *ai, struct Curl_sockaddr_ex *addr, int transport, curl_socket_t *sockfd) Curl_socket_open() argument
800 cf_socket_ctx_init(struct cf_socket_ctx *ctx, const struct Curl_addrinfo *ai, int transport) cf_socket_ctx_init() argument
1592 Curl_cf_tcp_create(struct Curl_cfilter **pcf, struct Curl_easy *data, struct connectdata *conn, const struct Curl_addrinfo *ai, int transport) Curl_cf_tcp_create() argument
1729 Curl_cf_udp_create(struct Curl_cfilter **pcf, struct Curl_easy *data, struct connectdata *conn, const struct Curl_addrinfo *ai, int transport) Curl_cf_udp_create() argument
1780 Curl_cf_unix_create(struct Curl_cfilter **pcf, struct Curl_easy *data, struct connectdata *conn, const struct Curl_addrinfo *ai, int transport) Curl_cf_unix_create() argument
[all...]
/third_party/ffmpeg/libavformat/
H A Drtsp.c86 { "rtsp_transport", "set RTSP transport protocols", OFFSET(lower_transport_mask), AV_OPT_TYPE_FLAGS, {.i64 = 0}, INT_MIN, INT_MAX, DEC|ENC, "rtsp_transport" }, \
518 rt->transport = RTSP_TRANSPORT_RAW; in sdp_parse_line()
528 if (rt->transport == RTSP_TRANSPORT_RAW) { in sdp_parse_line()
643 rt->transport = RTSP_TRANSPORT_RDT; in sdp_parse_line()
778 } else if (CONFIG_RTPDEC && rt->transport == RTSP_TRANSPORT_RDT) in ff_rtsp_undo_setup()
780 else if (CONFIG_RTPDEC && rt->transport == RTSP_TRANSPORT_RTP) in ff_rtsp_undo_setup()
853 } else if (rt->transport == RTSP_TRANSPORT_RAW) { in ff_rtsp_open_transport_ctx()
855 } else if (CONFIG_RTPDEC && rt->transport == RTSP_TRANSPORT_RDT && st) in ff_rtsp_open_transport_ctx()
866 } else if (CONFIG_RTPDEC && rt->transport == RTSP_TRANSPORT_RTP && in ff_rtsp_open_transport_ctx()
906 /* XXX: only one transport specificatio
1482 char transport[MAX_URL_SIZE]; ff_rtsp_make_setup_request() local
[all...]
/third_party/ltp/testcases/network/stress/ns-tools/
H A Doutput_ipsec_conf72 mode: transport / tunnel
151 transport)
154 -P $direct1 ipsec $protocol/transport//use ;
157 -P $direct2 ipsec $protocol/transport//use ;
/third_party/alsa-lib/aserver/
H A Daserver.c208 } transport; member
248 volatile snd_pcm_shm_ctrl_t *ctrl = client->transport.shm.ctrl; in pcm_shm_hw_ptr_changed()
267 volatile snd_pcm_shm_ctrl_t *ctrl = client->transport.shm.ctrl; in pcm_shm_appl_ptr_changed()
305 client->transport.shm.ctrl_id = shmid; in pcm_shm_open()
306 client->transport.shm.ctrl = shmat(shmid, 0, 0); in pcm_shm_open()
307 if (client->transport.shm.ctrl == (void*) -1) { in pcm_shm_open()
325 snd_pcm_shm_ctrl_t *ctrl = client->transport.shm.ctrl; in pcm_shm_close()
334 if (client->transport.shm.ctrl) { in pcm_shm_close()
335 err = shmdt((void *)client->transport.shm.ctrl); in pcm_shm_close()
338 err = shmctl(client->transport in pcm_shm_close()
[all...]
/third_party/backends/backend/
H A Dxerox_mfp.h50 typedef struct transport transport; typedef
125 /* transport to use */
126 transport *io;
131 struct transport { struct
142 /* USB transport */
/third_party/mbedtls/library/
H A Dssl_msg.c329 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_STREAM) { in mbedtls_ssl_check_record()
2138 * With stream transport (TLS) on success ssl->in_left == nb_want, but
2139 * with datagram transport (DTLS) on success ssl->in_left >= nb_want,
2168 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_DATAGRAM) { in mbedtls_ssl_fetch_input()
2392 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_DATAGRAM) { in mbedtls_ssl_flush_output()
2804 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_DATAGRAM && in mbedtls_ssl_write_handshake_msg_ext()
2845 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_DATAGRAM) { in mbedtls_ssl_write_handshake_msg_ext()
2888 if (ssl->conf->transport == MBEDTLS_SSL_TRANSPORT_DATAGRAM && in mbedtls_ssl_write_handshake_msg_ext()
2963 mbedtls_ssl_write_version(ssl->out_hdr + 1, ssl->conf->transport, in mbedtls_ssl_write_record()
2978 mbedtls_ssl_write_version(rec.ver, ssl->conf->transport, tls_ve in mbedtls_ssl_write_record()
6290 mbedtls_ssl_write_version(unsigned char version[2], int transport, mbedtls_ssl_protocol_version tls_version) mbedtls_ssl_write_version() argument
6308 mbedtls_ssl_read_version(const unsigned char version[2], int transport) mbedtls_ssl_read_version() argument
[all...]
/third_party/skia/third_party/externals/spirv-tools/utils/vscode/
H A Dextension.js32 run: { command: serverModule, transport: langClient.stdio },
33 debug: { command: serverModule, transport: langClient.stdio, options: debugOptions }
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/
H A Dextension.js32 run: { command: serverModule, transport: langClient.stdio },
33 debug: { command: serverModule, transport: langClient.stdio, options: debugOptions }

Completed in 24 milliseconds

1234