79 UINT  _tx_queue_send(TX_QUEUE *queue_ptr, VOID *source_ptr, ULONG wait_option)  in _tx_queue_send()  argument
109     queue_ptr -> tx_queue_performance_messages_sent_count++;  in _tx_queue_send()
113 …CE_IN_LINE_INSERT(TX_TRACE_QUEUE_SEND, queue_ptr, TX_POINTER_TO_ULONG_CONVERT(source_ptr), wait_op…  in _tx_queue_send()
119     suspended_count =  queue_ptr -> tx_queue_suspended_count;  in _tx_queue_send()
122     if (queue_ptr -> tx_queue_available_storage != TX_NO_MESSAGES)  in _tx_queue_send()
134             queue_ptr -> tx_queue_available_storage--;  in _tx_queue_send()
137             queue_ptr -> tx_queue_enqueued++;  in _tx_queue_send()
141             destination =  queue_ptr -> tx_queue_write;  in _tx_queue_send()
142             size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_send()
149             if (destination == queue_ptr -> tx_queue_end)  in _tx_queue_send()
153                 destination =  queue_ptr -> tx_queue_start;  in _tx_queue_send()
157             queue_ptr -> tx_queue_write =  destination;  in _tx_queue_send()
162             queue_send_notify =  queue_ptr -> tx_queue_send_notify;  in _tx_queue_send()
177                 (queue_send_notify)(queue_ptr);  in _tx_queue_send()
189             thread_ptr =  queue_ptr -> tx_queue_suspension_list;  in _tx_queue_send()
199                 queue_ptr -> tx_queue_suspension_list =  TX_NULL;  in _tx_queue_send()
207                 queue_ptr -> tx_queue_suspension_list =  thread_ptr -> tx_thread_suspended_next;  in _tx_queue_send()
211                 queue_ptr -> tx_queue_suspension_list =  next_thread;  in _tx_queue_send()
220             queue_ptr -> tx_queue_suspended_count =  suspended_count;  in _tx_queue_send()
230             size =         queue_ptr -> tx_queue_message_size;  in _tx_queue_send()
242             queue_send_notify =  queue_ptr -> tx_queue_send_notify;  in _tx_queue_send()
271                 (queue_send_notify)(queue_ptr);  in _tx_queue_send()
302             queue_ptr -> tx_queue_performance_full_suspension_count++;  in _tx_queue_send()
313             thread_ptr -> tx_thread_suspend_control_block =    (VOID *) queue_ptr;  in _tx_queue_send()
330                 queue_ptr -> tx_queue_suspension_list =         thread_ptr;  in _tx_queue_send()
338 …             next_thread =                                   queue_ptr -> tx_queue_suspension_list;  in _tx_queue_send()
347             queue_ptr -> tx_queue_suspended_count =  suspended_count + ((UINT) 1);  in _tx_queue_send()
355             queue_send_notify =  queue_ptr -> tx_queue_send_notify;  in _tx_queue_send()
394                     (queue_send_notify)(queue_ptr);  in _tx_queue_send()
411         queue_ptr -> tx_queue_performance_full_error_count++;  in _tx_queue_send()