Home
last modified time | relevance | path

Searched refs:client (Results 1 - 25 of 854) sorted by relevance

12345678910>>...35

/third_party/lwip/src/apps/mqtt/
H A Dmqtt.c3 * MQTT client
5 * @defgroup mqtt MQTT client
80 * MQTT client connection states
166 * @param client MQTT client
170 msg_generate_packet_id(mqtt_client_t *client) in msg_generate_packet_id() argument
172 client->pkt_id_seq++; in msg_generate_packet_id()
173 if (client->pkt_id_seq == 0) { in msg_generate_packet_id()
174 client->pkt_id_seq++; in msg_generate_packet_id()
176 return client in msg_generate_packet_id()
537 mqtt_close(mqtt_client_t *client, mqtt_connection_status_t reason) mqtt_close() argument
579 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_cyclic_timer() local
635 pub_ack_rec_rel_response(mqtt_client_t *client, u8_t msg, u16_t pkt_id, u8_t qos) pub_ack_rec_rel_response() argument
672 mqtt_message_received(mqtt_client_t *client, u8_t fixed_hdr_len, u16_t length, u32_t remaining_length) mqtt_message_received() argument
840 mqtt_parse_incoming(mqtt_client_t *client, struct pbuf *p) mqtt_parse_incoming() argument
933 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_tcp_recv_cb() local
977 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_tcp_sent_cb() local
1010 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_tcp_err_cb() local
1028 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_tcp_poll_cb() local
1045 mqtt_client_t *client = (mqtt_client_t *)arg; mqtt_tcp_connect_cb() local
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg) mqtt_publish() argument
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub) mqtt_sub_unsub() argument
1237 mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t pub_cb, mqtt_incoming_data_cb_t data_cb, void *arg) mqtt_set_inpub_callback() argument
1265 mqtt_client_free(mqtt_client_t *client) mqtt_client_free() argument
1282 mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ip_addr, u16_t port, mqtt_connection_cb_t cb, void *arg, const struct mqtt_connect_client_info_t *client_info) mqtt_client_connect() argument
1436 mqtt_disconnect(mqtt_client_t *client) mqtt_disconnect() argument
1455 mqtt_client_is_connected(mqtt_client_t *client) mqtt_client_is_connected() argument
[all...]
/third_party/node/test/parallel/
H A Dtest-tls-client-auth.js11 const client = keys.ec10;
21 split(client.cert, client);
33 client: {
34 key: client.key,
35 cert: client.cert,
42 ca: client.ca,
50 // As above, but without requesting client's cert.
52 client: {
59 ca: client
[all...]
H A Dtest-tls-alpn-server-client.js19 assert.strictEqual(result.client.ALPN, expected.client.ALPN);
56 const client = tls.connect(opt, function() {
57 results[clientIndex].client = { ALPN: client.alpnProtocol };
58 client.end();
61 results[clientIndex].client = { error: err };
86 client: { ALPN: 'a' } });
90 client: { ALPN: 'b' } });
94 client
[all...]
H A Dtest-http2-client-setLocalWindowSize.js27 const client = http2.connect(`http://localhost:${server.address().port}`);
29 client.on('connect', common.mustCall(() => {
32 () => client.setLocalWindowSize(outOfRangeNum),
48 () => client.setLocalWindowSize(value),
59 client.close();
72 const client = http2.connect(`http://localhost:${server.address().port}`);
74 client.on('connect', common.mustCall(() => {
77 client.setLocalWindowSize(windowSize);
79 assert.strictEqual(client.state.effectiveLocalWindowSize, windowSize);
80 assert.strictEqual(client
[all...]
H A Dtest-tls-write-error.js26 const client = new TestTLSSocket(server_cert);
28 client.connect({
32 const ch = client.createClientHello();
33 client.write(ch);
36 client.once('data', common.mustCall((buf) => {
39 remaining = client.parseTLSFrame(remaining);
42 const cke = client.createClientKeyExchange();
43 const finished = client.createFinished();
44 const ill = client.createIllegalHandshake();
48 client
[all...]
H A Dtest-http-server-request-timeouts-mixed.js41 client: connect(server.address().port),
46 request.client.setEncoding('utf8');
47 request.client.on('data', common.mustCallAtLeast((chunk) => {
51 request.client.on('end', common.mustCall(() => {
55 request.client.on('error', common.mustNotCall());
57 request.client.resume();
70 request1.client.write(requestBodyPart1);
78 request2.client.write(requestBodyPart1);
81 request3.client.write(requestBodyPart1);
90 request4.client
[all...]
H A Dtest-net-pingpong.js88 const client = net.createConnection(port, host);
90 client.setEncoding('ascii');
91 client.on('connect', common.mustCall(function() {
92 assert.strictEqual(client.readable, true);
93 assert.strictEqual(client.writable, true);
94 client.write('PING');
97 client.on('data', common.mustCall(function(data) {
102 assert.strictEqual(client.writable, false);
103 assert.strictEqual(client.readable, true);
106 assert.strictEqual(client
[all...]
/third_party/node/deps/undici/src/lib/
H A Dclient.js115 channels.sendHeaders = diagnosticsChannel.channel('undici:client:sendHeaders')
116 channels.beforeConnect = diagnosticsChannel.channel('undici:client:beforeConnect')
117 channels.connectError = diagnosticsChannel.channel('undici:client:connectError')
118 channels.connected = diagnosticsChannel.channel('undici:client:connected')
127 * @type {import('../types/client').default}
133 * @param {import('../types/client').Client.Options} options
452 const client = this[kClient]
454 client[kSocket] = null
455 client[kHTTP2Session] = null
457 if (client
[all...]
/third_party/alsa-lib/aserver/
H A Daserver.c154 typedef struct client client_t;
157 int (*open)(client_t *client, int *cookie);
158 int (*cmd)(client_t *client);
159 int (*close)(client_t *client);
162 struct client { struct
223 client_t *client = waiter->private_data;
227 n = write(client->poll_fd, buf, 1);
233 n = read(client->poll_fd, buf, 1);
240 client->polling = 0;
247 client_t *client in pcm_shm_hw_ptr_changed() local
266 client_t *client = pcm->appl.private_data; pcm_shm_appl_ptr_changed() local
283 pcm_shm_open(client_t *client, int *cookie) pcm_shm_open() argument
322 pcm_shm_close(client_t *client) pcm_shm_close() argument
347 shm_ack(client_t *client) shm_ack() argument
362 shm_ack_fd(client_t *client, int fd) shm_ack_fd() argument
377 shm_rbptr_fd(client_t *client, snd_pcm_rbptr_t *rbptr) shm_rbptr_fd() argument
386 client_t *client = snd_async_handler_get_callback_private(handler); async_handler() local
391 pcm_shm_cmd(client_t *client) pcm_shm_cmd() argument
533 client_t *client = waiter->private_data; ctl_handler() local
548 ctl_shm_open(client_t *client, int *cookie) ctl_shm_open() argument
585 ctl_shm_close(client_t *client) ctl_shm_close() argument
610 ctl_shm_cmd(client_t *client) ctl_shm_cmd() argument
725 snd_client_open(client_t *client) snd_client_open() argument
805 client_t *client = waiter->private_data; client_poll_handler() local
819 client_t *client = waiter->private_data; client_ctrl_handler() local
839 client_t *client; inet_pending_handler() local
896 client_t *client = calloc(1, sizeof(*client)); local_handler() local
[all...]
/third_party/python/Lib/test/
H A Dtest_imaplib.py213 client = None variable in NewIMAPTestsMixin
220 Returns (client, server).
244 self.client = self.imap_class(*self.server.server_address)
246 return self.client, self.server
254 # shutdown the client once again
255 if self.client is not None and self.client.state != 'LOGOUT':
256 self.client.shutdown()
285 client, _ = self._setup(EnableHandler)
286 self.assertFalse(client
483 client = self.imap_class("localhost", addr, timeout=0.001) global() variable in NewIMAPTestsMixin.test_imaplib_timeout_functionality_test.TimeoutHandler
[all...]
H A Dtest_ftplib.py60 # bpo-44359: Silently ignore socket errors. Such errors occur when a client
119 # We use this as the string IPv4 address to direct the client
496 self.client = ftplib.FTP(timeout=TIMEOUT, encoding=encoding)
497 self.client.connect(self.server.host, self.server.port)
500 self.client.close()
511 self.assertEqual(self.client.getwelcome(), '220 welcome')
514 self.assertEqual(self.client.sanitize('foo'), repr('foo'))
515 self.assertEqual(self.client.sanitize('pass 12345'), repr('pass *****'))
516 self.assertEqual(self.client.sanitize('PASS 12345'), repr('PASS *****'))
519 self.assertRaises(ValueError, self.client
[all...]
H A Dtest_poplib.py268 self.client = poplib.POP3(self.server.host, self.server.port,
272 self.client.close()
278 self.assertEqual(self.client.getwelcome(),
282 self.assertRaises(poplib.error_proto, self.client._shortcmd, 'echo -err')
285 self.assertOK(self.client.user('guido'))
286 self.assertRaises(poplib.error_proto, self.client.user, 'invalid')
289 self.assertOK(self.client.pass_('python'))
290 self.assertRaises(poplib.error_proto, self.client.user, 'invalid')
293 self.assertEqual(self.client.stat(), (10, 100))
296 self.assertEqual(self.client
[all...]
H A Dtest_docxmlrpc.py2 import http.client namespace
18 self.client.request("GET", "/")
19 self.client.getresponse()
80 self.client = http.client.HTTPConnection("localhost:%d" % PORT)
83 self.client.close()
92 self.client.request("GET", "/")
93 response = self.client.getresponse()
102 self.client.request("GET", "/pydoc.css")
103 response = self.client
[all...]
/third_party/libuv/test/
H A Dtest-udp-connect6.c30 ASSERT_NE((uv_udp_t*)(handle) == &server || (uv_udp_t*)(handle) == &client, 0)
33 static uv_udp_t client; variable
68 uv_udp_connect(&client, NULL); in cl_send_cb()
69 r = uv_udp_send(req, &client, &buf, 1, NULL, cl_send_cb); in cl_send_cb()
72 &client, in cl_send_cb()
94 uv_close((uv_handle_t*) &client, close_cb); in sv_recv_cb()
124 r = uv_udp_init(uv_default_loop(), &client); in TEST_IMPL()
131 r = uv_udp_connect(&client, (const struct sockaddr*) &tmp_addr); in TEST_IMPL()
136 r = uv_udp_connect(&client, NULL); in TEST_IMPL()
143 r = uv_udp_connect(&client, (cons in TEST_IMPL()
[all...]
H A Dtest-udp-connect.c30 ASSERT_NE((uv_udp_t*)(handle) == &server || (uv_udp_t*)(handle) == &client, 0)
33 static uv_udp_t client; variable
68 uv_udp_connect(&client, NULL); in cl_send_cb()
69 r = uv_udp_send(req, &client, &buf, 1, NULL, cl_send_cb); in cl_send_cb()
72 &client, in cl_send_cb()
94 uv_close((uv_handle_t*) &client, close_cb); in sv_recv_cb()
121 r = uv_udp_init(uv_default_loop(), &client); in TEST_IMPL()
128 r = uv_udp_connect(&client, (const struct sockaddr*) &tmp_addr); in TEST_IMPL()
133 r = uv_udp_connect(&client, NULL); in TEST_IMPL()
140 r = uv_udp_connect(&client, (cons in TEST_IMPL()
[all...]
H A Dtest-tcp-create-socket-early.c77 static void tcp_connector(uv_loop_t* loop, uv_tcp_t* client, uv_connect_t* req) { in tcp_connector() argument
83 r = uv_tcp_init(loop, client); in tcp_connector()
87 client, in tcp_connector()
97 uv_tcp_t client; in TEST_IMPL() local
103 r = uv_tcp_init_ex(uv_default_loop(), &client, AF_INET); in TEST_IMPL()
106 r = uv_fileno((const uv_handle_t*) &client, &fd); in TEST_IMPL()
113 r = uv_tcp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); in TEST_IMPL()
120 r = uv_tcp_bind(&client, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
124 r = uv_tcp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); in TEST_IMPL()
130 uv_close((uv_handle_t*) &client, NUL in TEST_IMPL()
140 uv_tcp_t client; TEST_IMPL() local
186 uv_tcp_t client; TEST_IMPL() local
203 uv_tcp_t client, server; TEST_IMPL() local
207 tcp_connector(uv_default_loop(), &client, &connect_req); TEST_IMPL() local
[all...]
H A Dtest-udp-create-socket-early.c37 uv_udp_t client; in TEST_IMPL() local
43 r = uv_udp_init_ex(uv_default_loop(), &client, AF_INET); in TEST_IMPL()
46 r = uv_fileno((const uv_handle_t*) &client, &fd); in TEST_IMPL()
53 r = uv_udp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); in TEST_IMPL()
60 r = uv_udp_bind(&client, (const struct sockaddr*) &addr, 0); in TEST_IMPL()
64 r = uv_udp_getsockname(&client, (struct sockaddr*) &sockname, &namelen); in TEST_IMPL()
70 uv_close((uv_handle_t*) &client, NULL); in TEST_IMPL()
80 uv_udp_t client; in TEST_IMPL() local
89 r = uv_udp_init_ex(uv_default_loop(), &client, AF_INET6); in TEST_IMPL()
92 r = uv_fileno((const uv_handle_t*) &client, in TEST_IMPL()
126 uv_udp_t client; TEST_IMPL() local
[all...]
/third_party/rust/crates/rust-openssl/openssl/src/ssl/test/
H A Dmod.rs53 let mut client = server.client(); in verify_untrusted() variables
54 client.ctx().set_verify(SslVerifyMode::PEER); in verify_untrusted()
56 client.connect_err(); in verify_untrusted()
63 let mut client = server.client(); in verify_trusted() variables
64 client.ctx().set_ca_file("test/root-ca.pem").unwrap(); in verify_trusted()
66 client.connect(); in verify_trusted()
78 let mut client = server.client(); in verify_trusted_with_set_cert() variables
91 let mut client = server.client(); verify_untrusted_callback_override_ok() variables
110 let mut client = server.client(); verify_untrusted_callback_override_bad() variables
124 let mut client = server.client(); verify_trusted_callback_override_ok() variables
144 let mut client = server.client(); verify_trusted_callback_override_bad() variables
159 let mut client = server.client(); verify_callback_load_certs() variables
178 let mut client = server.client(); verify_trusted_get_error_ok() variables
198 let mut client = server.client(); verify_trusted_get_error_err() variables
215 let mut client = server.client(); verify_callback() variables
237 let mut client = server.client().build().builder(); ssl_verify_callback() variables
463 let mut client = server.client(); test_alpn_server_advertise_multiple() variables
480 let mut client = server.client(); test_alpn_server_select_none_fatal() variables
497 let mut client = server.client(); test_alpn_server_select_none() variables
509 let mut client = server.client(); test_alpn_server_unilateral() variables
660 let mut client = server.client(); verify_valid_hostname() variables
664 let mut client = client.build().builder(); verify_valid_hostname() variables
680 let mut client = server.client(); verify_invalid_hostname() variables
684 let mut client = client.build().builder(); verify_invalid_hostname() variables
911 let mut client = server.client(); cert_store() variables
933 let mut client = server.client(); tmp_dh_callback() variables
960 let mut client = server.client(); tmp_ecdh_callback() variables
983 let mut client = server.client(); tmp_dh_callback_ssl() variables
1012 let mut client = server.client(); tmp_ecdh_callback_ssl() variables
1064 let mut client = server.client(); status_callbacks() variables
1075 let mut client = client.build().builder(); status_callbacks() variables
1095 let mut client = server.client(); new_session_callback() variables
1120 let mut client = server.client(); new_session_callback_swapped_ctx() variables
1129 let mut client = client.build().builder(); new_session_callback_swapped_ctx() variables
1200 let mut client = server.client(); no_version_overlap() variables
1233 let mut client = server.client(); custom_extensions() variables
1405 let mut client = server.client(); psk_ciphers() variables
[all...]
/third_party/node/test/pummel/
H A Dtest-net-many-clients.js45 const client = net.createConnection(port);
47 client.connections = 0;
49 client.setEncoding('utf8');
51 client.on('connect', function() {
53 client.recved = '';
54 client.connections += 1;
57 client.on('data', function(chunk) {
61 client.on('end', function() {
62 client.end();
65 client
[all...]
/third_party/pulseaudio/src/modules/dbus/
H A Diface-client.c31 #include "iface-client.h"
33 #define OBJECT_NAME "client"
38 pa_client *client; member
142 idx = c->client->index; in handle_get_index()
154 pa_dbus_send_basic_variant_reply(conn, msg, DBUS_TYPE_STRING, &c->client->driver); in handle_get_driver()
165 if (!c->client->module) { in handle_get_owner_module()
166 pa_dbus_send_error(conn, msg, PA_DBUS_ERROR_NO_SUCH_PROPERTY, "Client %d doesn't have an owner module.", c->client->index); in handle_get_owner_module()
170 owner_module = pa_dbusiface_core_get_module_path(c->core, c->client->module); in handle_get_owner_module()
185 *n = pa_idxset_size(c->client->sink_inputs); in get_playback_streams()
192 PA_IDXSET_FOREACH(sink_input, c->client in get_playback_streams()
395 pa_client *client = call_data; client_proplist_changed_cb() local
422 pa_dbusiface_client_new(pa_dbusiface_core *core, pa_client *client) pa_dbusiface_client_new() argument
[all...]
/third_party/nghttp2/src/
H A Dh2load_http1_session.cc58 auto client = session->get_client(); in htp_statuscb() local
64 client->on_status_code(session->stream_resp_counter_, htp->status_code); in htp_statuscb()
74 auto client = session->get_client(); in htp_msg_completecb() local
80 client->final = llhttp_should_keep_alive(htp) == 0; in htp_msg_completecb()
81 auto req_stat = client->get_req_stat(session->stream_resp_counter_); in htp_msg_completecb()
85 auto config = client->worker->config; in htp_msg_completecb()
87 client->on_stream_close(session->stream_resp_counter_, true, client->final); in htp_msg_completecb()
92 if (client->final) { in htp_msg_completecb()
97 if (client in htp_msg_completecb()
111 auto client = session->get_client(); htp_hdr_keycb() local
122 auto client = session->get_client(); htp_hdr_valcb() local
139 auto client = session->get_client(); htp_body_cb() local
176 Http1Session(Client *client) Http1Session() argument
[all...]
/third_party/node/deps/v8/src/heap/
H A Dsafepoint.cc291 void GlobalSafepoint::AppendClient(Isolate* client) { in AppendClient() argument
294 DCHECK_NULL(client->global_safepoint_prev_client_isolate_); in AppendClient()
295 DCHECK_NULL(client->global_safepoint_next_client_isolate_); in AppendClient()
296 DCHECK_NE(clients_head_, client); in AppendClient()
299 clients_head_->global_safepoint_prev_client_isolate_ = client; in AppendClient()
302 client->global_safepoint_prev_client_isolate_ = nullptr; in AppendClient()
303 client->global_safepoint_next_client_isolate_ = clients_head_; in AppendClient()
305 clients_head_ = client; in AppendClient()
306 client->shared_isolate_ = shared_isolate_; in AppendClient()
309 void GlobalSafepoint::RemoveClient(Isolate* client) { in RemoveClient() argument
[all...]
/third_party/ffmpeg/doc/examples/
H A Dhttp_multiclient.c25 * libavformat multi-client network API usage example.
36 static void process_client(AVIOContext *client, const char *in_uri) in process_client() argument
42 while ((ret = avio_handshake(client)) > 0) { in process_client()
43 av_opt_get(client, "resource", AV_OPT_SEARCH_CHILDREN, &resource); in process_client()
52 av_log(client, AV_LOG_TRACE, "resource=%p\n", resource); in process_client()
58 if ((ret = av_opt_set_int(client, "reply_code", reply_code, AV_OPT_SEARCH_CHILDREN)) < 0) { in process_client()
59 av_log(client, AV_LOG_ERROR, "Failed to set reply_code: %s.\n", av_err2str(ret)); in process_client()
62 av_log(client, AV_LOG_TRACE, "Set reply code to %d\n", reply_code); in process_client()
64 while ((ret = avio_handshake(client)) > 0); in process_client()
87 avio_write(client, bu in process_client()
103 AVIOContext *client = NULL, *server = NULL; main() local
[all...]
/third_party/node/test/fixtures/wpt/streams/transferable/resources/
H A Dservice-worker.js5 const client = msg.source;
7 sendingTest(client);
9 receivingTest(msg, client);
13 function sendingTest(client) {
16 client.postMessage(orig, [orig]);
18 client.postMessage(e.message);
22 function receivingTest(msg, client) {
25 .then(() => client.postMessage('OK'))
26 .catch(e => client.postMessage(`BAD: ${e}`)));
28 client
[all...]
/third_party/lwip/test/unit/mqtt/
H A Dtest_mqtt.c64 static void test_mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t status) in test_mqtt_connection_cb() argument
66 LWIP_UNUSED_ARG(client); in test_mqtt_connection_cb()
73 mqtt_client_t* client; in START_TEST() local
88 client = mqtt_client_new(); in START_TEST()
89 fail_unless(client != NULL); in START_TEST()
90 err = mqtt_client_connect(client, &test_mqtt_remote_ip, 1234, test_mqtt_connection_cb, NULL, &client_info); in START_TEST()
93 client->conn->connected(client->conn->callback_arg, client->conn, ERR_OK); in START_TEST()
98 client in START_TEST()
[all...]

Completed in 12 milliseconds

12345678910>>...35