| /nrf52832-nimble/rt-thread/components/net/at/src/ |
| H A D | at_client.c | 9 * 2018-04-12 chenyong add client implement
10 * 2018-08-17 chenyong multiple client support
269 * @param client current AT client object
277 int at_obj_exec_cmd(at_client_t client, at_response_t resp, const char *cmd_expr, ...) in at_obj_exec_cmd() argument
286 if (client == RT_NULL) in at_obj_exec_cmd()
288 LOG_E("input AT Client object is NULL, please create or get AT Client object!"); in at_obj_exec_cmd()
292 rt_mutex_take(client->lock, RT_WAITING_FOREVER); in at_obj_exec_cmd()
294 client->resp_status = AT_RESP_OK; in at_obj_exec_cmd()
295 client->resp = resp; in at_obj_exec_cmd()
298 at_vprintfln(client->device, cmd_expr, args); in at_obj_exec_cmd()
[all …]
|
| H A D | at_cli.c | 141 rt_kprintf("AT client not initialized\n"); in server_cli_parser()
198 static void client_cli_parser(at_client_t client) in client_cli_parser() argument
211 if (client) in client_cli_parser()
213 /* backup client device RX indicate */ in client_cli_parser()
216 client_odev_rx_ind = client->device->rx_indicate; in client_cli_parser()
217 rt_device_set_rx_indicate(client->device, client_getchar_rx_ind); in client_cli_parser()
227 rt_kprintf("======== Welcome to using RT-Thread AT command client cli ========\n"); in client_cli_parser()
228 …i will forward your command to server port(%s). Press 'ESC' to exit.\n", client->device->parent.na… in client_cli_parser()
248 at_obj_exec_cmd(client, RT_NULL, "%.*s", cur_line_len, cur_line); in client_cli_parser()
259 /* restore client device RX indicate */ in client_cli_parser()
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.0.2/src/apps/mqtt/ |
| H A D | mqtt.c | 3 * MQTT client
5 * @defgroup mqtt MQTT client
77 * MQTT client connection states
162 * @param client MQTT client
166 msg_generate_packet_id(mqtt_client_t *client) in msg_generate_packet_id() argument
168 client->pkt_id_seq++; in msg_generate_packet_id()
169 if (client->pkt_id_seq == 0) { in msg_generate_packet_id()
170 client->pkt_id_seq++; in msg_generate_packet_id()
172 return client->pkt_id_seq; in msg_generate_packet_id()
501 * @param client MQTT client
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/src/apps/mqtt/ |
| H A D | mqtt.c | 3 * 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->pkt_id_seq; in msg_generate_packet_id()
533 * @param client MQTT client
[all …]
|
| /nrf52832-nimble/packages/NimBLE-latest/nimble/host/mesh/src/ |
| H A D | proxy.c | 54 * @brief GATT Client Characteristic Configuration
198 static int filter_set(struct bt_mesh_proxy_client *client, in filter_set() argument
213 memset(client->filter, 0, sizeof(client->filter)); in filter_set()
214 client->filter_type = WHITELIST; in filter_set()
217 memset(client->filter, 0, sizeof(client->filter)); in filter_set()
218 client->filter_type = BLACKLIST; in filter_set()
228 static void filter_add(struct bt_mesh_proxy_client *client, u16_t addr) in filter_add() argument
238 for (i = 0; i < ARRAY_SIZE(client->filter); i++) { in filter_add()
239 if (client->filter[i] == addr) { in filter_add()
244 for (i = 0; i < ARRAY_SIZE(client->filter); i++) { in filter_add()
[all …]
|
| /nrf52832-nimble/rt-thread/components/dfs/filesystems/nfs/ |
| H A D | nfs_clnt.c | 27 nfsproc3_null_3(void *clnt_res, CLIENT *clnt) in nfsproc3_null_3()
36 nfsproc3_getattr_3(GETATTR3args arg1, GETATTR3res *clnt_res, CLIENT *clnt) in nfsproc3_getattr_3()
45 nfsproc3_setattr_3(SETATTR3args arg1, SETATTR3res *clnt_res, CLIENT *clnt) in nfsproc3_setattr_3()
54 nfsproc3_lookup_3(LOOKUP3args arg1, LOOKUP3res *clnt_res, CLIENT *clnt) in nfsproc3_lookup_3()
63 nfsproc3_access_3(ACCESS3args arg1, ACCESS3res *clnt_res, CLIENT *clnt) in nfsproc3_access_3()
72 nfsproc3_readlink_3(READLINK3args arg1, READLINK3res *clnt_res, CLIENT *clnt) in nfsproc3_readlink_3()
81 nfsproc3_read_3(READ3args arg1, READ3res *clnt_res, CLIENT *clnt) in nfsproc3_read_3()
90 nfsproc3_write_3(WRITE3args arg1, WRITE3res *clnt_res, CLIENT *clnt) in nfsproc3_write_3()
99 nfsproc3_create_3(CREATE3args arg1, CREATE3res *clnt_res, CLIENT *clnt) in nfsproc3_create_3()
108 nfsproc3_mkdir_3(MKDIR3args arg1, MKDIR3res *clnt_res, CLIENT *clnt) in nfsproc3_mkdir_3()
[all …]
|
| H A D | nfs.h | 928 extern enum clnt_stat nfsproc3_null_3(void *, CLIENT *);
930 extern enum clnt_stat nfsproc3_getattr_3(GETATTR3args , GETATTR3res *, CLIENT *);
932 extern enum clnt_stat nfsproc3_setattr_3(SETATTR3args , SETATTR3res *, CLIENT *);
934 extern enum clnt_stat nfsproc3_lookup_3(LOOKUP3args , LOOKUP3res *, CLIENT *);
936 extern enum clnt_stat nfsproc3_access_3(ACCESS3args , ACCESS3res *, CLIENT *);
938 extern enum clnt_stat nfsproc3_readlink_3(READLINK3args , READLINK3res *, CLIENT *);
940 extern enum clnt_stat nfsproc3_read_3(READ3args , READ3res *, CLIENT *);
942 extern enum clnt_stat nfsproc3_write_3(WRITE3args , WRITE3res *, CLIENT *);
944 extern enum clnt_stat nfsproc3_create_3(CREATE3args , CREATE3res *, CLIENT *);
946 extern enum clnt_stat nfsproc3_mkdir_3(MKDIR3args , MKDIR3res *, CLIENT *);
[all …]
|
| H A D | mount_clnt.c | 27 mountproc3_null_3(void *clnt_res, CLIENT *clnt) in mountproc3_null_3()
36 mountproc3_mnt_3(dirpath arg1, mountres3 *clnt_res, CLIENT *clnt) in mountproc3_mnt_3()
45 mountproc3_dump_3(mountlist *clnt_res, CLIENT *clnt) in mountproc3_dump_3()
54 mountproc3_umnt_3(dirpath arg1, void *clnt_res, CLIENT *clnt) in mountproc3_umnt_3()
63 mountproc3_umntall_3(void *clnt_res, CLIENT *clnt) in mountproc3_umntall_3()
72 mountproc3_export_3(exports *clnt_res, CLIENT *clnt) in mountproc3_export_3()
|
| H A D | mount.h | 100 extern enum clnt_stat mountproc3_null_3(void *, CLIENT *);
102 extern enum clnt_stat mountproc3_mnt_3(dirpath , mountres3 *, CLIENT *);
104 extern enum clnt_stat mountproc3_dump_3(mountlist *, CLIENT *);
106 extern enum clnt_stat mountproc3_umnt_3(dirpath , void *, CLIENT *);
108 extern enum clnt_stat mountproc3_umntall_3(void *, CLIENT *);
110 extern enum clnt_stat mountproc3_export_3(exports *, CLIENT *);
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/test/unit/mqtt/ |
| H A D | test_mqtt.c | 64 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()
97 if (client->conn->recv(client->conn->callback_arg, client->conn, p, ERR_OK) != ERR_OK) { in START_TEST()
101 mqtt_disconnect(client); in START_TEST()
103 mem_free(client); in START_TEST()
|
| /nrf52832-nimble/rt-thread/components/dfs/filesystems/nfs/rpc/ |
| H A D | clnt.h | 40 * clnt.h - Client side remote procedure call interface.
132 * Client rpc handle.
134 * Client is responsible for initializing auth, see e.g. auth_none.c.
136 typedef struct CLIENT CLIENT; typedef
137 struct CLIENT { struct
140 enum clnt_stat (*cl_call) (CLIENT *, unsigned long, xdrproc_t, char*, xdrproc_t, argument
144 void (*cl_geterr) (CLIENT *, struct rpc_err *);
146 bool_t (*cl_freeres) (CLIENT *, xdrproc_t, char*);
148 void (*cl_destroy) (CLIENT *); /* destroy this structure */
149 bool_t (*cl_control) (CLIENT *, int, char *);
[all …]
|
| H A D | clnt_generic.c | 48 * Generic client creation: takes (hostname, program-number, protocol) and
49 * returns client handle. Default options are set, which the user can
52 CLIENT *clnt_create(const char *hostname, const unsigned long prog, in clnt_create()
59 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()
92 void clnt_perror(CLIENT *rpch, const char *s) in clnt_perror()
94 rt_kprintf("rpc client error:%s\n", s); in clnt_perror()
|
| H A D | clnt_udp.c | 43 * clnt_udp.c, Implements a UDP/IP based, client side RPC.
53 * UDP bases client side rpc operations
55 static enum clnt_stat clntudp_call(register CLIENT *cl, /* client handle */
64 static void clntudp_geterr(CLIENT *, struct rpc_err *);
65 static bool_t clntudp_freeres(CLIENT *, xdrproc_t, char*);
66 static bool_t clntudp_control(CLIENT *, int, char *);
67 static void clntudp_destroy(CLIENT *);
80 * Private data kept per client handle
100 * Create a UDP based client handle.
115 CLIENT *clntudp_bufcreate(struct sockaddr_in *raddr, in clntudp_bufcreate()
[all …]
|
| H A D | pmap.c | 35 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()
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.0.2/src/include/lwip/apps/ |
| H A D | mqtt.h | 3 * MQTT client
59 * Client information and connection parameters */
61 /** Client identifier, must be set by caller */
94 * client has connected to the server after initiating a mqtt connection attempt by
97 * @param client MQTT client itself
102 typedef void (*mqtt_connection_cb_t)(mqtt_client_t *client, void *arg, mqtt_connection_status_t sta…
176 /** MQTT client */
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);
215 /** Create new client */
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/src/include/lwip/apps/ |
| H A D | mqtt.h | 3 * MQTT client
67 * Client information and connection parameters */
69 /** Client identifier, must be set by caller */
118 * client has connected to the server after initiating a mqtt connection attempt by
121 * @param client MQTT client itself
126 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);
[all …]
|
| H A D | http_client.h | 3 * HTTP client
72 * HTTP client result codes
101 * Prototype of a http client callback function
114 * Prototype of http client callback: called when the headers are received
116 * @param connection http client connection
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.0.2/doc/ |
| H A D | mqtt_client.txt | 1 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 */
36 /* Initiate client and connect to server, if this fails immediately an error code is returned
41 err = mqtt_client_connect(client, ip_addr, MQTT_PORT, mqtt_connection_cb, 0, &ci);
49 Connection to server can also be probed by calling mqtt_client_is_connected(client)
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/doc/ |
| H A D | mqtt_client.txt | 1 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 */
36 /* Initiate client and connect to server, if this fails immediately an error code is returned
41 err = mqtt_client_connect(client, ip_addr, MQTT_PORT, mqtt_connection_cb, 0, &ci);
49 Connection to server can also be probed by calling mqtt_client_is_connected(client)
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/at/include/ |
| H A D | at.h | 9 * 2018-08-17 chenyong multiple client support
190 /* AT client initialize and start*/
193 /* ========================== multiple AT client function ============================ */
195 /* get AT client object */
199 /* AT client wait for connection to external devices. */
200 int at_client_obj_wait_connect(at_client_t client, rt_uint32_t timeout);
202 /* AT client send or receive data */
203 rt_size_t at_client_obj_send(at_client_t client, const char *buf, rt_size_t size);
204 rt_size_t at_client_obj_recv(at_client_t client, char *buf, rt_size_t size, rt_int32_t timeout);
206 /* set AT client a line end sign */
[all …]
|
| /nrf52832-nimble/packages/NimBLE-latest/apps/blemesh_models_example_2/ |
| H A D | README.md | 10 - Generic OnOff Client
12 - Generic Level Client
15 - Generic Power OnOff Client
18 - Light Lightness Client
21 - Light CTL Client
27 - Generic OnOff Client
29 - Generic Level Client
44 * Button1 and Button2 are associated with gen. OnOff Client or Vendor Model which is part of Root e…
45 …Button3 and Button4 are associated with gen. Level Client / Light Lightness Client / Light CTL Cli…
96 The meshctl utility also supports a onoff model client that can be used to
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/ |
| H A D | FEATURES | 7 - 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…
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/src/include/lwip/prot/ |
| H A D | dhcp6.h | 70 /* DHCP6 client states */
95 … 1 /* Failure, reason unspecified; this status code is sent by either a client or a server to ind…
97 #define DHCP6_STATUS_NOBINDING 3 /* Client record (binding) unavailable. */
98 …4 /* The prefix for the address is not appropriate for the link to which the client is attached. */
99 #define DHCP6_STATUS_USEMULTICAST 5 /* Sent by a server to a client to force the client to send m…
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/src/apps/lwiperf/ |
| H A D | lwiperf.c | 10 * This is a simple performance measuring client/server to check your bandwith using
11 * iPerf2 on a PC as server/client.
12 * It is currently a minimal implementation providing a TCP client/server only.
87 /** This is the Iperf settings struct sent from the client */
107 /* 1=server, 0=client */
109 /* master state used to abort sessions (e.g. listener, main client) */
123 /* 1=start server when client is closed */
296 /* time specified by the client is over -> close the connection */ in lwiperf_tcp_client_send_more()
383 /** Start TCP connection back to the client (either parallel or after the
449 new_conn->settings.flags = 0; /* prevent the remote side starting back as client again */ in lwiperf_tx_start_passive()
[all …]
|
| /nrf52832-nimble/rt-thread/components/net/lwip-2.1.0/src/apps/http/ |
| H A D | http_client.c | 3 * HTTP client
38 * @defgroup httpc HTTP client
63 * HTTPC_DEBUG: Enable debugging for HTTP client.
154 /** Free http client state and deallocate all resources within */
277 /** http client tcp recv callback */
318 … /* full header received, send window update for header bytes and call into client callback */ in httpc_tcp_recv()
350 /** http client tcp err callback */
362 /** http client tcp poll callback */
380 /** http client tcp sent callback */
391 /** http client tcp connected callback */
[all …]
|