Home
last modified time | relevance | path

Searched refs:dst_queue (Results 1 – 25 of 37) sorted by relevance

12

/dports/mail/postfix-current/postfix-3.7-20211107/src/oqmgr/
H A Dqmgr_move.c57 void qmgr_move(const char *src_queue, const char *dst_queue, in qmgr_move() argument
66 if (strcmp(src_queue, dst_queue) == 0) in qmgr_move()
69 msg_info("start move queue %s -> %s", src_queue, dst_queue); in qmgr_move()
84 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { in qmgr_move()
87 myname, queue_id, src_queue, dst_queue); in qmgr_move()
89 myname, queue_id, src_queue, dst_queue); in qmgr_move()
94 myname, queue_id, src_queue, dst_queue); in qmgr_move()
103 msg_info("end move queue %s -> %s", src_queue, dst_queue); in qmgr_move()
/dports/mail/postfix-current/postfix-3.7-20211107/src/qmgr/
H A Dqmgr_move.c57 void qmgr_move(const char *src_queue, const char *dst_queue, in qmgr_move() argument
66 if (strcmp(src_queue, dst_queue) == 0) in qmgr_move()
69 msg_info("start move queue %s -> %s", src_queue, dst_queue); in qmgr_move()
84 if (mail_queue_rename(queue_id, src_queue, dst_queue)) { in qmgr_move()
87 myname, queue_id, src_queue, dst_queue); in qmgr_move()
89 myname, queue_id, src_queue, dst_queue); in qmgr_move()
94 myname, queue_id, src_queue, dst_queue); in qmgr_move()
103 msg_info("end move queue %s -> %s", src_queue, dst_queue); in qmgr_move()
H A Dqmgr_entry.c203 void qmgr_entry_move_todo(QMGR_QUEUE *dst_queue, QMGR_ENTRY *entry) in qmgr_entry_move_todo() argument
206 QMGR_TRANSPORT *dst_transport = dst_queue->transport; in qmgr_entry_move_todo()
216 if (QMGR_QUEUE_THROTTLED(dst_queue)) in qmgr_entry_move_todo()
217 msg_panic("%s: destination queue %s is throttled", myname, dst_queue->name); in qmgr_entry_move_todo()
235 dst_peer = qmgr_peer_obtain(dst_job, dst_queue); in qmgr_entry_move_todo()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/media/platform/s5p-mfc/
H A Ds5p_mfc.c189 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_watchdog_worker()
226 while (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_frame_all_extracted()
227 dst_buf = list_entry(ctx->dst_queue.next, in s5p_mfc_handle_frame_all_extracted()
266 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_copy_time()
327 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_new()
484 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_handle_error()
611 if (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_stream_complete()
612 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in s5p_mfc_handle_stream_complete()
775 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_open()
H A Ds5p_mfc_enc.c1140 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_seq_start()
1156 if (!list_empty(&ctx->dst_queue)) { in enc_post_seq_start()
1157 dst_mb = list_entry(ctx->dst_queue.next, in enc_post_seq_start()
1204 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_frame_start()
1273 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in enc_post_frame_start()
2542 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
2543 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
2573 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
H A Ds5p_mfc_dec.c1045 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
1046 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
1092 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
H A Ds5p_mfc_opr_v5.c1206 if (list_empty(&ctx->dst_queue)) { in s5p_mfc_run_enc_frame()
1236 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in s5p_mfc_run_enc_frame()
1274 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in s5p_mfc_run_init_enc()
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/media/platform/s5p-mfc/
H A Ds5p_mfc.c189 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_watchdog_worker()
226 while (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_frame_all_extracted()
227 dst_buf = list_entry(ctx->dst_queue.next, in s5p_mfc_handle_frame_all_extracted()
266 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_copy_time()
327 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_new()
484 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_handle_error()
611 if (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_stream_complete()
612 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in s5p_mfc_handle_stream_complete()
775 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_open()
H A Ds5p_mfc_enc.c1140 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_seq_start()
1156 if (!list_empty(&ctx->dst_queue)) { in enc_post_seq_start()
1157 dst_mb = list_entry(ctx->dst_queue.next, in enc_post_seq_start()
1204 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_frame_start()
1273 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in enc_post_frame_start()
2542 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
2543 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
2573 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
H A Ds5p_mfc_dec.c1045 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
1046 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
1092 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/media/platform/s5p-mfc/
H A Ds5p_mfc.c189 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_watchdog_worker()
226 while (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_frame_all_extracted()
227 dst_buf = list_entry(ctx->dst_queue.next, in s5p_mfc_handle_frame_all_extracted()
266 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_copy_time()
327 list_for_each_entry(dst_buf, &ctx->dst_queue, list) { in s5p_mfc_handle_frame_new()
484 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_handle_error()
611 if (!list_empty(&ctx->dst_queue)) { in s5p_mfc_handle_stream_complete()
612 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in s5p_mfc_handle_stream_complete()
775 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_open()
H A Ds5p_mfc_enc.c1140 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_seq_start()
1156 if (!list_empty(&ctx->dst_queue)) { in enc_post_seq_start()
1157 dst_mb = list_entry(ctx->dst_queue.next, in enc_post_seq_start()
1204 dst_mb = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, list); in enc_pre_frame_start()
1273 mb_entry = list_entry(ctx->dst_queue.next, struct s5p_mfc_buf, in enc_post_frame_start()
2542 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
2543 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
2573 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
H A Ds5p_mfc_dec.c1045 s5p_mfc_cleanup_queue(&ctx->dst_queue, &ctx->vq_dst); in s5p_mfc_stop_streaming()
1046 INIT_LIST_HEAD(&ctx->dst_queue); in s5p_mfc_stop_streaming()
1092 list_add_tail(&mfc_buf->list, &ctx->dst_queue); in s5p_mfc_buf_queue()
/dports/devel/onetbb/oneTBB-2021.4.0/test/conformance/
H A Dconformance_concurrent_queue.cpp430 CQ dst_queue(sqb, sqe); in TestConstructors() local
433 CHECK_FAST_MESSAGE(src_queue.size() == dst_queue.size(), "different size"); in TestConstructors()
564 CQ dst_queue(std::move(src_queue)); in TestConstructors() local
567 …CHECK_FAST_MESSAGE((size == size_of_queue && size_of_queue == dst_queue.size()), "not working move… in TestConstructors()
570 …std::equal(locations.begin(), locations.end(), dst_queue.unsafe_begin(), [](const T* t1, const T& … in TestConstructors()
577 bool pop_result = dst_queue.try_pop( popped); in TestConstructors()
1320 CQ dst_queue( std::move(src_queue), allocator<T>(1) ); in TestMoveConstructors() local
1326 qit = dst_queue.unsafe_begin(); in TestMoveConstructors()
1334 CQ dst_queue2( std::move(dst_queue), allocator<T>(1) ); in TestMoveConstructors()
1338 TestQueueOperabilityAfterDataMove<T>( dst_queue ); in TestMoveConstructors()
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/
H A Dtest_concurrent_queue.cpp583 CQ dst_queue(sqb, sqe); in TestConstructors() local
585 ASSERT(src_queue.size()==dst_queue.size(), "different size"); in TestConstructors()
722 CQ dst_queue( std::move(src_queue) ); in TestConstructors() local
725 ASSERT( size == size_of_queue && size_of_queue == dst_queue.size(), in TestConstructors()
728 qit = dst_queue.unsafe_begin(); in TestConstructors()
735 bool pop_result = dst_queue.try_pop( popped ); in TestConstructors()
794 CQ dst_queue( std::move(src_queue), allocator<T>(1) ); in TestMoveConstructors() local
800 qit = dst_queue.unsafe_begin(); in TestMoveConstructors()
808 CQ dst_queue2( std::move(dst_queue), allocator<T>(1) ); in TestMoveConstructors()
812 TestQueueOperabilityAfterDataMove<T>( dst_queue ); in TestMoveConstructors()
/dports/devel/tbb/oneTBB-2020.3/src/test/
H A Dtest_concurrent_queue.cpp583 CQ dst_queue(sqb, sqe); in TestConstructors() local
585 ASSERT(src_queue.size()==dst_queue.size(), "different size"); in TestConstructors()
722 CQ dst_queue( std::move(src_queue) ); in TestConstructors() local
725 ASSERT( size == size_of_queue && size_of_queue == dst_queue.size(), in TestConstructors()
728 qit = dst_queue.unsafe_begin(); in TestConstructors()
735 bool pop_result = dst_queue.try_pop( popped ); in TestConstructors()
794 CQ dst_queue( std::move(src_queue), allocator<T>(1) ); in TestMoveConstructors() local
800 qit = dst_queue.unsafe_begin(); in TestMoveConstructors()
808 CQ dst_queue2( std::move(dst_queue), allocator<T>(1) ); in TestMoveConstructors()
812 TestQueueOperabilityAfterDataMove<T>( dst_queue ); in TestMoveConstructors()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/
H A Dtest_concurrent_queue.cpp583 CQ dst_queue(sqb, sqe); in TestConstructors() local
585 ASSERT(src_queue.size()==dst_queue.size(), "different size"); in TestConstructors()
722 CQ dst_queue( std::move(src_queue) ); in TestConstructors() local
725 ASSERT( size == size_of_queue && size_of_queue == dst_queue.size(), in TestConstructors()
728 qit = dst_queue.unsafe_begin(); in TestConstructors()
735 bool pop_result = dst_queue.try_pop( popped ); in TestConstructors()
794 CQ dst_queue( std::move(src_queue), allocator<T>(1) ); in TestMoveConstructors() local
800 qit = dst_queue.unsafe_begin(); in TestMoveConstructors()
808 CQ dst_queue2( std::move(dst_queue), allocator<T>(1) ); in TestMoveConstructors()
812 TestQueueOperabilityAfterDataMove<T>( dst_queue ); in TestMoveConstructors()
/dports/multimedia/v4l_compat/linux-5.13-rc2/sound/soc/intel/skylake/
H A Dskl-sst-ipc.h85 u8 dst_queue; member
H A Dskl-messages.c1057 msg.dst_queue = dst_index; in skl_unbind_modules()
1164 msg.dst_queue = dst_index; in skl_bind_modules()
1167 msg.src_queue, msg.dst_queue); in skl_bind_modules()
/dports/multimedia/libv4l/linux-5.13-rc2/sound/soc/intel/skylake/
H A Dskl-sst-ipc.h85 u8 dst_queue; member
H A Dskl-messages.c1057 msg.dst_queue = dst_index; in skl_unbind_modules()
1164 msg.dst_queue = dst_index; in skl_bind_modules()
1167 msg.src_queue, msg.dst_queue); in skl_bind_modules()
/dports/multimedia/v4l-utils/linux-5.13-rc2/sound/soc/intel/skylake/
H A Dskl-sst-ipc.h85 u8 dst_queue; member
H A Dskl-messages.c1057 msg.dst_queue = dst_index; in skl_unbind_modules()
1164 msg.dst_queue = dst_index; in skl_bind_modules()
1167 msg.src_queue, msg.dst_queue); in skl_bind_modules()
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/libedataserver/
H A De-data-server-util.c1213 GQueue *dst_queue) in e_queue_transfer() argument
1216 g_return_if_fail (dst_queue != NULL); in e_queue_transfer()
1218 dst_queue->head = g_list_concat (dst_queue->head, src_queue->head); in e_queue_transfer()
1219 dst_queue->tail = g_list_last (dst_queue->head); in e_queue_transfer()
1220 dst_queue->length += src_queue->length; in e_queue_transfer()
H A De-data-server-util.h90 GQueue *dst_queue);

12