Searched defs:input_queue (Results 1 – 5 of 5) sorted by relevance
14 def Steering(cache, generations, input_queue, result_queue): argument
986 let input_queue = Arc::new(Mutex::new(Queue::new())); in run_queue_test() localVariable1026 let mut input_queue = input_queue.lock(); in run_queue_test() localVariable
174 let input_queue = match self.input.as_mut() { in start_receive_queue() localVariable
648 mbedtls_test_ssl_message_queue *input_queue, in mbedtls_test_ssl_endpoint_init()
735 mbedtls_test_ssl_message_queue *input_queue, in mbedtls_test_ssl_endpoint_init()