Searched refs:incoming_async_msg (Results 1 – 5 of 5) sorted by relevance
93 async_msg incoming_async_msg; in process_next_msg_() local94 bool dequeued = q_.dequeue_for(incoming_async_msg, std::chrono::seconds(10)); in process_next_msg_()100 switch (incoming_async_msg.msg_type) in process_next_msg_()103 incoming_async_msg.worker_ptr->backend_sink_it_(incoming_async_msg); in process_next_msg_()107 incoming_async_msg.worker_ptr->backend_flush_(); in process_next_msg_()
98 async_msg incoming_async_msg; in process_next_msg_() local99 bool dequeued = q_.dequeue_for(incoming_async_msg, std::chrono::seconds(10)); in process_next_msg_()105 switch (incoming_async_msg.msg_type) in process_next_msg_()108 incoming_async_msg.worker_ptr->backend_sink_it_(incoming_async_msg); in process_next_msg_()112 incoming_async_msg.worker_ptr->backend_flush_(); in process_next_msg_()
206 async_msg incoming_async_msg; in process_next_msg_() local207 bool dequeued = q_.dequeue_for(incoming_async_msg, std::chrono::seconds(10)); in process_next_msg_()213 switch (incoming_async_msg.msg_type) in process_next_msg_()217 auto msg = incoming_async_msg.to_log_msg(); in process_next_msg_()218 incoming_async_msg.worker_ptr->backend_log_(msg); in process_next_msg_()223 incoming_async_msg.worker_ptr->backend_flush_(); in process_next_msg_()
285 async_msg incoming_async_msg; in process_next_msg() local288 if (_q.dequeue(incoming_async_msg)) in process_next_msg()291 switch (incoming_async_msg.msg_type) in process_next_msg()304 incoming_async_msg.fill_log_msg(incoming_log_msg); in process_next_msg()