Home
last modified time | relevance | path

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

123456

/NetX-Duo-v6.4.1/addons/mqtt/
Dnxd_mqtt_client.c50 static UINT _nxd_mqtt_client_create_internal(NXD_MQTT_CLIENT *client_ptr, CHAR *client_name,
54 static UINT _nxd_mqtt_packet_send(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, UINT wait_opt…
55 static UINT _nxd_mqtt_packet_receive(NXD_MQTT_CLIENT *client_ptr, NX_PACKET **packet_ptr, UINT wait…
56 static UINT _nxd_mqtt_copy_transmit_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX_P…
58 static VOID _nxd_mqtt_release_transmit_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, N…
59 static VOID _nxd_mqtt_release_receive_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX…
60 static UINT _nxd_mqtt_client_retransmit_message(NXD_MQTT_CLIENT *client_ptr, ULONG wait_option);
61 static UINT _nxd_mqtt_client_connect_packet_send(NXD_MQTT_CLIENT *client_ptr, ULONG wait_option);
112 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
138 client_ptr -> nxd_mqtt_client_packet_pool_ptr, wait_option); in _nxd_mqtt_client_set_fixed_header()
[all …]
Dnxd_mqtt_client.h370 … (*nxd_mqtt_client_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT number_of_…
371 … (*nxd_mqtt_connect_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT status, VO…
373 …D (*nxd_mqtt_disconnect_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr);
374 … (*nxd_mqtt_packet_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, NX_PACKET *pack…
376 … (*nxd_mqtt_ack_receive_notify)(struct NXD_MQTT_CLIENT_STRUCT *client_ptr, UINT type, USHO…
447 UINT nxd_mqtt_client_create(NXD_MQTT_CLIENT *client_ptr, CHAR *client_name, CHAR *client_id, UINT c…
451 UINT nxd_mqtt_client_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UINT server_port,
454 UINT nxd_mqtt_client_login_set(NXD_MQTT_CLIENT *client_ptr,
457 UINT nxd_mqtt_client_will_message_set(NXD_MQTT_CLIENT *client_ptr,
461 UINT nxd_mqtt_client_secure_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UINT serve…
[all …]
/NetX-Duo-v6.4.1/addons/websocket/
Dnx_websocket_client.c94 UINT _nxe_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_p… in _nxe_websocket_client_create() argument
101 … (client_ptr == NX_NULL) || (client_ptr -> nx_websocket_client_id == NX_WEBSOCKET_CLIENT_ID) || in _nxe_websocket_client_create()
108 status = _nx_websocket_client_create(client_ptr, client_name, ip_ptr, pool_ptr); in _nxe_websocket_client_create()
154 UINT _nx_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_pt… in _nx_websocket_client_create() argument
160 memset((void *)client_ptr, 0, sizeof(NX_WEBSOCKET_CLIENT)); in _nx_websocket_client_create()
163 …status = tx_mutex_create(&client_ptr -> nx_websocket_client_mutex, (CHAR *)client_name, TX_NO_INHE… in _nx_websocket_client_create()
170 client_ptr -> nx_websocket_client_name = client_name; in _nx_websocket_client_create()
173 client_ptr -> nx_websocket_client_ip_ptr = ip_ptr; in _nx_websocket_client_create()
176 client_ptr -> nx_websocket_client_packet_pool_ptr = pool_ptr; in _nx_websocket_client_create()
179 client_ptr -> nx_websocket_client_id = NX_WEBSOCKET_CLIENT_ID; in _nx_websocket_client_create()
[all …]
Dnx_websocket_client.h261 UINT nx_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_ptr…
262 UINT nx_websocket_client_delete(NX_WEBSOCKET_CLIENT *client_ptr);
263 UINT nx_websocket_client_packet_allocate(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET **packet_ptr, …
264 UINT nx_websocket_client_connect(NX_WEBSOCKET_CLIENT *client_ptr, NX_TCP_SOCKET *socket_ptr,
269 UINT nx_websocket_client_secure_connect(NX_WEBSOCKET_CLIENT *client_ptr, NX_SECURE_TLS_SESSION *tl…
274 UINT nx_websocket_client_disconnect(NX_WEBSOCKET_CLIENT *client_ptr, UINT wait_option);
275 UINT nx_websocket_client_send(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET *packet_ptr, UINT code, U…
276 UINT nx_websocket_client_receive(NX_WEBSOCKET_CLIENT *client_ptr, NX_PACKET **packet_ptr, UINT *co…
277 UINT nx_websocket_client_connection_status_callback_set(NX_WEBSOCKET_CLIENT *client_ptr, VOID *con…
284 UINT _nxe_websocket_client_create(NX_WEBSOCKET_CLIENT *client_ptr, UCHAR *client_name, NX_IP *ip_p…
[all …]
/NetX-Duo-v6.4.1/addons/ptp/
Dnxd_ptp_client.c335 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
367 (NX_PTP_MSG_DOMAIN(ptr) != client_ptr -> nx_ptp_client_domain)) in _nx_ptp_msg_parse_hdr()
380 (interface_index != client_ptr -> nx_ptp_client_interface_index) in _nx_ptp_msg_parse_hdr()
383 !client_ptr -> nx_ptp_client_ipv4_group_joined) || in _nx_ptp_msg_parse_hdr()
385 !client_ptr -> nx_ptp_client_ipv6_group_joined) in _nx_ptp_msg_parse_hdr()
395 if (client_ptr -> nx_ptp_client_state == NX_PTP_CLIENT_STATE_LISTENING) in _nx_ptp_msg_parse_hdr()
397 client_ptr -> nx_ptp_client_master_addr = src_addr; in _nx_ptp_msg_parse_hdr()
630 NX_PTP_CLIENT *client_ptr = (NX_PTP_CLIENT *)ptp_instance; in _nx_ptp_client_soft_clock_adjust() local
645 client_ptr -> nx_ptp_client_soft_clock.nanosecond += offset_ns; in _nx_ptp_client_soft_clock_adjust()
646 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.h324 typedef UINT (*NX_PTP_CLIENT_EVENT_CALLBACK)(struct NX_PTP_CLIENT_STRUCT *client_ptr, UINT event,
334 typedef UINT (*NX_PTP_CLIENT_CLOCK_CALLBACK)(struct NX_PTP_CLIENT_STRUCT *client_ptr, UINT operatio…
707 UINT _nx_ptp_client_create(NX_PTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT interface_index,
710 UINT _nx_ptp_client_delete(NX_PTP_CLIENT *client_ptr);
711 UINT _nx_ptp_client_start(NX_PTP_CLIENT *client_ptr, UCHAR *client_port_identity_ptr, UINT client_p…
714 UINT _nx_ptp_client_stop(NX_PTP_CLIENT *client_ptr);
715 UINT _nx_ptp_client_time_get(NX_PTP_CLIENT *client_ptr, NX_PTP_TIME *time_ptr);
716 UINT _nx_ptp_client_time_set(NX_PTP_CLIENT *client_ptr, NX_PTP_TIME *time_ptr);
725 VOID _nx_ptp_client_packet_timestamp_notify(NX_PTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, NX_PT…
726 UINT _nx_ptp_client_soft_clock_callback(NX_PTP_CLIENT *client_ptr, UINT operation,
[all …]
/NetX-Duo-v6.4.1/addons/smtp/
Dnxd_smtp_client.c56 static UINT _nx_smtp_cmd_idle(NX_SMTP_CLIENT *client_ptr);
57 static UINT _nx_smtp_rsp_idle(NX_SMTP_CLIENT *client_ptr);
58 static UINT _nx_smtp_cmd_greeting(NX_SMTP_CLIENT *client_ptr);
59 static UINT _nx_smtp_rsp_greeting(NX_SMTP_CLIENT *client_ptr);
60 static UINT _nx_smtp_cmd_ehlo(NX_SMTP_CLIENT *client_ptr);
61 static UINT _nx_smtp_rsp_ehlo(NX_SMTP_CLIENT *client_ptr);
62 static UINT _nx_smtp_cmd_helo(NX_SMTP_CLIENT *client_ptr);
63 static UINT _nx_smtp_rsp_helo(NX_SMTP_CLIENT *client_ptr);
64 static UINT _nx_smtp_cmd_mail(NX_SMTP_CLIENT *client_ptr);
65 static UINT _nx_smtp_rsp_mail(NX_SMTP_CLIENT *client_ptr);
[all …]
Dnxd_smtp_client.h358 UINT (*cmd) (NX_SMTP_CLIENT *client_ptr);
359 UINT (*rsp) (NX_SMTP_CLIENT *client_ptr);
394 UINT nxd_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pa…
399 UINT nx_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
400 UINT nx_smtp_mail_send(NX_SMTP_CLIENT *client_ptr, CHAR *recipient_address, UINT priority,
409 UINT _nxd_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pac…
413 UINT _nxde_smtp_client_create(NX_SMTP_CLIENT *client_ptr, NX_IP *ip_ptr, NX_PACKET_POOL *client_pa…
418 UINT _nx_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
419 UINT _nxe_smtp_client_delete (NX_SMTP_CLIENT *client_ptr);
421 UINT _nx_smtp_mail_send(NX_SMTP_CLIENT *client_ptr, CHAR *recipient_address, UINT priority,
[all …]
/NetX-Duo-v6.4.1/addons/telnet/
Dnxd_telnet_client.c86 UINT _nxde_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, NXD_ADDRESS *server_ip_address, in _nxde_telnet_client_connect() argument
94 if ((client_ptr == NX_NULL) || (!server_ip_address)) in _nxde_telnet_client_connect()
100 if (client_ptr -> nx_telnet_client_id != NX_TELNET_CLIENT_ID) in _nxde_telnet_client_connect()
109 status = _nxd_telnet_client_connect(client_ptr, server_ip_address, server_port, wait_option); in _nxde_telnet_client_connect()
161 UINT _nxd_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, NXD_ADDRESS *server_ip_address, in _nxd_telnet_client_connect() argument
170 if (client_ptr -> nx_telnet_client_socket.nx_tcp_socket_state != NX_TCP_CLOSED) in _nxd_telnet_client_connect()
178 …status = nx_tcp_client_socket_bind(&(client_ptr -> nx_telnet_client_socket), NX_ANY_PORT, wait_op… in _nxd_telnet_client_connect()
190 status = nxd_tcp_client_socket_connect(&(client_ptr -> nx_telnet_client_socket), in _nxd_telnet_client_connect()
198 nx_tcp_client_socket_unbind(&(client_ptr -> nx_telnet_client_socket)); in _nxd_telnet_client_connect()
253 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.h154 UINT nx_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT server…
155 UINT nx_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, ULO…
156 UINT nx_telnet_client_delete(NX_TELNET_CLIENT *client_ptr);
157 UINT nx_telnet_client_disconnect(NX_TELNET_CLIENT *client_ptr, ULONG wait_option);
158 UINT nx_telnet_client_packet_receive(NX_TELNET_CLIENT *client_ptr, NX_PACKET **packet_ptr, ULONG…
159 UINT nx_telnet_client_packet_send(NX_TELNET_CLIENT *client_ptr, NX_PACKET *packet_ptr, ULONG wai…
168 UINT _nxe_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT serv…
169 UINT _nx_telnet_client_connect(NX_TELNET_CLIENT *client_ptr, ULONG server_ip_address, UINT serve…
170 UINT _nxe_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, U…
171 UINT _nx_telnet_client_create(NX_TELNET_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, UL…
[all …]
/NetX-Duo-v6.4.1/addons/sntp/
Dnxd_sntp_client.c133 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
134 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator), in _nxe_sntp_client_create() argument
135 … UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code), in _nxe_sntp_client_create() argument
136 … VOID (random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand)) in _nxe_sntp_client_create() argument
143 …if ((ip_ptr == NX_NULL) || (ip_ptr -> nx_ip_id != NX_IP_ID) || (client_ptr == NX_NULL) || (packet_… in _nxe_sntp_client_create()
151 if ((client_ptr == NX_NULL) || (client_ptr -> nx_sntp_client_id == NXD_SNTP_ID)) in _nxe_sntp_client_create()
166 status = _nx_sntp_client_create(client_ptr, ip_ptr, iface_index, packet_pool_ptr, in _nxe_sntp_client_create()
231 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
232 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator), in _nx_sntp_client_create() argument
233 … UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code), in _nx_sntp_client_create() argument
[all …]
Dnxd_sntp_client.h592 … (*apply_custom_sanity_checks)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, NX_SNTP_TIME_ME…
594 … (*leap_second_handler)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, UINT indicator)…
596 … (*kiss_of_death_handler)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, UINT code);
598 … (*random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand);
670 UINT nx_sntp_client_create(NX_SNTP_CLIENT *client_ptr, NX_IP *ip_ptr, UINT iface_index, NX_PACKET…
671 … UINT (*leap_second_handler)(NX_SNTP_CLIENT *client_ptr, UINT indicator),
672 UINT (*kiss_of_death_handler)(NX_SNTP_CLIENT *client_ptr, UINT code),
673 … VOID (random_number_generator)(struct NX_SNTP_CLIENT_STRUCT *client_ptr, ULONG *rand));
674 UINT nx_sntp_client_delete (NX_SNTP_CLIENT *client_ptr);
675 UINT nx_sntp_client_get_local_time(NX_SNTP_CLIENT *client_ptr, ULONG *seconds, ULONG *fraction, …
[all …]
/NetX-Duo-v6.4.1/addons/web/
Dnx_web_http_client.c142 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
151 … (client_ptr == NX_NULL) || (client_ptr -> nx_web_http_client_id == NX_WEB_HTTP_CLIENT_ID) || in _nxe_web_http_client_create()
163 status = _nx_web_http_client_create(client_ptr, client_name, ip_ptr, pool_ptr, window_size); in _nxe_web_http_client_create()
216 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
223 memset((void *) client_ptr, 0, sizeof(NX_WEB_HTTP_CLIENT)); in _nx_web_http_client_create()
226 status = nx_tcp_socket_create(ip_ptr, &(client_ptr -> nx_web_http_client_socket), client_name, in _nx_web_http_client_create()
239 client_ptr -> nx_web_http_client_name = client_name; in _nx_web_http_client_create()
242 client_ptr -> nx_web_http_client_ip_ptr = ip_ptr; in _nx_web_http_client_create()
245 client_ptr -> nx_web_http_client_packet_pool_ptr = pool_ptr; in _nx_web_http_client_create()
248 client_ptr -> nx_web_http_client_state = NX_WEB_HTTP_CLIENT_STATE_READY; in _nx_web_http_client_create()
[all …]
Dnx_web_http_client.h143 …VOID (*nx_web_http_client_response_callback)(struct NX_WEB_HTTP_CLIENT_STRUCT *client_ptr,
250 UINT _nx_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip…
252 UINT _nxe_web_http_client_create(NX_WEB_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *i…
256 UINT nx_web_http_client_delete(NX_WEB_HTTP_CLIENT *client_ptr);
257 UINT nx_web_http_client_response_body_get(NX_WEB_HTTP_CLIENT *client_ptr, NX_PACKET **packet…
258 UINT nx_web_http_client_put_packet(NX_WEB_HTTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, UL…
259 UINT nx_web_http_client_get_start(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UI…
260 UINT nx_web_http_client_get_start_extended(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *serv…
262 UINT nx_web_http_client_put_start(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *server_ip, UI…
263 UINT nx_web_http_client_put_start_extended(NX_WEB_HTTP_CLIENT *client_ptr, NXD_ADDRESS *serv…
[all …]
/NetX-Duo-v6.4.1/addons/http/
Dnxd_http_client.c94 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
103 (client_ptr == NX_NULL) || (client_ptr -> nx_http_client_id == NXD_HTTP_CLIENT_ID) || in _nxe_http_client_create()
115 status = _nx_http_client_create(client_ptr, client_name, ip_ptr, pool_ptr, window_size); in _nxe_http_client_create()
168 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
175 memset((void *) client_ptr, 0, sizeof(NX_HTTP_CLIENT)); in _nx_http_client_create()
178 status = nx_tcp_socket_create(ip_ptr, &(client_ptr -> nx_http_client_socket), client_name, in _nx_http_client_create()
191 client_ptr -> nx_http_client_name = client_name; in _nx_http_client_create()
194 client_ptr -> nx_http_client_ip_ptr = ip_ptr; in _nx_http_client_create()
197 client_ptr -> nx_http_client_packet_pool_ptr = pool_ptr; in _nx_http_client_create()
200 client_ptr -> nx_http_client_state = NX_HTTP_CLIENT_STATE_READY; in _nx_http_client_create()
[all …]
Dnxd_http_client.h234 UINT _nx_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, NX…
236 UINT _nxe_http_client_create(NX_HTTP_CLIENT *client_ptr, CHAR *client_name, NX_IP *ip_ptr, N…
238 UINT nx_http_client_delete(NX_HTTP_CLIENT *client_ptr);
239 UINT nx_http_client_get_start(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *resource, …
240 UINT nx_http_client_get_start_extended(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *r…
241 UINT nx_http_client_get_packet(NX_HTTP_CLIENT *client_ptr, NX_PACKET **packet_ptr, ULONG wai…
242 UINT nx_http_client_put_start(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *resource, …
243 UINT nx_http_client_put_start_extended(NX_HTTP_CLIENT *client_ptr, ULONG ip_address, CHAR *r…
244 UINT nx_http_client_put_packet(NX_HTTP_CLIENT *client_ptr, NX_PACKET *packet_ptr, ULONG wait…
245 UINT nx_http_client_set_connect_port(NX_HTTP_CLIENT *client_ptr, UINT port);
[all …]
/NetX-Duo-v6.4.1/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 …]
/NetX-Duo-v6.4.1/addons/pop3/
Dnxd_pop3_client.c117 UINT _nxe_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nxe_pop3_client_create() argument
127 …if ((ip_ptr == NX_NULL) || (client_ptr == NX_NULL) || (packet_pool_ptr == NX_NULL) || (client_name… in _nxe_pop3_client_create()
142 status = _nx_pop3_client_create(client_ptr, in _nxe_pop3_client_create()
151 NX_PARAMETER_NOT_USED(client_ptr); in _nxe_pop3_client_create()
214 UINT _nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nx_pop3_client_create() argument
226 status = _nxd_pop3_client_create(client_ptr, in _nx_pop3_client_create()
234 NX_PARAMETER_NOT_USED(client_ptr); in _nx_pop3_client_create()
299 UINT _nxde_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, in _nxde_pop3_client_create() argument
308 …if ((ip_ptr == NX_NULL) || (client_ptr == NX_NULL) || (packet_pool_ptr == NX_NULL) || (server_ip_a… in _nxde_pop3_client_create()
323 status = _nxd_pop3_client_create(client_ptr, in _nxde_pop3_client_create()
[all …]
Dnxd_pop3_client.h223 UINT nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr, …
224 UINT nxd_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr,…
225 UINT nx_pop3_client_mail_items_get(NX_POP3_CLIENT *client_ptr, UINT *number_mail_items, ULONG *m…
226 UINT nx_pop3_client_mail_item_size_get(NX_POP3_CLIENT *client_ptr, UINT mail_item, ULONG *size);
227 UINT nx_pop3_client_mail_item_message_get(NX_POP3_CLIENT *client_ptr, NX_PACKET **recv_packet_pt…
228 UINT nx_pop3_client_mail_item_get(NX_POP3_CLIENT *client_ptr, UINT mail_item, ULONG *item_size);
229 UINT nx_pop3_client_mail_item_delete(NX_POP3_CLIENT *client_ptr, UINT mail_index);
230 UINT nx_pop3_client_quit(NX_POP3_CLIENT *client_ptr);
231 UINT nx_pop3_client_delete(NX_POP3_CLIENT *client_ptr);
239 UINT _nx_pop3_client_create(NX_POP3_CLIENT *client_ptr, UINT APOP_authentication, NX_IP *ip_ptr,…
[all …]
/NetX-Duo-v6.4.1/test/regression/rtsp_test/
Dnetx_rtsp_api_test.c83 NX_RTSP_CLIENT *client_ptr; in test_entry() local
132 client_ptr = &(rtsp_0.nx_rtsp_server_client_list[0]); in test_entry()
133 client_ptr -> nx_rtsp_client_server_ptr = &rtsp_0; in test_entry()
134 client_ptr -> nx_rtsp_client_request_ptr = &test_request; in test_entry()
135 client_ptr -> nx_rtsp_client_response_packet = &test_packet; in test_entry()
141 status = nx_rtsp_server_sdp_set(client_ptr, NX_NULL, sizeof(test_sdp) - 1); in test_entry()
143 status = nx_rtsp_server_sdp_set(client_ptr, test_sdp, 0); in test_entry()
145 client_ptr -> nx_rtsp_client_server_ptr = NX_NULL; in test_entry()
146 status = nx_rtsp_server_sdp_set(client_ptr, test_sdp, sizeof(test_sdp) - 1); in test_entry()
148 client_ptr -> nx_rtsp_client_server_ptr = &rtsp_0; in test_entry()
[all …]
/NetX-Duo-v6.4.1/test/regression/mqtt_test/
Dnetx_mqtt_branch_test.c71 static NXD_MQTT_CLIENT *client_ptr; variable
159 client_ptr = (NXD_MQTT_CLIENT*)pointer; in test_application_define()
176 static UINT client_tls_setup(NXD_MQTT_CLIENT* client_ptr, NX_SECURE_TLS_SESSION* tls_session, in client_tls_setup() argument
283 …status = nxd_mqtt_client_create(client_ptr, "my client", CLIENT_ID, strlen(CLIENT_ID), &ip_0, &poo… in ntest_0_entry()
289 client_ptr -> nxd_mqtt_client_state = NXD_MQTT_CLIENT_STATE_CONNECTED; in ntest_0_entry()
301 client_ptr -> nxd_mqtt_client_mutex_ptr -> tx_mutex_id = 0; in ntest_0_entry()
302 status = nxd_mqtt_client_login_set(client_ptr, "test_user", 10, "test_pass", 10); in ntest_0_entry()
305 client_ptr -> nxd_mqtt_client_mutex_ptr->tx_mutex_id = TX_MUTEX_ID; in ntest_0_entry()
308 client_ptr -> nxd_mqtt_client_mutex_ptr -> tx_mutex_id = 0; in ntest_0_entry()
309 status = nxd_mqtt_client_subscribe(client_ptr, "topic", 6, 0); in ntest_0_entry()
[all …]
Dnetx_mqtt_not_connected_test.c31 static NXD_MQTT_CLIENT *client_ptr; variable
92 client_ptr = (NXD_MQTT_CLIENT*)pointer; in test_application_define()
124 …status = nxd_mqtt_client_create(client_ptr, "my client", CLIENT_ID, strlen(CLIENT_ID), &ip_0, &poo… in ntest_0_entry()
131 …status = nxd_mqtt_client_publish(client_ptr, TOPIC, strlen(TOPIC), MESSAGE, strlen(MESSAGE), 0, 0,… in ntest_0_entry()
135 status = nxd_mqtt_client_subscribe(client_ptr, TOPIC, strlen(TOPIC), 0); in ntest_0_entry()
140 status = nxd_mqtt_client_unsubscribe(client_ptr, TOPIC, strlen(TOPIC)); in ntest_0_entry()
144 nxd_mqtt_client_delete(client_ptr); in ntest_0_entry()
/NetX-Duo-v6.4.1/test/regression/azure_iot/
Duser_agent_string_unit_test.c241 UINT __wrap__nxde_mqtt_client_secure_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, U… in __wrap__nxde_mqtt_client_secure_connect() argument
242 … UINT (*tls_setup)(NXD_MQTT_CLIENT *client_ptr, NX_SECURE_TLS_SESSION *, in __wrap__nxde_mqtt_client_secure_connect() argument
248 client_ptr -> nxd_mqtt_client_state = NXD_MQTT_CLIENT_STATE_CONNECTED; in __wrap__nxde_mqtt_client_secure_connect()
249 client_ptr -> nxd_mqtt_client_packet_identifier = 1; in __wrap__nxde_mqtt_client_secure_connect()
250 client_ptr -> nxd_mqtt_tls_session.nx_secure_tls_id = NX_SECURE_TLS_ID; in __wrap__nxde_mqtt_client_secure_connect()
251 client_ptr -> nxd_mqtt_tls_session.nx_secure_tls_local_session_active = NX_FALSE; in __wrap__nxde_mqtt_client_secure_connect()
252 …client_ptr -> nxd_mqtt_tls_session.nx_secure_tls_tcp_socket = &client_ptr -> nxd_mqtt_client_socke… in __wrap__nxde_mqtt_client_secure_connect()
253 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_connect_ip.nxd_ip_version = NX_IP_VERSION_V4; in __wrap__nxde_mqtt_client_secure_connect()
254 client_ptr -> nxd_mqtt_client_socket.nx_tcp_socket_state = NX_TCP_ESTABLISHED; in __wrap__nxde_mqtt_client_secure_connect()
258 UINT __wrap__nxde_mqtt_client_disconnect(NXD_MQTT_CLIENT *client_ptr) in __wrap__nxde_mqtt_client_disconnect() argument
[all …]
Ddirect_method_unit_test.c65 extern UINT _nxd_mqtt_client_append_message(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, CHA…
67 extern UINT _nxd_mqtt_client_set_fixed_header(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr,
77 static VOID (*test_receive_notify)(NXD_MQTT_CLIENT *client_ptr, UINT message_count) = NX_NULL;
91 UINT __wrap__nxde_mqtt_client_receive_notify_set(NXD_MQTT_CLIENT *client_ptr, in __wrap__nxde_mqtt_client_receive_notify_set() argument
92 … VOID (*receive_notify)(NXD_MQTT_CLIENT *client_ptr, UINT message_count)) in __wrap__nxde_mqtt_client_receive_notify_set() argument
99 UINT __wrap__nxde_mqtt_client_subscribe(NXD_MQTT_CLIENT *client_ptr, UINT op, in __wrap__nxde_mqtt_client_subscribe() argument
108 UINT __wrap__nxde_mqtt_client_unsubscribe(NXD_MQTT_CLIENT *client_ptr, CHAR *topic_name, in __wrap__nxde_mqtt_client_unsubscribe() argument
147 UINT __wrap__nxd_mqtt_client_publish_packet_send(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, in __wrap__nxd_mqtt_client_publish_packet_send() argument
156 tx_mutex_put(client_ptr -> nxd_mqtt_client_mutex_ptr); in __wrap__nxd_mqtt_client_publish_packet_send()
175 UINT __wrap__nxde_mqtt_client_secure_connect(NXD_MQTT_CLIENT *client_ptr, NXD_ADDRESS *server_ip, U… in __wrap__nxde_mqtt_client_secure_connect() argument
[all …]
/NetX-Duo-v6.4.1/addons/azure_iot/
Dnx_azure_iot.c30 extern UINT _nxd_mqtt_client_packet_allocate(NXD_MQTT_CLIENT *client_ptr, NX_PACKET **packet_ptr, U…
31 extern UINT _nxd_mqtt_client_publish_packet_send(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr,
165 NX_AZURE_IOT_RESOURCE *nx_azure_iot_resource_search(NXD_MQTT_CLIENT *client_ptr) in nx_azure_iot_resource_search() argument
170 if ((_nx_azure_iot_created_ptr == NX_NULL) || (client_ptr == NX_NULL)) in nx_azure_iot_resource_search()
180 if (&(resource_ptr -> resource_mqtt) == client_ptr) in nx_azure_iot_resource_search()
333 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
340 status = _nxd_mqtt_client_packet_allocate(client_ptr, packet_pptr, wait_option); in nx_azure_iot_publish_packet_get()
353 UINT nx_azure_iot_publish_mqtt_packet(NXD_MQTT_CLIENT *client_ptr, NX_PACKET *packet_ptr, in nx_azure_iot_publish_mqtt_packet() argument
372 status = _nxd_mqtt_client_publish_packet_send(client_ptr, packet_ptr, in nx_azure_iot_publish_mqtt_packet()
383 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 …]

123456