Home
last modified time | relevance | path

Searched refs:pool_ptr (Results 1 – 25 of 74) sorted by relevance

123

/NetX-Duo-v6.3.0/common/src/
Dnx_packet_pool_delete.c74 UINT _nx_packet_pool_delete(NX_PACKET_POOL *pool_ptr) in _nx_packet_pool_delete() argument
89 pool_ptr -> nx_packet_pool_id = 0; in _nx_packet_pool_delete()
92 if (pool_ptr == pool_ptr -> nx_packet_pool_created_next) in _nx_packet_pool_delete()
102 (pool_ptr -> nx_packet_pool_created_next) -> nx_packet_pool_created_previous = in _nx_packet_pool_delete()
103 pool_ptr -> nx_packet_pool_created_previous; in _nx_packet_pool_delete()
104 (pool_ptr -> nx_packet_pool_created_previous) -> nx_packet_pool_created_next = in _nx_packet_pool_delete()
105 pool_ptr -> nx_packet_pool_created_next; in _nx_packet_pool_delete()
108 if (_nx_packet_pool_created_ptr == pool_ptr) in _nx_packet_pool_delete()
112 _nx_packet_pool_created_ptr = pool_ptr -> nx_packet_pool_created_next; in _nx_packet_pool_delete()
124 thread_ptr = pool_ptr -> nx_packet_pool_suspension_list; in _nx_packet_pool_delete()
[all …]
Dnx_packet_pool_create.c76 UINT _nx_packet_pool_create(NX_PACKET_POOL *pool_ptr, CHAR *name_ptr, ULONG payload_size, in _nx_packet_pool_create() argument
123 memset(pool_ptr, 0, sizeof(NX_PACKET_POOL)); in _nx_packet_pool_create()
126 pool_ptr -> nx_packet_pool_name = name_ptr; in _nx_packet_pool_create()
127 pool_ptr -> nx_packet_pool_suspension_list = TX_NULL; in _nx_packet_pool_create()
128 pool_ptr -> nx_packet_pool_suspended_count = 0; in _nx_packet_pool_create()
129 pool_ptr -> nx_packet_pool_start = (CHAR *)pool_start; in _nx_packet_pool_create()
130 pool_ptr -> nx_packet_pool_size = pool_size; in _nx_packet_pool_create()
131 pool_ptr -> nx_packet_pool_payload_size = original_payload_size; in _nx_packet_pool_create()
154 ((NX_PACKET *)packet_ptr) -> nx_packet_pool_owner = pool_ptr; in _nx_packet_pool_create()
191 pool_ptr -> nx_packet_pool_available = packets; in _nx_packet_pool_create()
[all …]
Dnx_packet_pool_info_get.c79 UINT _nx_packet_pool_info_get(NX_PACKET_POOL *pool_ptr, ULONG *total_packets, ULONG *free_packets, in _nx_packet_pool_info_get() argument
94 *total_packets = pool_ptr -> nx_packet_pool_total; in _nx_packet_pool_info_get()
102 *free_packets = pool_ptr -> nx_packet_pool_available; in _nx_packet_pool_info_get()
110 *empty_pool_requests = pool_ptr -> nx_packet_pool_empty_requests; in _nx_packet_pool_info_get()
118 *empty_pool_suspensions = pool_ptr -> nx_packet_pool_empty_suspensions; in _nx_packet_pool_info_get()
126 *invalid_packet_releases = pool_ptr -> nx_packet_pool_invalid_releases; in _nx_packet_pool_info_get()
133 …NX_TRACE_PACKET_POOL_INFO_GET, pool_ptr, pool_ptr -> nx_packet_pool_total, pool_ptr -> nx_packet_p… in _nx_packet_pool_info_get()
Dnx_packet_allocate.c76 UINT _nx_packet_allocate(NX_PACKET_POOL *pool_ptr, NX_PACKET **packet_ptr, in _nx_packet_allocate() argument
91 if (pool_ptr -> nx_packet_pool_payload_size < packet_type) in _nx_packet_allocate()
100 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_PACKET_ALLOCATE, pool_ptr, 0, packet_type, pool_ptr -> nx_packet_… in _nx_packet_allocate()
106 if (pool_ptr -> nx_packet_pool_available) in _nx_packet_allocate()
110 pool_ptr -> nx_packet_pool_available--; in _nx_packet_allocate()
113 work_ptr = pool_ptr -> nx_packet_pool_available_list; in _nx_packet_allocate()
116 pool_ptr -> nx_packet_pool_available_list = work_ptr -> nx_packet_queue_next; in _nx_packet_allocate()
177 pool_ptr -> nx_packet_pool_empty_requests++; in _nx_packet_allocate()
188 pool_ptr -> nx_packet_pool_empty_suspensions++; in _nx_packet_allocate()
199 thread_ptr -> tx_thread_suspend_control_block = (void *)pool_ptr; in _nx_packet_allocate()
[all …]
Dnx_packet_release.c78 NX_PACKET_POOL *pool_ptr; /* Pool pointer */ in _nx_packet_release() local
102 pool_ptr = packet_ptr -> nx_packet_pool_owner; in _nx_packet_release()
105 if ((pool_ptr) && (pool_ptr -> nx_packet_pool_id == NX_PACKET_POOL_ID)) in _nx_packet_release()
109 pool_ptr -> nx_packet_pool_invalid_releases++; in _nx_packet_release()
130 pool_ptr = packet_ptr -> nx_packet_pool_owner; in _nx_packet_release() local
133 thread_ptr = pool_ptr -> nx_packet_pool_suspension_list; in _nx_packet_release()
146 pool_ptr -> nx_packet_pool_suspension_list = NX_NULL; in _nx_packet_release()
154 … pool_ptr -> nx_packet_pool_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_packet_release()
164 pool_ptr -> nx_packet_pool_suspended_count--; in _nx_packet_release()
235 packet_ptr -> nx_packet_queue_next = pool_ptr -> nx_packet_pool_available_list; in _nx_packet_release()
[all …]
Dnx_packet_pool_cleanup.c81 NX_PACKET_POOL *pool_ptr; /* Working packet pool pointer */ in _nx_packet_pool_cleanup() local
86 pool_ptr = (NX_PACKET_POOL *)thread_ptr -> tx_thread_suspend_control_block; in _nx_packet_pool_cleanup() local
92 if ((thread_ptr -> tx_thread_suspend_cleanup) && (pool_ptr) && in _nx_packet_pool_cleanup()
93 (pool_ptr -> nx_packet_pool_id == NX_PACKET_POOL_ID)) in _nx_packet_pool_cleanup()
110 pool_ptr -> nx_packet_pool_suspension_list = TX_NULL; in _nx_packet_pool_cleanup()
118 if (pool_ptr -> nx_packet_pool_suspension_list == thread_ptr) in _nx_packet_pool_cleanup()
120 … pool_ptr -> nx_packet_pool_suspension_list = thread_ptr -> tx_thread_suspended_next; in _nx_packet_pool_cleanup()
131 pool_ptr -> nx_packet_pool_suspended_count--; in _nx_packet_pool_cleanup()
Dnxe_packet_pool_low_watermark_set.c80 UINT _nxe_packet_pool_low_watermark_set(NX_PACKET_POOL *pool_ptr, ULONG low_watermark) in _nxe_packet_pool_low_watermark_set() argument
88 if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID)) in _nxe_packet_pool_low_watermark_set()
97 status = _nx_packet_pool_low_watermark_set(pool_ptr, low_watermark); in _nxe_packet_pool_low_watermark_set()
103 NX_PARAMETER_NOT_USED(pool_ptr); in _nxe_packet_pool_low_watermark_set()
Dnxe_packet_pool_delete.c77 UINT _nxe_packet_pool_delete(NX_PACKET_POOL *pool_ptr) in _nxe_packet_pool_delete() argument
84 if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID)) in _nxe_packet_pool_delete()
93 status = _nx_packet_pool_delete(pool_ptr); in _nxe_packet_pool_delete()
Dnxe_packet_allocate.c81 UINT _nxe_packet_allocate(NX_PACKET_POOL *pool_ptr, NX_PACKET **packet_ptr, in _nxe_packet_allocate() argument
89 …if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID) || (packet_ptr =… in _nxe_packet_allocate()
105 status = _nx_packet_allocate(pool_ptr, packet_ptr, packet_type, wait_option); in _nxe_packet_allocate()
Dnxe_packet_pool_info_get.c84 UINT _nxe_packet_pool_info_get(NX_PACKET_POOL *pool_ptr, ULONG *total_packets, ULONG *free_packets, in _nxe_packet_pool_info_get() argument
93 if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID)) in _nxe_packet_pool_info_get()
102 status = _nx_packet_pool_info_get(pool_ptr, total_packets, free_packets, empty_pool_requests, in _nxe_packet_pool_info_get()
Dnxe_packet_copy.c81 NX_PACKET_POOL *pool_ptr, ULONG wait_option) in _nxe_packet_copy() argument
88 if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID) || in _nxe_packet_copy()
112 status = _nx_packet_copy(packet_ptr, new_packet_ptr, pool_ptr, wait_option); in _nxe_packet_copy()
Dnxe_packet_data_append.c82 NX_PACKET_POOL *pool_ptr, ULONG wait_option) in _nxe_packet_data_append() argument
89 if ((pool_ptr == NX_NULL) || (pool_ptr -> nx_packet_pool_id != NX_PACKET_POOL_ID) || in _nxe_packet_data_append()
119 status = _nx_packet_data_append(packet_ptr, data_start, data_size, pool_ptr, wait_option); in _nxe_packet_data_append()
Dnx_http_proxy_client.c384 NX_PACKET_POOL *pool_ptr = ip_ptr -> nx_ip_default_packet_pool; in _nx_http_proxy_client_connect() local
406 status = _nx_packet_allocate(pool_ptr, &packet_ptr, NX_IPv4_TCP_PACKET, NX_NO_WAIT); in _nx_http_proxy_client_connect()
410 status = _nx_packet_allocate(pool_ptr, &packet_ptr, NX_IPv6_TCP_PACKET, NX_NO_WAIT); in _nx_http_proxy_client_connect()
444 …status = _nx_packet_data_append(packet_ptr, "CONNECT ", sizeof("CONNECT ") - 1, pool_ptr, NX_NO_WA… in _nx_http_proxy_client_connect()
445 … status += _nx_packet_data_append(packet_ptr, ip_string_ptr, ip_string_len, pool_ptr, NX_NO_WAIT); in _nx_http_proxy_client_connect()
446 status += _nx_packet_data_append(packet_ptr, ":", sizeof(":") - 1, pool_ptr, NX_NO_WAIT); in _nx_http_proxy_client_connect()
447 …status += _nx_packet_data_append(packet_ptr, port_string_ptr, port_string_len, pool_ptr, NX_NO_WAI… in _nx_http_proxy_client_connect()
448 …status += _nx_packet_data_append(packet_ptr, " HTTP/1.1", sizeof(" HTTP/1.1") - 1, pool_ptr, NX_NO… in _nx_http_proxy_client_connect()
449 …status += _nx_packet_data_append(packet_ptr, NX_HTTP_CRLF, NX_HTTP_CRLF_SIZE, pool_ptr, NX_NO_WAIT… in _nx_http_proxy_client_connect()
452 …status += _nx_packet_data_append(packet_ptr, "Host: ", sizeof("Host: ") - 1, pool_ptr, NX_NO_WAIT); in _nx_http_proxy_client_connect()
[all …]
Dnx_packet_pool_low_watermark_set.c70 UINT _nx_packet_pool_low_watermark_set(NX_PACKET_POOL *pool_ptr, ULONG low_watermark) in _nx_packet_pool_low_watermark_set() argument
80 pool_ptr -> nx_packet_pool_low_watermark = low_watermark; in _nx_packet_pool_low_watermark_set()
89 NX_PARAMETER_NOT_USED(pool_ptr); in _nx_packet_pool_low_watermark_set()
Dnx_packet_debug_info_get.c77 UINT _nx_packet_debug_info_get(NX_PACKET_POOL *pool_ptr, UINT packet_index, NX_PACKET **packet_ppt… in _nx_packet_debug_info_get() argument
85 packet_ptr = (NX_PACKET *)(pool_ptr -> nx_packet_pool_start); in _nx_packet_debug_info_get()
91 …payload_size = (ULONG)(((pool_ptr -> nx_packet_pool_payload_size + header_size + NX_PACKET_ALIGNME… in _nx_packet_debug_info_get()
94 …packet_ptr = (NX_PACKET *)(pool_ptr -> nx_packet_pool_start + packet_index * (header_size + payloa… in _nx_packet_debug_info_get()
Dnx_packet_copy.c83 NX_PACKET_POOL *pool_ptr, ULONG wait_option) in _nx_packet_copy() argument
107 …NX_TRACE_IN_LINE_INSERT(NX_TRACE_PACKET_COPY, packet_ptr, 0, pool_ptr, wait_option, NX_TRACE_PACKE… in _nx_packet_copy()
119 status = _nx_packet_allocate(pool_ptr, &work_ptr, 0, wait_option); in _nx_packet_copy()
170 … _nx_packet_data_append(work_ptr, packet_ptr -> nx_packet_data_start, size, pool_ptr, wait_option); in _nx_packet_copy()
181 …_nx_packet_data_append(work_ptr, packet_ptr -> nx_packet_prepend_ptr, size, pool_ptr, wait_option); in _nx_packet_copy()
Dnxe_packet_pool_create.c85 UINT _nxe_packet_pool_create(NX_PACKET_POOL *pool_ptr, CHAR *name_ptr, ULONG payload_size, in _nxe_packet_pool_create() argument
104 …if ((pool_ptr == NX_NULL) || (pool_start == NX_NULL) || (pool_control_block_size != (UINT)sizeof(N… in _nxe_packet_pool_create()
162 if ((pool_ptr == created_pool) || in _nxe_packet_pool_create()
193 status = _nx_packet_pool_create(pool_ptr, name_ptr, payload_size, pool_start, pool_size); in _nxe_packet_pool_create()
Dnx_packet_data_append.c80 NX_PACKET_POOL *pool_ptr, ULONG wait_option) in _nx_packet_data_append() argument
95 …_INSERT(NX_TRACE_PACKET_DATA_APPEND, packet_ptr, data_start, data_size, pool_ptr, NX_TRACE_PACKET_… in _nx_packet_data_append()
145 status = _nx_packet_allocate(pool_ptr, &work_ptr, 0, wait_option); in _nx_packet_data_append()
225 NX_PARAMETER_NOT_USED(pool_ptr); in _nx_packet_data_append()
/NetX-Duo-v6.3.0/common/inc/
Dnx_packet.h93 UINT _nx_packet_allocate(NX_PACKET_POOL *pool_ptr, NX_PACKET **packet_ptr,
96 NX_PACKET_POOL *pool_ptr, ULONG wait_option);
98 NX_PACKET_POOL *pool_ptr, ULONG wait_option);
103 UINT _nx_packet_debug_info_get(NX_PACKET_POOL *pool_ptr, UINT packet_index, NX_PACKET **packet_pptr,
107 UINT _nx_packet_pool_create(NX_PACKET_POOL *pool_ptr, CHAR *name, ULONG payload_size,
109 UINT _nx_packet_pool_delete(NX_PACKET_POOL *pool_ptr);
110 UINT _nx_packet_pool_info_get(NX_PACKET_POOL *pool_ptr, ULONG *total_packets, ULONG *free_packets,
117 UINT _nx_packet_pool_low_watermark_set(NX_PACKET_POOL *pool_ptr, ULONG low_watermark);
123 UINT _nxe_packet_allocate(NX_PACKET_POOL *pool_ptr, NX_PACKET **packet_ptr,
126 NX_PACKET_POOL *pool_ptr, ULONG wait_option);
[all …]
/NetX-Duo-v6.3.0/nx_secure/src/
Dnxe_secure_dtls_packet_allocate.c70 …NT _nxe_secure_dtls_packet_allocate(NX_SECURE_DTLS_SESSION *dtls_session, NX_PACKET_POOL *pool_ptr, in _nxe_secure_dtls_packet_allocate() argument
76 if ((dtls_session == NX_NULL) || (pool_ptr == NX_NULL) || (packet_ptr == NX_NULL)) in _nxe_secure_dtls_packet_allocate()
87 status = _nx_secure_dtls_packet_allocate(dtls_session, pool_ptr, packet_ptr, wait_option); in _nxe_secure_dtls_packet_allocate()
92 NX_PARAMETER_NOT_USED(pool_ptr); in _nxe_secure_dtls_packet_allocate()
Dnx_secure_dtls_packet_allocate.c77 UINT _nx_secure_dtls_packet_allocate(NX_SECURE_DTLS_SESSION *dtls_session, NX_PACKET_POOL *pool_ptr, in _nx_secure_dtls_packet_allocate() argument
97 status = nx_packet_allocate(pool_ptr, packet_ptr, packet_type, wait_option); in _nx_secure_dtls_packet_allocate()
157 NX_PARAMETER_NOT_USED(pool_ptr); in _nx_secure_dtls_packet_allocate()
Dnxe_secure_tls_packet_allocate.c75 UINT _nxe_secure_tls_packet_allocate(NX_SECURE_TLS_SESSION *tls_session, NX_PACKET_POOL *pool_ptr, in _nxe_secure_tls_packet_allocate() argument
108 status = _nx_secure_tls_packet_allocate(tls_session, pool_ptr, packet_ptr, wait_option); in _nxe_secure_tls_packet_allocate()
/NetX-Duo-v6.3.0/addons/rtsp/
Dnx_rtsp_server.c1311 NX_PACKET_POOL *pool_ptr = rtsp_client_ptr -> nx_rtsp_client_server_ptr -> nx_rtsp_server_packet_po… in _nx_rtsp_server_error_response_send() local
1351 pool_ptr, NX_RTSP_SERVER_PACKET_TIMEOUT); in _nx_rtsp_server_error_response_send()
1352 …status += nx_packet_data_append(response_packet_ptr, " ", 1, pool_ptr, NX_RTSP_SERVER_PACKET_TIMEO… in _nx_rtsp_server_error_response_send()
1356 …status += nx_packet_data_append(response_packet_ptr, temp_buffer, temp_length, pool_ptr, NX_RTSP_S… in _nx_rtsp_server_error_response_send()
1357 …status += nx_packet_data_append(response_packet_ptr, " ", 1, pool_ptr, NX_RTSP_SERVER_PACKET_TIMEO… in _nx_rtsp_server_error_response_send()
1360 temp_length, pool_ptr, NX_RTSP_SERVER_PACKET_TIMEOUT); in _nx_rtsp_server_error_response_send()
1361 …x_rtsp_client_response_packet, NX_RTSP_SERVER_STRING_WITH_SIZE("\r\n"), pool_ptr, NX_RTSP_SERVER_P… in _nx_rtsp_server_error_response_send()
1364 …rtsp_client_response_packet, NX_RTSP_SERVER_STRING_WITH_SIZE("CSeq: "), pool_ptr, NX_RTSP_SERVER_P… in _nx_rtsp_server_error_response_send()
1366 …status += nx_packet_data_append(response_packet_ptr, temp_buffer, temp_length, pool_ptr, NX_RTSP_S… in _nx_rtsp_server_error_response_send()
1367 …x_rtsp_client_response_packet, NX_RTSP_SERVER_STRING_WITH_SIZE("\r\n"), pool_ptr, NX_RTSP_SERVER_P… in _nx_rtsp_server_error_response_send()
[all …]
/NetX-Duo-v6.3.0/addons/ftp/
Dnxd_ftp_server.h373 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
376 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
386 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
389 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
392 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
395 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
406 …e, NX_IP *ip_ptr, FX_MEDIA *media_ptr, VOID *stack_ptr, ULONG stack_size, NX_PACKET_POOL *pool_ptr,
436 UINT _nx_ftp_packet_allocate(NX_PACKET_POOL *pool_ptr, NX_FTP_CLIENT_REQUEST *client_request…
438 UINT _nx_ftp_server_block_header_send(NX_PACKET_POOL *pool_ptr, NX_FTP_CLIENT_REQUEST *clien…
/NetX-Duo-v6.3.0/samples/
Ddemo_mqtt_client.c94 void thread_mqtt_entry(NX_IP *ip_ptr, NX_PACKET_POOL *pool_ptr);
97 void thread_mqtt_entry(NX_IP *ip_ptr, NX_PACKET_POOL *pool_ptr) in thread_mqtt_entry() argument
106 … ip_ptr, pool_ptr, (VOID*)mqtt_client_stack, sizeof(mqtt_client_stack), in thread_mqtt_entry()

123