Home
last modified time | relevance | path

Searched refs:client (Results 1 – 25 of 49) sorted by relevance

12

/components/net/at/src/
A Dat_client.c330 …client->last_cmd_len = at_vprintfln(client->device, client->send_buf, client->send_bufsz, cmd_expr… in at_obj_exec_cmd()
411 …client->last_cmd_len = at_vprintfln(client->device, client->send_buf, client->send_bufsz, cmd_expr… in at_obj_exec_cmd_format()
415 …client->last_cmd_len = at_vprintf(client->device, client->send_buf, client->send_bufsz, cmd_expr, … in at_obj_exec_cmd_format()
419 …client->last_cmd_len = at_vprintfcr(client->device, client->send_buf, client->send_bufsz, cmd_expr… in at_obj_exec_cmd_format()
423 …client->last_cmd_len = at_vprintflf(client->device, client->send_buf, client->send_bufsz, cmd_expr… in at_obj_exec_cmd_format()
711 return client; in at_client_get_first()
782 rt_memset(client->recv_line_buf, 0x00, client->recv_bufsz); in at_recv_readline()
801 if (client->recv_line_len < client->recv_bufsz) in at_recv_readline()
811 client->urc = get_urc_obj(client); in at_recv_readline()
851 client->urc->func(client, client->recv_line_buf, client->recv_line_len); in client_parser()
[all …]
A Dat_cli.c194 static void client_cli_parser(at_client_t client) in client_cli_parser() argument
208 if (client) in client_cli_parser()
212 client_odev_status = client->status; in client_cli_parser()
213 client->status = AT_STATUS_CLI; in client_cli_parser()
222 client_odev_rx_ind = client->device->rx_indicate; in client_cli_parser()
223 rt_device_set_rx_indicate(client->device, client_getchar_rx_ind); in client_cli_parser()
267 client->status = client_odev_status; in client_cli_parser()
314 at_client_t client = RT_NULL; in at() local
322 client = at_client_get(argv[2]); in at()
323 if (client == RT_NULL) in at()
[all …]
/components/net/lwip/lwip-2.0.3/src/apps/mqtt/
A Dmqtt.c534 client->connect_cb(client, client->connect_arg, reason); in mqtt_close()
568 …if ((client->server_watchdog * MQTT_CYCLIC_TIMER_INTERVAL) > (client->keep_alive + client->keep_al… in mqtt_cyclic_timer()
610 mqtt_output_send(&client->output, client->conn); in pub_ack_rec_rel_response()
662 client->connect_cb(client, client->connect_arg, res); in mqtt_message_received()
793 client->rx_buffer[client->msg_idx++] = b; in mqtt_parse_incoming()
926 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_sent_cb()
998 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_connect_cb()
1083 mqtt_output_send(&client->output, client->conn); in mqtt_publish()
1150 mqtt_output_send(&client->output, client->conn); in mqtt_sub_unsub()
1185 return client; in mqtt_client_new()
[all …]
/components/net/lwip/lwip-2.1.2/src/apps/mqtt/
A Dmqtt.c565 client->connect_cb(client, client->connect_arg, reason); in mqtt_close()
599 …if ((client->server_watchdog * MQTT_CYCLIC_TIMER_INTERVAL) > (client->keep_alive + client->keep_al… in mqtt_cyclic_timer()
641 mqtt_output_send(&client->output, client->conn); in pub_ack_rec_rel_response()
703 client->connect_cb(client, client->connect_arg, res); in mqtt_message_received()
859 client->rx_buffer[client->msg_idx++] = b; in mqtt_parse_incoming()
998 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_sent_cb()
1016 client->conn = 0; in mqtt_tcp_err_cb()
1070 mqtt_output_send(&client->output, client->conn); in mqtt_tcp_connect_cb()
1156 mqtt_output_send(&client->output, client->conn); in mqtt_publish()
1224 mqtt_output_send(&client->output, client->conn); in mqtt_sub_unsub()
[all …]
/components/drivers/i2c/
A Ddev_i2c_bus.c46 client = rt_calloc(1, sizeof(*client)); in i2c_bus_scan_clients()
48 if (!client) in i2c_bus_scan_clients()
61 client->bus = bus; in i2c_bus_scan_clients()
86 RT_ASSERT(client != RT_NULL); in rt_i2c_device_register()
103 client->id = id; in i2c_match()
112 client->ofw_id = rt_ofw_node_match(client->parent.ofw_node, driver->ofw_ids); in i2c_match()
114 if (client->ofw_id) in i2c_match()
116 client->id = RT_NULL; in i2c_match()
131 if (!client->bus) in i2c_probe()
136 err = driver->probe(client); in i2c_probe()
[all …]
/components/net/lwip/lwip-2.1.2/test/unit/mqtt/
A Dtest_mqtt.c64 static void test_mqtt_connection_cb(mqtt_client_t *client, void *arg, mqtt_connection_status_t stat… 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, &clie… in START_TEST()
93 client->conn->connected(client->conn->callback_arg, client->conn, ERR_OK); in START_TEST()
98 client->conn->rcv_wnd -= p->tot_len; in START_TEST()
99 if (client->conn->recv(client->conn->callback_arg, client->conn, p, ERR_OK) != ERR_OK) { in START_TEST()
103 mqtt_disconnect(client); in START_TEST()
[all …]
/components/net/lwip/lwip-2.1.2/src/include/lwip/apps/
A Dmqtt.h126 typedef void (*mqtt_connection_cb_t)(mqtt_client_t *client, void *arg, mqtt_connection_status_t sta…
176 err_t mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connecti…
179 void mqtt_disconnect(mqtt_client_t *client);
182 void mqtt_client_free(mqtt_client_t* client);
184 u8_t mqtt_client_is_connected(mqtt_client_t *client);
186 void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t,
189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void…
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument
196 #define mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0) argument
198 err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_len…
/components/drivers/mailbox/
A Dmailbox.c118 client = chan->client; in rt_mbox_send()
122 if (client->tx_prepare) in rt_mbox_send()
124 client->tx_prepare(client, data); in rt_mbox_send()
170 if (chan->client->tx_done) in rt_mbox_send_done()
172 chan->client->tx_done(chan->client, data, err); in rt_mbox_send_done()
210 chan->client->rx_callback(chan->client, data); in rt_mbox_recv()
235 if (!client && index < 0) in rt_mbox_request_by_index()
240 np = client->dev->ofw_node; in rt_mbox_request_by_index()
306 chan->client = client; in rt_mbox_request_by_index()
324 if (!client || !name) in rt_mbox_request_by_name()
[all …]
/components/net/lwip/lwip-2.0.3/src/include/lwip/apps/
A Dmqtt.h102 typedef void (*mqtt_connection_cb_t)(mqtt_client_t *client, void *arg, mqtt_connection_status_t sta…
209 err_t mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connecti…
213 void mqtt_disconnect(mqtt_client_t *client);
219 u8_t mqtt_client_is_connected(mqtt_client_t *client);
222 void mqtt_set_inpub_callback(mqtt_client_t *client, mqtt_incoming_publish_cb_t,
226 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void…
230 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument
233 #define mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0) argument
237 err_t mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_len…
/components/net/lwip/lwip-2.0.3/doc/
A Dmqtt_client.txt1 MQTT client for lwIP
18 mqtt_client_t *client = mqtt_client_new();
19 if(client != NULL) {
20 example_do_connect(&client);
25 void example_do_connect(mqtt_client_t *client)
30 /* Setup an empty client info structure */
33 /* Minimal amount of information required is client identifier, so set it here */
65 err = mqtt_subscribe(client, "subtopic", 1, mqtt_sub_request_cb, arg);
74 example_do_connect(client);
139 void example_publish(mqtt_client_t *client, void *arg)
[all …]
/components/net/lwip/lwip-2.1.2/doc/
A Dmqtt_client.txt1 MQTT client for lwIP
18 mqtt_client_t *client = mqtt_client_new();
19 if(client != NULL) {
20 example_do_connect(&client);
25 void example_do_connect(mqtt_client_t *client)
30 /* Setup an empty client info structure */
33 /* Minimal amount of information required is client identifier, so set it here */
65 err = mqtt_subscribe(client, "subtopic", 1, mqtt_sub_request_cb, arg);
74 example_do_connect(client);
139 void example_publish(mqtt_client_t *client, void *arg)
[all …]
/components/dfs/dfs_v1/filesystems/nfs/rpc/
A Dclnt_generic.c59 CLIENT *client; in clnt_create() local
78 client = clntudp_create(&server, prog, vers, tv, &sock); in clnt_create()
79 if (client == NULL) return NULL; in clnt_create()
81 clnt_control(client, CLSET_TIMEOUT, (char *)&tv); in clnt_create()
89 return (client); in clnt_create()
A Dpmap.c35 register CLIENT *client = RT_NULL; in pmap_getport() local
40 client = clntudp_bufcreate(address, PMAPPROG, PMAPVERS, timeout, in pmap_getport()
44 if (client != (CLIENT *) NULL) in pmap_getport()
50 if (CLNT_CALL(client, PMAPPROC_GETPORT, (xdrproc_t)xdr_pmap, (char*)&parms, in pmap_getport()
55 CLNT_DESTROY(client); in pmap_getport()
A Dauth_none.c61 static bool_t authnone_marshal(AUTH *client, XDR *xdrs);
107 static bool_t authnone_marshal(AUTH *client, XDR *xdrs) in authnone_marshal() argument
/components/net/lwip/lwip-2.1.2/
A DFEATURES7 - DHCP client, stateless DHCPv6 (since v2.1.0), DNS client (incl. mDNS hostname resolver), AutoIP/A…
11 …altcp), HTTP(S) client (since v2.1.0), SNTP client, SMTP client (SMTPS via altcp), ping, NetBIOS n…
A DSConscript167 # 7. HTTP server + client
185 # 10. SMTP client
190 # 11. SNTP client
211 # 15. MQTT client files
/components/net/at/include/
A Dat.h141 void (*func)(struct at_client *client, const char *data, rt_size_t size);
216 int at_client_obj_wait_connect(at_client_t client, rt_uint32_t timeout);
219 rt_size_t at_client_obj_send(at_client_t client, const char *buf, rt_size_t size);
220 rt_size_t at_client_obj_recv(at_client_t client, char *buf, rt_size_t size, rt_int32_t timeout);
223 void at_obj_set_end_sign(at_client_t client, char ch);
226 int at_obj_set_urc_table(at_client_t client, const struct at_urc * table, rt_size_t size);
229 int at_obj_exec_cmd(at_client_t client, at_response_t resp, const char *cmd_expr, ...);
230 int at_obj_exec_cmd_format(at_client_t client, at_response_t resp, const char* format, const char *…
/components/drivers/include/drivers/
A Dmailbox.h45 struct rt_mbox_client *client; member
73 struct rt_mbox_chan *rt_mbox_request_by_index(struct rt_mbox_client *client, int index);
74 struct rt_mbox_chan *rt_mbox_request_by_name(struct rt_mbox_client *client, char *name);
A Ddev_i2c.h280 rt_err_t (*probe)(struct rt_i2c_client *client);
281 rt_err_t (*remove)(struct rt_i2c_client *client);
282 rt_err_t (*shutdown)(struct rt_i2c_client *client);
286 rt_err_t rt_i2c_device_register(struct rt_i2c_client *client);
/components/net/lwip/lwip-2.0.3/src/netif/ppp/
A Dauth.c1816 char *client;
1838 if (client != NULL && client[0] == 0)
1839 client = NULL;
1864 char *client;
1879 if (client != NULL && client[0] == 0)
1880 client = NULL;
1909 …if (!client || !client[0] || !pcb->settings.user || !pcb->settings.passwd || strcmp(client, pcb->s… in get_secret()
1937 client, server); in get_secret()
1989 char *client;
2322 char *client;
[all …]
/components/net/lwip/lwip-2.1.2/src/netif/ppp/
A Dauth.c1816 char *client;
1838 if (client != NULL && client[0] == 0)
1839 client = NULL;
1864 char *client;
1879 if (client != NULL && client[0] == 0)
1880 client = NULL;
1909 …if (!client || !client[0] || !pcb->settings.user || !pcb->settings.passwd || strcmp(client, pcb->s… in get_secret()
1937 client, server); in get_secret()
1989 char *client;
2322 char *client;
[all …]
/components/net/lwip/lwip-1.4.1/src/netif/ppp/
A Dauth.c1057 have_chap_secret(char *client, char *server, u32_t remote) in have_chap_secret() argument
1059 LWIP_UNUSED_ARG(client); in have_chap_secret()
1074 get_secret(int unit, char *client, char *server, char *secret, int *secret_len, int save_addrs) in get_secret() argument
1086 if(!client || !client[0] || strcmp(client, ppp_settings.user)) { in get_secret()
1092 AUTHDEBUG(LOG_ERR, ("Secret for %s on %s is too long\n", client, server)); in get_secret()
1119 AUTHDEBUG(LOG_ERR, ("Secret for %s on %s is too long\n", client, server)); in get_secret()
1258 scan_authfile(FILE *f, char *client, char *server, char *secret, struct wordlist **addrs, struct wo…
/components/vbus/
A DKconfig37 The interrupt number used to notify the client on a particular system.
42 The interrupt be triggered on a particular system when the client notify the host.
/components/dfs/dfs_v1/filesystems/nfs/
A Dnfs_auth.c30 static bool_t authnone_marshal(AUTH *client, XDR *xdrs);
144 static bool_t authnone_marshal(AUTH *client, XDR *xdrs) in authnone_marshal() argument
/components/net/lwip/lwip-2.1.2/src/
A DFilelists.cmake166 # HTTP server + client
184 # SMTP client
189 # SNTP client
209 # MQTT client files

Completed in 41 milliseconds

12