Lines Matching refs:queue_ptr
80 UINT _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option) in _tx_queue_send() argument
110 queue_ptr -> tx_queue_performance_messages_sent_count++; in _tx_queue_send()
114 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op… in _tx_queue_send()
120 suspended_count = queue_ptr -> tx_queue_suspended_count; in _tx_queue_send()
123 if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES) in _tx_queue_send()
135 queue_ptr -> tx_queue_available_storage--; in _tx_queue_send()
138 queue_ptr -> tx_queue_enqueued++; in _tx_queue_send()
142 destination = queue_ptr -> tx_queue_write; in _tx_queue_send()
143 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
150 if (destination == queue_ptr -> tx_queue_end) in _tx_queue_send()
154 destination = queue_ptr -> tx_queue_start; in _tx_queue_send()
158 queue_ptr -> tx_queue_write = destination; in _tx_queue_send()
163 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_send()
178 (queue_send_notify)(queue_ptr); in _tx_queue_send()
190 thread_ptr = queue_ptr -> tx_queue_suspension_list; in _tx_queue_send()
200 queue_ptr -> tx_queue_suspension_list = TX_NULL; in _tx_queue_send()
208 queue_ptr -> tx_queue_suspension_list = thread_ptr -> tx_thread_suspended_next; in _tx_queue_send()
212 queue_ptr -> tx_queue_suspension_list = next_thread; in _tx_queue_send()
221 queue_ptr -> tx_queue_suspended_count = suspended_count; in _tx_queue_send()
231 size = queue_ptr -> tx_queue_message_size; in _tx_queue_send()
243 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_send()
272 (queue_send_notify)(queue_ptr); in _tx_queue_send()
303 queue_ptr -> tx_queue_performance_full_suspension_count++; in _tx_queue_send()
314 thread_ptr -> tx_thread_suspend_control_block = (VOID *) queue_ptr; in _tx_queue_send()
331 queue_ptr -> tx_queue_suspension_list = thread_ptr; in _tx_queue_send()
339 … next_thread = queue_ptr -> tx_queue_suspension_list; in _tx_queue_send()
348 queue_ptr -> tx_queue_suspended_count = suspended_count + ((UINT) 1); in _tx_queue_send()
356 queue_send_notify = queue_ptr -> tx_queue_send_notify; in _tx_queue_send()
395 (queue_send_notify)(queue_ptr); in _tx_queue_send()
412 queue_ptr -> tx_queue_performance_full_error_count++; in _tx_queue_send()