Searched refs:pending_queue (Results 1 – 9 of 9) sorted by relevance
372 token_sequence_type pending_queue; // tokens already preprocessed member in boost::wave::impl::pp_iterator_functor594 pending_queue.splice(pending_queue.begin(), rescanned); in operator ()()595 act_token = pending_queue.front(); in operator ()()597 pending_queue.pop_front(); in operator ()()615 pending_queue.push_front(act_token); // push this token back in operator ()()633 if (!pending_queue.empty() || !unput_queue.empty()) in get_next_token()646 if (!pending_queue.empty()) { in get_next_token()648 pop_front_token(pending_queue); in get_next_token()650 return act_token = pending_queue.front(); in get_next_token()675 pending_queue.push_back( in get_next_token()[all …]
1027 ContainerT pending_queue; in expand_whole_tokensequence() local1030 while (!pending_queue.empty() || first_it != last_it) { in expand_whole_tokensequence()1033 pending_queue, first_it, in expand_whole_tokensequence()1040 BOOST_ASSERT(pending_queue.empty()/* && unput_queue.empty()*/); in expand_whole_tokensequence()
341 !QUEUE_EMPTY(&loop->pending_queue) || in uv__loop_alive()350 QUEUE_EMPTY(&loop->pending_queue) && in uv__backend_timeout()787 if (QUEUE_EMPTY(&loop->pending_queue)) in uv__run_pending()790 QUEUE_MOVE(&loop->pending_queue, &pq); in uv__run_pending()796 w = QUEUE_DATA(q, uv__io_t, pending_queue); in uv__run_pending()853 QUEUE_INIT(&w->pending_queue); in uv__io_init()928 QUEUE_REMOVE(&w->pending_queue); in uv__io_close()937 if (QUEUE_EMPTY(&w->pending_queue)) in uv__io_feed()938 QUEUE_INSERT_TAIL(&loop->pending_queue, &w->pending_queue); in uv__io_feed()
62 QUEUE_INIT(&loop->pending_queue); in uv_loop_init()195 assert(QUEUE_EMPTY(&loop->pending_queue)); in uv__loop_close()
721 nvenc->pending_queue = g_async_queue_new (); in gst_nv_base_enc_start()764 if (nvenc->pending_queue) { in gst_nv_base_enc_stop()765 g_async_queue_unref (nvenc->pending_queue); in gst_nv_base_enc_stop()766 nvenc->pending_queue = NULL; in gst_nv_base_enc_stop()1357 g_async_queue_lock (nvenc->pending_queue); in gst_nv_base_enc_stop_bitstream_thread()1365 g_async_queue_unlock (nvenc->pending_queue); in gst_nv_base_enc_stop_bitstream_thread()1396 while ((ptr = g_async_queue_try_pop (nvenc->pending_queue))) { in gst_nv_base_enc_reset_queues()2369 g_async_queue_push (nvenc->pending_queue, state); in _submit_input_buffer()2392 g_async_queue_lock (nvenc->pending_queue); in _submit_input_buffer()2394 len = g_async_queue_length_unlocked (nvenc->pending_queue); in _submit_input_buffer()[all …]
135 GAsyncQueue *pending_queue; member
96 void* pending_queue[2]; member224 void* pending_queue[2]; \
106 GstAtomicQueue *pending_queue; member
35036 - The submitted input/output buffer pair will be queued to pending_queue35037 - If NvEncEncodePicture returned success, then move all pair in pending_queue