Lines Matching refs:queue_ptr

79 UINT  _tx_queue_front_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option)  in _tx_queue_front_send()  argument
109 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_front_send()
113 …LINE_INSERT(TX_TRACE_QUEUE_FRONT_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_front_send()
119 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_front_send()
122 if (queue_ptr -> tx_queue_available_storage != ((UINT) 0)) in _tx_queue_front_send()
137 if (queue_ptr -> tx_queue_read == queue_ptr -> tx_queue_start) in _tx_queue_front_send()
142queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_end, queue_ptr -> tx_queu… in _tx_queue_front_send()
148queue_ptr -> tx_queue_read = TX_ULONG_POINTER_SUB(queue_ptr -> tx_queue_read, queue_ptr -> tx_que… in _tx_queue_front_send()
154 queue_ptr -> tx_queue_available_storage--; in _tx_queue_front_send()
157 queue_ptr -> tx_queue_enqueued++; in _tx_queue_front_send()
161 destination = queue_ptr -> tx_queue_read; in _tx_queue_front_send()
162 size = queue_ptr -> tx_queue_message_size; in _tx_queue_front_send()
171 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
184 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()
193 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_front_send()
203 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_front_send()
211 queue_ptr -> tx_queue_suspension_list = thread_ptr -> tx_thread_suspended_next; in _tx_queue_front_send()
215 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_front_send()
224 queue_ptr -> tx_queue_suspended_count = suspended_count; in _tx_queue_front_send()
235 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
241 size = queue_ptr -> tx_queue_message_size; in _tx_queue_front_send()
276 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()
311 thread_ptr -> tx_thread_suspend_control_block = (VOID *) queue_ptr; in _tx_queue_front_send()
331 queue_ptr -> tx_queue_suspension_list = thread_ptr; in _tx_queue_front_send()
339 … next_thread = queue_ptr -> tx_queue_suspension_list; in _tx_queue_front_send()
349 queue_ptr -> tx_queue_suspension_list = thread_ptr; in _tx_queue_front_send()
353 queue_ptr -> tx_queue_suspended_count = suspended_count + ((UINT) 1); in _tx_queue_front_send()
361 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_front_send()
400 (queue_send_notify)(queue_ptr); in _tx_queue_front_send()