/dports/mail/postfix-current/postfix-3.7-20211107/src/oqmgr/ |
H A D | qmgr_move.c | 57 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 D | qmgr_move.c | 57 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 D | qmgr_entry.c | 203 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 D | s5p_mfc.c | 189 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 D | s5p_mfc_enc.c | 1140 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 D | s5p_mfc_dec.c | 1045 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 D | s5p_mfc_opr_v5.c | 1206 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 D | s5p_mfc.c | 189 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 D | s5p_mfc_enc.c | 1140 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 D | s5p_mfc_dec.c | 1045 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 D | s5p_mfc.c | 189 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 D | s5p_mfc_enc.c | 1140 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 D | s5p_mfc_dec.c | 1045 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 D | conformance_concurrent_queue.cpp | 430 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 D | test_concurrent_queue.cpp | 583 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 D | test_concurrent_queue.cpp | 583 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 D | test_concurrent_queue.cpp | 583 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 D | skl-sst-ipc.h | 85 u8 dst_queue; member
|
H A D | skl-messages.c | 1057 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 D | skl-sst-ipc.h | 85 u8 dst_queue; member
|
H A D | skl-messages.c | 1057 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 D | skl-sst-ipc.h | 85 u8 dst_queue; member
|
H A D | skl-messages.c | 1057 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 D | e-data-server-util.c | 1213 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 D | e-data-server-util.h | 90 GQueue *dst_queue);
|