Lines Matching refs:queue_ptr

80 UINT  _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option)  in _tx_queue_front_send()  argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
114 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
123 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
138 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
143queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
149queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
155 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
158 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
162 destination = queue_ptr -> tx_queue_read; in _tx_queue_front_send()
163 size = queue_ptr -> tx_queue_message_size; in _tx_queue_front_send()
172 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
185 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()
194 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_front_send()
204 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_front_send()
212 queue_ptr -> tx_queue_suspension_list = thread_ptr -> tx_thread_suspended_next; in _tx_queue_front_send()
216 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_front_send()
225 queue_ptr -> tx_queue_suspended_count = suspended_count; in _tx_queue_front_send()
236 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
242 size = queue_ptr -> tx_queue_message_size; in _tx_queue_front_send()
277 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()
312 thread_ptr -> tx_thread_suspend_control_block = (VOID *) queue_ptr; in _tx_queue_front_send()
332 queue_ptr -> tx_queue_suspension_list = thread_ptr; in _tx_queue_front_send()
340 … next_thread = queue_ptr -> tx_queue_suspension_list; in _tx_queue_front_send()
350 queue_ptr -> tx_queue_suspension_list = thread_ptr; in _tx_queue_front_send()
354 queue_ptr -> tx_queue_suspended_count = suspended_count + ((UINT) 1); in _tx_queue_front_send()
362 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
401 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()