| /dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/sequence_manager/ |
| H A D | sequence_manager_impl.cc | 241 main_thread_only().active_queues.clear(); in ~SequenceManagerImpl()
375 main_thread_only().active_queues.insert(task_queue.get()); in CreateTaskQueueImpl()
415 main_thread_only().active_queues.erase(task_queue.get()); in UnregisterTaskQueueImpl()
944 Value active_queues(Value::Type::LIST); in AsValueWithSelectorResult() local
945 for (auto* const queue : main_thread_only().active_queues) in AsValueWithSelectorResult()
946 active_queues.Append(queue->AsValue(now, force_verbose)); in AsValueWithSelectorResult()
947 state.SetKey("active_queues", std::move(active_queues)); in AsValueWithSelectorResult()
995 for (auto* const queue : main_thread_only().active_queues) in ReclaimMemory()
1006 main_thread_only().active_queues.erase(it->first); in CleanUpQueues()
1059 for (TaskQueueImpl* task_queue : main_thread_only().active_queues) in DeletePendingTasks()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/sequence_manager/ |
| H A D | sequence_manager_impl.cc | 211 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) { in ~SequenceManagerImpl()
220 main_thread_only().active_queues.clear(); in ~SequenceManagerImpl()
352 main_thread_only().active_queues.insert(task_queue.get()); in CreateTaskQueueImpl()
392 main_thread_only().active_queues.erase(task_queue.get()); in UnregisterTaskQueueImpl()
914 for (auto* const queue : main_thread_only().active_queues) in AsValueWithSelectorResultInto()
966 for (auto* const queue : main_thread_only().active_queues) in ReclaimMemory()
977 main_thread_only().active_queues.erase(it->first); in CleanUpQueues()
987 for (internal::TaskQueueImpl* queue : main_thread_only().active_queues) { in RemoveAllCanceledTasksFromFrontOfWorkQueues()
1030 for (TaskQueueImpl* task_queue : main_thread_only().active_queues) in DeletePendingTasks()
1042 for (TaskQueueImpl* task_queue : main_thread_only().active_queues) { in HasTasks()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/sequence_manager/test/ |
| H A D | sequence_manager_for_test.cc | 80 return main_thread_only().active_queues.size(); in ActiveQueuesCount()
89 for (auto* const queue : main_thread_only().active_queues) in PendingTasksCount()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/sfc/ |
| H A D | mcdi_functions.c | 366 atomic_set(&efx->active_queues, 0); in efx_fini_dmaq()
380 atomic_read(&efx->active_queues) == 0, in efx_fini_dmaq()
382 pending = atomic_read(&efx->active_queues); in efx_fini_dmaq()
|
| H A D | farch.c | 596 return (atomic_read(&efx->active_queues) == 0 || in efx_farch_flush_wake()
663 while (timeout && atomic_read(&efx->active_queues) > 0) { in efx_farch_do_flush()
699 if (atomic_read(&efx->active_queues) && in efx_farch_do_flush()
702 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in efx_farch_do_flush()
707 atomic_set(&efx->active_queues, 0); in efx_farch_do_flush()
760 atomic_set(&efx->active_queues, 0); in efx_farch_finish_flr()
1137 WARN_ON(atomic_read(&efx->active_queues) == 0); in efx_farch_handle_drain_event()
1138 atomic_dec(&efx->active_queues); in efx_farch_handle_drain_event()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/sfc/ |
| H A D | mcdi_functions.c | 366 atomic_set(&efx->active_queues, 0); in efx_fini_dmaq()
380 atomic_read(&efx->active_queues) == 0, in efx_fini_dmaq()
382 pending = atomic_read(&efx->active_queues); in efx_fini_dmaq()
|
| H A D | farch.c | 596 return (atomic_read(&efx->active_queues) == 0 || in efx_farch_flush_wake()
663 while (timeout && atomic_read(&efx->active_queues) > 0) { in efx_farch_do_flush()
699 if (atomic_read(&efx->active_queues) && in efx_farch_do_flush()
702 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in efx_farch_do_flush()
707 atomic_set(&efx->active_queues, 0); in efx_farch_do_flush()
760 atomic_set(&efx->active_queues, 0); in efx_farch_finish_flr()
1137 WARN_ON(atomic_read(&efx->active_queues) == 0); in efx_farch_handle_drain_event()
1138 atomic_dec(&efx->active_queues); in efx_farch_handle_drain_event()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/sfc/ |
| H A D | mcdi_functions.c | 366 atomic_set(&efx->active_queues, 0); in efx_fini_dmaq()
380 atomic_read(&efx->active_queues) == 0, in efx_fini_dmaq()
382 pending = atomic_read(&efx->active_queues); in efx_fini_dmaq()
|
| H A D | farch.c | 596 return (atomic_read(&efx->active_queues) == 0 || in efx_farch_flush_wake()
663 while (timeout && atomic_read(&efx->active_queues) > 0) { in efx_farch_do_flush()
699 if (atomic_read(&efx->active_queues) && in efx_farch_do_flush()
702 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in efx_farch_do_flush()
707 atomic_set(&efx->active_queues, 0); in efx_farch_do_flush()
760 atomic_set(&efx->active_queues, 0); in efx_farch_finish_flr()
1137 WARN_ON(atomic_read(&efx->active_queues) == 0); in efx_farch_handle_drain_event()
1138 atomic_dec(&efx->active_queues); in efx_farch_handle_drain_event()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/block/ |
| H A D | blk-mq-tag.h | 12 atomic_t active_queues; member
|
| H A D | blk-mq-tag.c | 36 atomic_inc(&hctx->tags->active_queues); in __blk_mq_tag_busy()
70 atomic_dec(&tags->active_queues); in __blk_mq_tag_idle()
|
| H A D | blk-mq.h | 330 users = atomic_read(&hctx->tags->active_queues); in hctx_may_queue()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/block/ |
| H A D | blk-mq-tag.h | 12 atomic_t active_queues; member
|
| H A D | blk-mq-tag.c | 36 atomic_inc(&hctx->tags->active_queues); in __blk_mq_tag_busy()
70 atomic_dec(&tags->active_queues); in __blk_mq_tag_idle()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/block/ |
| H A D | blk-mq-tag.h | 12 atomic_t active_queues; member
|
| H A D | blk-mq-tag.c | 36 atomic_inc(&hctx->tags->active_queues); in __blk_mq_tag_busy()
70 atomic_dec(&tags->active_queues); in __blk_mq_tag_idle()
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/transport/ |
| H A D | redis.py | 322 if channel.active_queues: # BRPOP mode?
337 if channel.active_queues:
367 if channel.active_queues: # BRPOP mode?
721 queues = self._queue_cycle.consume(len(self.active_queues))
1014 self._queue_cycle.update(self.active_queues)
1021 def active_queues(self): member in Channel
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/drm/msm/adreno/ |
| H A D | a6xx_hfi.h | 13 u32 active_queues; /* Number of active queues */ member
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/gpu/drm/msm/adreno/ |
| H A D | a6xx_hfi.h | 13 u32 active_queues; /* Number of active queues */ member
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/gpu/drm/msm/adreno/ |
| H A D | a6xx_hfi.h | 13 u32 active_queues; /* Number of active queues */ member
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/sfc/falcon/ |
| H A D | farch.c | 609 return (atomic_read(&efx->active_queues) == 0 || in ef4_farch_flush_wake()
676 while (timeout && atomic_read(&efx->active_queues) > 0) { in ef4_farch_do_flush()
701 if (atomic_read(&efx->active_queues) && in ef4_farch_do_flush()
704 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in ef4_farch_do_flush()
709 atomic_set(&efx->active_queues, 0); in ef4_farch_do_flush()
762 atomic_set(&efx->active_queues, 0); in ef4_farch_finish_flr()
1146 WARN_ON(atomic_read(&efx->active_queues) == 0); in ef4_farch_handle_drain_event()
1147 atomic_dec(&efx->active_queues); in ef4_farch_handle_drain_event()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/sfc/falcon/ |
| H A D | farch.c | 609 return (atomic_read(&efx->active_queues) == 0 || in ef4_farch_flush_wake()
676 while (timeout && atomic_read(&efx->active_queues) > 0) { in ef4_farch_do_flush()
701 if (atomic_read(&efx->active_queues) && in ef4_farch_do_flush()
704 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in ef4_farch_do_flush()
709 atomic_set(&efx->active_queues, 0); in ef4_farch_do_flush()
762 atomic_set(&efx->active_queues, 0); in ef4_farch_finish_flr()
1146 WARN_ON(atomic_read(&efx->active_queues) == 0); in ef4_farch_handle_drain_event()
1147 atomic_dec(&efx->active_queues); in ef4_farch_handle_drain_event()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/sfc/falcon/ |
| H A D | farch.c | 609 return (atomic_read(&efx->active_queues) == 0 || in ef4_farch_flush_wake()
676 while (timeout && atomic_read(&efx->active_queues) > 0) { in ef4_farch_do_flush()
701 if (atomic_read(&efx->active_queues) && in ef4_farch_do_flush()
704 "(rx %d+%d)\n", atomic_read(&efx->active_queues), in ef4_farch_do_flush()
709 atomic_set(&efx->active_queues, 0); in ef4_farch_do_flush()
762 atomic_set(&efx->active_queues, 0); in ef4_farch_finish_flr()
1146 WARN_ON(atomic_read(&efx->active_queues) == 0); in ef4_farch_handle_drain_event()
1147 atomic_dec(&efx->active_queues); in ef4_farch_handle_drain_event()
|
| /dports/graphics/mesa-devel/mesa-22.0-branchpoint-2059-ge8a63cf61ec/src/freedreno/decode/ |
| H A D | crashdec-hfi.c | 66 uint32_t active_queues; /* Number of active queues */ member
500 printf("\tactive_queues: %u\n", table->active_queues); in dump_gmu_hfi()
|
| /dports/devel/py-celery/celery-4.4.7/docs/userguide/ |
| H A D | workers.rst | 711 .. control:: active_queues
717 the :control:`active_queues` control command:
721 $ celery -A proj inspect active_queues
730 $ celery -A proj inspect active_queues -d celery@worker1.local
735 :meth:`@control.inspect.active_queues` method:
739 >>> app.control.inspect().active_queues()
742 >>> app.control.inspect(['worker1.local']).active_queues()
|