81 UINT  _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option)  in _tx_queue_receive()  argument
108     queue_ptr -> tx_queue_performance_messages_received_count++;  in _tx_queue_receive()
113 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait…  in _tx_queue_receive()
119     suspended_count =  queue_ptr -> tx_queue_suspended_count;  in _tx_queue_receive()
122     if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES)  in _tx_queue_receive()
132             source =       queue_ptr -> tx_queue_read;  in _tx_queue_receive()
134             size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
141             if (source == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
145                 source =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
149             queue_ptr -> tx_queue_read =  source;  in _tx_queue_receive()
152             queue_ptr -> tx_queue_available_storage++;  in _tx_queue_receive()
155             queue_ptr -> tx_queue_enqueued--;  in _tx_queue_receive()
166             thread_ptr =  queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
181                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
196                     queue_ptr -> tx_queue_suspension_list =  TX_NULL;  in _tx_queue_receive()
205                     queue_ptr -> tx_queue_suspension_list =  next_thread;  in _tx_queue_receive()
214                 queue_ptr -> tx_queue_suspended_count =  suspended_count;  in _tx_queue_receive()
251                 source =       queue_ptr -> tx_queue_read;  in _tx_queue_receive()
253                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
260                 if (source == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
264                     source =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
268                 queue_ptr -> tx_queue_read =  source;  in _tx_queue_receive()
290                 destination =  queue_ptr -> tx_queue_write;  in _tx_queue_receive()
291                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
298                 if (destination == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
302                     destination =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
306                 queue_ptr -> tx_queue_write =  destination;  in _tx_queue_receive()
309                 thread_ptr =  queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
320                     queue_ptr -> tx_queue_suspension_list =  TX_NULL;  in _tx_queue_receive()
329                     queue_ptr -> tx_queue_suspension_list =  next_thread;  in _tx_queue_receive()
338                 queue_ptr -> tx_queue_suspended_count =  suspended_count;  in _tx_queue_receive()
395             queue_ptr -> tx_queue_performance_empty_suspension_count++;  in _tx_queue_receive()
406             thread_ptr -> tx_thread_suspend_control_block =    (VOID *) queue_ptr;  in _tx_queue_receive()
423                 queue_ptr -> tx_queue_suspension_list =         thread_ptr;  in _tx_queue_receive()
431 …             next_thread =                                   queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
440             queue_ptr -> tx_queue_suspended_count =  suspended_count + ((UINT) 1);  in _tx_queue_receive()