82 UINT  _tx_queue_receive(TX_QUEUE *queue_ptr, VOID *destination_ptr, ULONG wait_option)  in _tx_queue_receive()  argument
109     queue_ptr -> tx_queue_performance_messages_received_count++;  in _tx_queue_receive()
114 …_LINE_INSERT(TX_TRACE_QUEUE_RECEIVE, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(destination_ptr), wait…  in _tx_queue_receive()
120     suspended_count =  queue_ptr -> tx_queue_suspended_count;  in _tx_queue_receive()
123     if (queue_ptr -> tx_queue_enqueued != TX_NO_MESSAGES)  in _tx_queue_receive()
133             source =       queue_ptr -> tx_queue_read;  in _tx_queue_receive()
135             size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
142             if (source == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
146                 source =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
150             queue_ptr -> tx_queue_read =  source;  in _tx_queue_receive()
153             queue_ptr -> tx_queue_available_storage++;  in _tx_queue_receive()
156             queue_ptr -> tx_queue_enqueued--;  in _tx_queue_receive()
167             thread_ptr =  queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
182                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
197                     queue_ptr -> tx_queue_suspension_list =  TX_NULL;  in _tx_queue_receive()
206                     queue_ptr -> tx_queue_suspension_list =  next_thread;  in _tx_queue_receive()
215                 queue_ptr -> tx_queue_suspended_count =  suspended_count;  in _tx_queue_receive()
252                 source =       queue_ptr -> tx_queue_read;  in _tx_queue_receive()
254                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
261                 if (source == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
265                     source =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
269                 queue_ptr -> tx_queue_read =  source;  in _tx_queue_receive()
291                 destination =  queue_ptr -> tx_queue_write;  in _tx_queue_receive()
292                 size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_receive()
299                 if (destination == queue_ptr -> tx_queue_end)  in _tx_queue_receive()
303                     destination =  queue_ptr -> tx_queue_start;  in _tx_queue_receive()
307                 queue_ptr -> tx_queue_write =  destination;  in _tx_queue_receive()
310                 thread_ptr =  queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
321                     queue_ptr -> tx_queue_suspension_list =  TX_NULL;  in _tx_queue_receive()
330                     queue_ptr -> tx_queue_suspension_list =  next_thread;  in _tx_queue_receive()
339                 queue_ptr -> tx_queue_suspended_count =  suspended_count;  in _tx_queue_receive()
396             queue_ptr -> tx_queue_performance_empty_suspension_count++;  in _tx_queue_receive()
407             thread_ptr -> tx_thread_suspend_control_block =    (VOID *) queue_ptr;  in _tx_queue_receive()
424                 queue_ptr -> tx_queue_suspension_list =         thread_ptr;  in _tx_queue_receive()
432 …             next_thread =                                   queue_ptr -> tx_queue_suspension_list;  in _tx_queue_receive()
441             queue_ptr -> tx_queue_suspended_count =  suspended_count + ((UINT) 1);  in _tx_queue_receive()