Home
last modified time | relevance | path

Searched refs:client_ptr (Results 1 – 25 of 35) sorted by relevance

12

/NetX-Duo-v6.3.0/addons/mqtt/
Dnxd_mqtt_client.c51 static UINT _nxd_mqtt_client_create_internal(NXD_MQTT_CLIENT *client_ptr, CHAR *client_name,
55 static UINT _nxd_mqtt_packet_send(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, UINT wait_opt…
56 static UINT _nxd_mqtt_packet_receive(NXD_MQTT_CLIENT *client_ptr, NX_PACKET **packet_ptr, UINT wait…
57 static UINT _nxd_mqtt_copy_transmit_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX_P…
59 static VOID _nxd_mqtt_release_transmit_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, N…
60 static VOID _nxd_mqtt_release_receive_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX…
61 static UINT _nxd_mqtt_client_retransmit_message(NXD_MQTT_CLIENT *client_ptr, ULONG wait_option);
62 static UINT _nxd_mqtt_client_connect_packet_send(NXD_MQTT_CLIENT *client_ptr, ULONG wait_option);
113 UINT _nxd_mqtt_client_set_fixed_header(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, UCHAR co… in _nxd_mqtt_client_set_fixed_header() argument
139 client_ptr -> nxd_mqtt_client_packet_pool_ptr, wait_option); in _nxd_mqtt_client_set_fixed_header()
[all …]
Dnxd_mqtt_client.h371 … (*nxd_mqtt_client_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT number_of_…
372 … (*nxd_mqtt_connect_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT status, VO…
374 …D (*nxd_mqtt_disconnect_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr);
375 … (*nxd_mqtt_packet_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, NX_PACKET *pack…
377 … (*nxd_mqtt_ack_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT type, USHO…
448 UINT nxd_mqtt_client_create(NXD_MQTT_CLIENT *client_ptr, CHAR *client_name, CHAR *client_id, UINT c…
452 UINT nxd_mqtt_client_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UINT server_port,
455 UINT nxd_mqtt_client_login_set(NXD_MQTT_CLIENT *client_ptr,
458 UINT nxd_mqtt_client_will_message_set(NXD_MQTT_CLIENT *client_ptr,
462 UINT nxd_mqtt_client_secure_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UINT serve…
[all …]
/NetX-Duo-v6.3.0/addons/websocket/
Dnx_websocket_client.c95 UINT _nxe_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_p… in _nxe_websocket_client_create() argument
102 … (client_ptr == NX_NULL) || (client_ptr -> nx_websocket_client_id == NX_WEBSOCKET_CLIENT_ID) || in _nxe_websocket_client_create()
109 status = _nx_websocket_client_create(client_ptr, client_name, ip_ptr, pool_ptr); in _nxe_websocket_client_create()
155 UINT _nx_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_pt… in _nx_websocket_client_create() argument
161 memset((void *)client_ptr, 0, sizeof(NX_WEBSOCKET_CLIENT)); in _nx_websocket_client_create()
164 …status = tx_mutex_create(&client_ptr -> nx_websocket_client_mutex, (CHAR *)client_name, TX_NO_INHE… in _nx_websocket_client_create()
171 client_ptr -> nx_websocket_client_name = client_name; in _nx_websocket_client_create()
174 client_ptr -> nx_websocket_client_ip_ptr = ip_ptr; in _nx_websocket_client_create()
177 client_ptr -> nx_websocket_client_packet_pool_ptr = pool_ptr; in _nx_websocket_client_create()
180 client_ptr -> nx_websocket_client_id = NX_WEBSOCKET_CLIENT_ID; in _nx_websocket_client_create()
[all …]
Dnx_websocket_client.h262 UINT nx_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_ptr…
263 UINT nx_websocket_client_delete(NX_WEBSOCKET_CLIENT *client_ptr);
264 UINT nx_websocket_client_packet_allocate(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET **packet_ptr, …
265 UINT nx_websocket_client_connect(NX_WEBSOCKET_CLIENT *client_ptr, NX_TCP_SOCKET *socket_ptr,
270 UINT nx_websocket_client_secure_connect(NX_WEBSOCKET_CLIENT *client_ptr, NX_SECURE_TLS_SESSION *tl…
275 UINT nx_websocket_client_disconnect(NX_WEBSOCKET_CLIENT *client_ptr, UINT wait_option);
276 UINT nx_websocket_client_send(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET *packet_ptr, UINT code, U…
277 UINT nx_websocket_client_receive(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET **packet_ptr, UINT *co…
278 UINT nx_websocket_client_connection_status_callback_set(NX_WEBSOCKET_CLIENT *client_ptr, VOID *con…
285 UINT _nxe_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_p…
[all …]
/NetX-Duo-v6.3.0/addons/smtp/
Dnxd_smtp_client.c57 static UINT _nx_smtp_cmd_idle(NX_SMTP_CLIENT *client_ptr);
58 static UINT _nx_smtp_rsp_idle(NX_SMTP_CLIENT *client_ptr);
59 static UINT _nx_smtp_cmd_greeting(NX_SMTP_CLIENT *client_ptr);
60 static UINT _nx_smtp_rsp_greeting(NX_SMTP_CLIENT *client_ptr);
61 static UINT _nx_smtp_cmd_ehlo(NX_SMTP_CLIENT *client_ptr);
62 static UINT _nx_smtp_rsp_ehlo(NX_SMTP_CLIENT *client_ptr);
63 static UINT _nx_smtp_cmd_helo(NX_SMTP_CLIENT *client_ptr);
64 static UINT _nx_smtp_rsp_helo(NX_SMTP_CLIENT *client_ptr);
65 static UINT _nx_smtp_cmd_mail(NX_SMTP_CLIENT *client_ptr);
66 static UINT _nx_smtp_rsp_mail(NX_SMTP_CLIENT *client_ptr);
[all …]
Dnxd_smtp_client.h359 UINT (*cmd) (NX_SMTP_CLIENT *client_ptr);
360 UINT (*rsp) (NX_SMTP_CLIENT *client_ptr);
395 UINT nxd_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pa…
400 UINT nx_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
401 UINT nx_smtp_mail_send(NX_SMTP_CLIENT *client_ptr, CHAR *recipient_address, UINT priority,
410 UINT _nxd_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pac…
414 UINT _nxde_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pa…
419 UINT _nx_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
420 UINT _nxe_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
422 UINT _nx_smtp_mail_send(NX_SMTP_CLIENT *client_ptr, CHAR *recipient_address, UINT priority,
[all …]
/NetX-Duo-v6.3.0/addons/telnet/
Dnxd_telnet_client.c87 UINT _nxde_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, NXD_ADDRESS *server_ip_address, in _nxde_telnet_client_connect() argument
95 if ((client_ptr == NX_NULL) || (!server_ip_address)) in _nxde_telnet_client_connect()
101 if (client_ptr -> nx_telnet_client_id != NX_TELNET_CLIENT_ID) in _nxde_telnet_client_connect()
110 status = _nxd_telnet_client_connect(client_ptr, server_ip_address, server_port, wait_option); in _nxde_telnet_client_connect()
162 UINT _nxd_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, NXD_ADDRESS *server_ip_address, in _nxd_telnet_client_connect() argument
171 if (client_ptr -> nx_telnet_client_socket.nx_tcp_socket_state != NX_TCP_CLOSED) in _nxd_telnet_client_connect()
179 …status = nx_tcp_client_socket_bind(&(client_ptr -> nx_telnet_client_socket), NX_ANY_PORT, wait_op… in _nxd_telnet_client_connect()
191 status = nxd_tcp_client_socket_connect(&(client_ptr -> nx_telnet_client_socket), in _nxd_telnet_client_connect()
199 nx_tcp_client_socket_unbind(&(client_ptr -> nx_telnet_client_socket)); in _nxd_telnet_client_connect()
254 UINT _nxe_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip, UINT server_port, U… in _nxe_telnet_client_connect() argument
[all …]
Dnxd_telnet_client.h155 UINT nx_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT server…
156 UINT nx_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, ULO…
157 UINT nx_telnet_client_delete(NX_TELNET_CLIENT *client_ptr);
158 UINT nx_telnet_client_disconnect(NX_TELNET_CLIENT *client_ptr, ULONG wait_option);
159 UINT nx_telnet_client_packet_receive(NX_TELNET_CLIENT *client_ptr, NX_PACKET **packet_ptr, ULONG…
160 UINT nx_telnet_client_packet_send(NX_TELNET_CLIENT *client_ptr, NX_PACKET *packet_ptr, ULONG wai…
169 UINT _nxe_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT serv…
170 UINT _nx_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT serve…
171 UINT _nxe_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, U…
172 UINT _nx_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, UL…
[all …]
Dnxd_telnet_server.c645 NX_TELNET_CLIENT_REQUEST *client_ptr; in _nx_telnet_server_disconnect() local
648 client_ptr = &(server_ptr -> nx_telnet_server_client_list[logical_connection]); in _nx_telnet_server_disconnect()
651 if (client_ptr -> nx_telnet_client_request_socket.nx_tcp_socket_state >= NX_TCP_ESTABLISHED) in _nx_telnet_server_disconnect()
655 …nx_tcp_socket_disconnect(&(client_ptr -> nx_telnet_client_request_socket), NX_TELNET_SERVER_TIMEOU… in _nx_telnet_server_disconnect()
658 nx_tcp_server_socket_unaccept(&(client_ptr -> nx_telnet_client_request_socket)); in _nx_telnet_server_disconnect()
665 client_ptr -> nx_telnet_client_request_activity_timeout = 0; in _nx_telnet_server_disconnect()
672 …(server_ptr -> nx_telnet_connection_end)(server_ptr, client_ptr -> nx_telnet_client_request_connec… in _nx_telnet_server_disconnect()
687 client_ptr = &(server_ptr -> nx_telnet_server_client_list[i]); in _nx_telnet_server_disconnect()
690 if (client_ptr -> nx_telnet_client_request_socket.nx_tcp_socket_state == NX_TCP_CLOSED) in _nx_telnet_server_disconnect()
695 … &(client_ptr -> nx_telnet_client_request_socket)); in _nx_telnet_server_disconnect()
[all …]
/NetX-Duo-v6.3.0/addons/ptp/
Dnxd_ptp_client.c261 static UINT _nx_ptp_msg_parse_hdr(NX_PTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX_PTP_MSG_HEAD… in _nx_ptp_msg_parse_hdr() argument
291 (NX_PTP_MSG_DOMAIN(ptr) != client_ptr -> nx_ptp_client_domain)) in _nx_ptp_msg_parse_hdr()
303 (interface_index != client_ptr -> nx_ptp_client_interface_index) in _nx_ptp_msg_parse_hdr()
306 !client_ptr -> nx_ptp_client_ipv4_group_joined) || in _nx_ptp_msg_parse_hdr()
308 !client_ptr -> nx_ptp_client_ipv6_group_joined) in _nx_ptp_msg_parse_hdr()
318 if (client_ptr -> nx_ptp_client_state == NX_PTP_CLIENT_STATE_LISTENING) in _nx_ptp_msg_parse_hdr()
320 client_ptr -> nx_ptp_client_master_addr = src_addr; in _nx_ptp_msg_parse_hdr()
456 NX_PTP_CLIENT *client_ptr = (NX_PTP_CLIENT *)ptp_instance; in _nx_ptp_client_soft_clock_adjust() local
471 client_ptr -> nx_ptp_client_soft_clock.nanosecond += offset_ns; in _nx_ptp_client_soft_clock_adjust()
472 if (client_ptr -> nx_ptp_client_soft_clock.nanosecond >= NX_PTP_NANOSECONDS_PER_SEC) in _nx_ptp_client_soft_clock_adjust()
[all …]
Dnxd_ptp_client.h179 typedef UINT (*NX_PTP_CLIENT_EVENT_CALLBACK)(struct NX_PTP_CLIENT_STRUCT *client_ptr, UINT event,
189 typedef UINT (*NX_PTP_CLIENT_CLOCK_CALLBACK)(struct NX_PTP_CLIENT_STRUCT *client_ptr, UINT operatio…
425 UINT _nx_ptp_client_create(NX_PTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT interface_index,
428 UINT _nx_ptp_client_delete(NX_PTP_CLIENT *client_ptr);
429 UINT _nx_ptp_client_start(NX_PTP_CLIENT *client_ptr, UCHAR *client_port_identity_ptr, UINT client_p…
432 UINT _nx_ptp_client_stop(NX_PTP_CLIENT *client_ptr);
433 UINT _nx_ptp_client_time_get(NX_PTP_CLIENT *client_ptr, NX_PTP_TIME *time_ptr);
434 UINT _nx_ptp_client_time_set(NX_PTP_CLIENT *client_ptr, NX_PTP_TIME *time_ptr);
442 VOID _nx_ptp_client_packet_timestamp_notify(NX_PTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX_PT…
443 UINT _nx_ptp_client_soft_clock_callback(NX_PTP_CLIENT *client_ptr, UINT operation,
[all …]
/NetX-Duo-v6.3.0/addons/sntp/
Dnxd_sntp_client.c134 UINT _nxe_sntp_client_create(NX_SNTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT iface_index, NX_PACKE… in _nxe_sntp_client_create() argument
135 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator), in _nxe_sntp_client_create() argument
136 … UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code), in _nxe_sntp_client_create() argument
137 … VOID (random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand)) in _nxe_sntp_client_create() argument
144 …if ((ip_ptr == NX_NULL) || (ip_ptr -> nx_ip_id != NX_IP_ID) || (client_ptr == NX_NULL) || (packet_… in _nxe_sntp_client_create()
152 if ((client_ptr == NX_NULL) || (client_ptr -> nx_sntp_client_id == NXD_SNTP_ID)) in _nxe_sntp_client_create()
167 status = _nx_sntp_client_create(client_ptr, ip_ptr, iface_index, packet_pool_ptr, in _nxe_sntp_client_create()
232 UINT _nx_sntp_client_create(NX_SNTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT iface_index, NX_PACKET… in _nx_sntp_client_create() argument
233 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator), in _nx_sntp_client_create() argument
234 … UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code), in _nx_sntp_client_create() argument
[all …]
Dnxd_sntp_client.h593 … (*apply_custom_sanity_checks)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, NX_SNTP_TIME_ME…
595 … (*leap_second_handler)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, UINT indicator)…
597 … (*kiss_of_death_handler)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, UINT code);
599 … (*random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand);
671 UINT nx_sntp_client_create(NX_SNTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT iface_index, NX_PACKET…
672 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator),
673 UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code),
674 … VOID (random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand));
675 UINT nx_sntp_client_delete (NX_SNTP_CLIENT *client_ptr);
676 UINT nx_sntp_client_get_local_time(NX_SNTP_CLIENT *client_ptr, ULONG *seconds, ULONG *fraction, …
[all …]
/NetX-Duo-v6.3.0/addons/web/
Dnx_web_http_client.c143 UINT _nxe_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr,… in _nxe_web_http_client_create() argument
152 … (client_ptr == NX_NULL) || (client_ptr -> nx_web_http_client_id == NX_WEB_HTTP_CLIENT_ID) || in _nxe_web_http_client_create()
164 status = _nx_web_http_client_create(client_ptr, client_name, ip_ptr, pool_ptr, window_size); in _nxe_web_http_client_create()
217 UINT _nx_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, … in _nx_web_http_client_create() argument
224 memset((void *) client_ptr, 0, sizeof(NX_WEB_HTTP_CLIENT)); in _nx_web_http_client_create()
227 status = nx_tcp_socket_create(ip_ptr, &(client_ptr -> nx_web_http_client_socket), client_name, in _nx_web_http_client_create()
240 client_ptr -> nx_web_http_client_name = client_name; in _nx_web_http_client_create()
243 client_ptr -> nx_web_http_client_ip_ptr = ip_ptr; in _nx_web_http_client_create()
246 client_ptr -> nx_web_http_client_packet_pool_ptr = pool_ptr; in _nx_web_http_client_create()
249 client_ptr -> nx_web_http_client_state = NX_WEB_HTTP_CLIENT_STATE_READY; in _nx_web_http_client_create()
[all …]
Dnx_web_http_client.h144 …VOID (*nx_web_http_client_response_callback)(struct NX_WEB_HTTP_CLIENT_STRUCT *client_ptr,
251 UINT _nx_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip…
253 UINT _nxe_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *i…
257 UINT nx_web_http_client_delete(NX_WEB_HTTP_CLIENT *client_ptr);
258 UINT nx_web_http_client_response_body_get(NX_WEB_HTTP_CLIENT *client_ptr, NX_PACKET **packet…
259 UINT nx_web_http_client_put_packet(NX_WEB_HTTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, UL…
260 UINT nx_web_http_client_get_start(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UI…
261 UINT nx_web_http_client_get_start_extended(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *serv…
263 UINT nx_web_http_client_put_start(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UI…
264 UINT nx_web_http_client_put_start_extended(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *serv…
[all …]
/NetX-Duo-v6.3.0/addons/http/
Dnxd_http_client.c95 UINT _nxe_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, NX_PACK… in _nxe_http_client_create() argument
104 (client_ptr == NX_NULL) || (client_ptr -> nx_http_client_id == NXD_HTTP_CLIENT_ID) || in _nxe_http_client_create()
116 status = _nx_http_client_create(client_ptr, client_name, ip_ptr, pool_ptr, window_size); in _nxe_http_client_create()
169 UINT _nx_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, NX_PACKE… in _nx_http_client_create() argument
176 memset((void *) client_ptr, 0, sizeof(NX_HTTP_CLIENT)); in _nx_http_client_create()
179 status = nx_tcp_socket_create(ip_ptr, &(client_ptr -> nx_http_client_socket), client_name, in _nx_http_client_create()
192 client_ptr -> nx_http_client_name = client_name; in _nx_http_client_create()
195 client_ptr -> nx_http_client_ip_ptr = ip_ptr; in _nx_http_client_create()
198 client_ptr -> nx_http_client_packet_pool_ptr = pool_ptr; in _nx_http_client_create()
201 client_ptr -> nx_http_client_state = NX_HTTP_CLIENT_STATE_READY; in _nx_http_client_create()
[all …]
Dnxd_http_client.h235 UINT _nx_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, NX…
237 UINT _nxe_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, N…
239 UINT nx_http_client_delete(NX_HTTP_CLIENT *client_ptr);
240 UINT nx_http_client_get_start(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *resource, …
241 UINT nx_http_client_get_start_extended(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *r…
242 UINT nx_http_client_get_packet(NX_HTTP_CLIENT *client_ptr, NX_PACKET **packet_ptr, ULONG wai…
243 UINT nx_http_client_put_start(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *resource, …
244 UINT nx_http_client_put_start_extended(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *r…
245 UINT nx_http_client_put_packet(NX_HTTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, ULONG wait…
246 UINT nx_http_client_set_connect_port(NX_HTTP_CLIENT *client_ptr, UINT port);
[all …]
/NetX-Duo-v6.3.0/samples/
Ddemo_rtsp_over_rtp.c170 SAMPLE_CLIENT *client_ptr; in demo_timer_entry() local
173 client_ptr = &sample_client_multicast; in demo_timer_entry()
177 client_ptr = &sample_client[i]; in demo_timer_entry()
180 if (client_ptr -> rtp_session_video_client_count) in demo_timer_entry()
182 client_ptr -> video_play_time_ms += DEMO_PLAY_TIMER_INTERVAL; in demo_timer_entry()
183 if (client_ptr -> video_play_time_ms >= DEMO_RTP_VIDEO_PLAY_INTERVAL) in demo_timer_entry()
190 if (client_ptr -> rtp_session_audio_client_count) in demo_timer_entry()
192 client_ptr -> audio_play_time_ms += DEMO_PLAY_TIMER_INTERVAL; in demo_timer_entry()
193 if (client_ptr -> audio_play_time_ms >= DEMO_RTP_AUDIO_PLAY_INTERVAL) in demo_timer_entry()
220 SAMPLE_CLIENT *client_ptr; in sample_entry() local
[all …]
Ddemo_mqtt_client.c78 static VOID my_disconnect_func(NXD_MQTT_CLIENT *client_ptr) in my_disconnect_func() argument
80 NX_PARAMETER_NOT_USED(client_ptr); in my_disconnect_func()
85 static VOID my_notify_func(NXD_MQTT_CLIENT* client_ptr, UINT number_of_messages) in my_notify_func() argument
87 NX_PARAMETER_NOT_USED(client_ptr); in my_notify_func()
Ddemo_netxduo_sntp_client.c32 UINT leap_second_handler(NX_SNTP_CLIENT *client_ptr, UINT leap_indicator);
33 UINT kiss_of_death_handler(NX_SNTP_CLIENT *client_ptr, UINT KOD_code);
448 UINT leap_second_handler(NX_SNTP_CLIENT *client_ptr, UINT leap_indicator) in leap_second_handler() argument
450 NX_PARAMETER_NOT_USED(client_ptr); in leap_second_handler()
467 UINT kiss_of_death_handler(NX_SNTP_CLIENT *client_ptr, UINT KOD_code) in kiss_of_death_handler() argument
473 NX_PARAMETER_NOT_USED(client_ptr); in kiss_of_death_handler()
/NetX-Duo-v6.3.0/addons/pop3/
Dnxd_pop3_client.c118 UINT _nxe_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nxe_pop3_client_create() argument
128 …if ((ip_ptr == NX_NULL) || (client_ptr == NX_NULL) || (packet_pool_ptr == NX_NULL) || (client_name… in _nxe_pop3_client_create()
143 status = _nx_pop3_client_create(client_ptr, in _nxe_pop3_client_create()
152 NX_PARAMETER_NOT_USED(client_ptr); in _nxe_pop3_client_create()
215 UINT _nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nx_pop3_client_create() argument
227 status = _nxd_pop3_client_create(client_ptr, in _nx_pop3_client_create()
235 NX_PARAMETER_NOT_USED(client_ptr); in _nx_pop3_client_create()
300 UINT _nxde_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nxde_pop3_client_create() argument
309 …if ((ip_ptr == NX_NULL) || (client_ptr == NX_NULL) || (packet_pool_ptr == NX_NULL) || (server_ip_a… in _nxde_pop3_client_create()
324 status = _nxd_pop3_client_create(client_ptr, in _nxde_pop3_client_create()
[all …]
Dnxd_pop3_client.h224 UINT nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, …
225 UINT nxd_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr,…
226 UINT nx_pop3_client_mail_items_get(NX_POP3_CLIENT *client_ptr, UINT *number_mail_items, ULONG *m…
227 UINT nx_pop3_client_mail_item_size_get(NX_POP3_CLIENT *client_ptr, UINT mail_item, ULONG *size);
228 UINT nx_pop3_client_mail_item_message_get(NX_POP3_CLIENT *client_ptr, NX_PACKET **recv_packet_pt…
229 UINT nx_pop3_client_mail_item_get(NX_POP3_CLIENT *client_ptr, UINT mail_item, ULONG *item_size);
230 UINT nx_pop3_client_mail_item_delete(NX_POP3_CLIENT *client_ptr, UINT mail_index);
231 UINT nx_pop3_client_quit(NX_POP3_CLIENT *client_ptr);
232 UINT nx_pop3_client_delete(NX_POP3_CLIENT *client_ptr);
240 UINT _nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr,…
[all …]
/NetX-Duo-v6.3.0/addons/azure_iot/
Dnx_azure_iot.c35 extern UINT _nxd_mqtt_client_packet_allocate(NXD_MQTT_CLIENT *client_ptr, NX_PACKET **packet_ptr, U…
36 extern UINT _nxd_mqtt_client_publish_packet_send(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr,
170 NX_AZURE_IOT_RESOURCE *nx_azure_iot_resource_search(NXD_MQTT_CLIENT *client_ptr) in nx_azure_iot_resource_search() argument
175 if ((_nx_azure_iot_created_ptr == NX_NULL) || (client_ptr == NX_NULL)) in nx_azure_iot_resource_search()
185 if (&(resource_ptr -> resource_mqtt) == client_ptr) in nx_azure_iot_resource_search()
359 UINT nx_azure_iot_publish_packet_get(NX_AZURE_IOT *nx_azure_iot_ptr, NXD_MQTT_CLIENT *client_ptr, in nx_azure_iot_publish_packet_get() argument
366 status = _nxd_mqtt_client_packet_allocate(client_ptr, packet_pptr, wait_option); in nx_azure_iot_publish_packet_get()
379 UINT nx_azure_iot_publish_mqtt_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, in nx_azure_iot_publish_mqtt_packet() argument
398 status = _nxd_mqtt_client_publish_packet_send(client_ptr, packet_ptr, in nx_azure_iot_publish_mqtt_packet()
409 UINT nx_azure_iot_mqtt_packet_id_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *packet_id) in nx_azure_iot_mqtt_packet_id_get() argument
[all …]
Dnx_azure_iot.h311 NX_AZURE_IOT_RESOURCE *nx_azure_iot_resource_search(NXD_MQTT_CLIENT *client_ptr);
312 UINT nx_azure_iot_publish_mqtt_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr,
314 UINT nx_azure_iot_publish_packet_get(NX_AZURE_IOT *nx_azure_iot_ptr, NXD_MQTT_CLIENT *client_ptr,
316 UINT nx_azure_iot_mqtt_packet_id_get(NXD_MQTT_CLIENT *client_ptr, UCHAR *packet_id);
318 UINT nx_azure_iot_mqtt_tls_setup(NXD_MQTT_CLIENT *client_ptr, NX_SECURE_TLS_SESSION *tls_session,
Dnx_azure_iot_provisioning_client.c48 static VOID nx_azure_iot_provisioning_client_mqtt_receive_callback(NXD_MQTT_CLIENT *client_ptr,
50 static VOID nx_azure_iot_provisioning_client_mqtt_disconnect_notify(NXD_MQTT_CLIENT *client_ptr);
104 static VOID nx_azure_iot_provisioning_client_mqtt_disconnect_notify(NXD_MQTT_CLIENT *client_ptr) in nx_azure_iot_provisioning_client_mqtt_disconnect_notify() argument
107 NX_AZURE_IOT_RESOURCE *resource = nx_azure_iot_resource_search(client_ptr); in nx_azure_iot_provisioning_client_mqtt_disconnect_notify()
211 static VOID nx_azure_iot_provisioning_client_mqtt_receive_callback(NXD_MQTT_CLIENT *client_ptr, in nx_azure_iot_provisioning_client_mqtt_receive_callback() argument
214 NX_AZURE_IOT_RESOURCE *resource = nx_azure_iot_resource_search(client_ptr); in nx_azure_iot_provisioning_client_mqtt_receive_callback()
231 for (packet_ptr = client_ptr -> message_receive_queue_head; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
259 client_ptr -> message_receive_queue_head = NX_NULL; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
260 client_ptr -> message_receive_queue_tail = NX_NULL; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
261 client_ptr -> message_receive_queue_depth = 0; in nx_azure_iot_provisioning_client_mqtt_receive_callback()
[all …]

12