| /dports/devel/quantum/quantum-2.2/quantum/impl/ |
| H A D | quantum_dispatcher_core_impl.h | 49 IQueue::setThreadName(IQueue::QueueType::Coro, in DispatcherCore()
64 IQueue::setThreadName(IQueue::QueueType::Coro, in DispatcherCore()
74 IQueue::setThreadName(IQueue::QueueType::IO, in DispatcherCore()
127 if (type == IQueue::QueueType::All) in size()
133 return coroSize((int)IQueue::QueueId::All) + ioSize((int)IQueue::QueueId::All); in size()
135 else if (type == IQueue::QueueType::Coro) in size()
146 if (type == IQueue::QueueType::All) in empty()
152 return coroEmpty((int)IQueue::QueueId::All) && ioEmpty((int)IQueue::QueueId::All); in empty()
154 else if (type == IQueue::QueueType::Coro) in empty()
272 if (type == IQueue::QueueType::All) in stats()
[all …]
|
| H A D | quantum_local_impl.h | 37 ITask::Ptr task = IQueue::getCurrentTask(); in variable()
47 ITask::Ptr task = IQueue::getCurrentTask(); in context()
59 ITask::Ptr task = IQueue::getCurrentTask(); in taskId()
|
| H A D | quantum_dispatcher_impl.h | 47 return postImpl<Ret>((int)IQueue::QueueId::Any,
60 return postImpl<Ret>((int)IQueue::QueueId::Any,
103 return postImpl<Ret>((int)IQueue::QueueId::Any,
115 return postImpl<Ret>((int)IQueue::QueueId::Any,
158 return postAsyncIoImpl<Ret>((int)IQueue::QueueId::Any,
170 return postAsyncIoImpl<Ret>((int)IQueue::QueueId::Any,
341 size_t Dispatcher::size(IQueue::QueueType type, in size()
348 bool Dispatcher::empty(IQueue::QueueType type, in empty()
416 QueueStatistics Dispatcher::stats(IQueue::QueueType type, in stats()
441 if (queueId < (int)IQueue::QueueId::Any) in postImpl()
[all …]
|
| /dports/devel/quantum/quantum-2.2/quantum/interface/ |
| H A D | quantum_iqueue.h | 38 struct IQueue : public ITerminate struct
41 using Ptr = std::shared_ptr<IQueue>; argument
85 TaskSetterGuard(IQueue& taskQueue, argument
88 IQueue& _taskQueue;
95 using IQueuePtr = IQueue::Ptr;
98 void IQueue::setThreadName(QueueType type, in setThreadName()
142 ITask::Ptr& IQueue::currentTask() in currentTask()
149 ITask::Ptr IQueue::getCurrentTask() in getCurrentTask()
155 void IQueue::setCurrentTask(ITask::Ptr task) in setCurrentTask()
161 IQueue::TaskSetterGuard::TaskSetterGuard(IQueue& taskQueue, in TaskSetterGuard()
[all …]
|
| /dports/devel/quantum/quantum-2.2/tests/ |
| H A D | quantum_tests.cpp | 237 dispatcher.post((int)IQueue::QueueId::Any, in enqueue_sleep_tasks()
274 EXPECT_EQ(0, (int)getDispatcher().size(IQueue::QueueType::Coro)); in TEST_P()
275 EXPECT_EQ(0, (int)getDispatcher().size(IQueue::QueueType::IO)); in TEST_P()
333 EXPECT_EQ((size_t)0, getDispatcher().size(IQueue::QueueType::Coro)); in TEST_P()
349 …EXPECT_EQ((size_t)10, getDispatcher().stats(IQueue::QueueType::IO, (int)IQueue::QueueId::Any).post… in TEST_P()
355 …EXPECT_LE((size_t)0, getDispatcher().stats(IQueue::QueueType::IO, (int)IQueue::QueueId::Any).compl… in TEST_P()
356 …EXPECT_EQ((size_t)10, getDispatcher().stats(IQueue::QueueType::IO, (int)IQueue::QueueId::Any).comp… in TEST_P()
368 …EXPECT_EQ((size_t)0, getDispatcher().stats(IQueue::QueueType::IO, (int)IQueue::QueueId::Any).error… in TEST_P()
374 …EXPECT_EQ((size_t)0, getDispatcher().stats(IQueue::QueueType::IO, (int)IQueue::QueueId::Any).highP… in TEST_P()
380 EXPECT_EQ((size_t)0, getDispatcher().size(IQueue::QueueType::IO)); in TEST_P()
[all …]
|
| /dports/textproc/jade/jade-1.2.1/include/ |
| H A D | IQueue.h | 46 class IQueue : private IQueueBase {
48 IQueue() { } in IQueue() function
49 ~IQueue() { clear(); } in ~IQueue()
54 void swap(IQueue<T> &to) { IQueueBase::swap(to); } in swap()
|
| H A D | IQueue.cxx | 12 void IQueue<T>::clear() in clear()
|
| /dports/textproc/opensp/OpenSP-1.5.2/include/ |
| H A D | IQueue.h | 46 class IQueue : private IQueueBase {
48 IQueue() { } in IQueue() function
49 ~IQueue() { clear(); } in ~IQueue()
54 void swap(IQueue<T> &to) { IQueueBase::swap(to); } in swap()
|
| /dports/devel/quantum/quantum-2.2/quantum/ |
| H A D | quantum_dispatcher.h | 326 size_t size(IQueue::QueueType type = IQueue::QueueType::All,
327 int queueId = (int)IQueue::QueueId::All) const;
336 bool empty(IQueue::QueueType type = IQueue::QueueType::All,
337 int queueId = (int)IQueue::QueueId::All) const;
373 QueueStatistics stats(IQueue::QueueType type = IQueue::QueueType::All,
374 int queueId = (int)IQueue::QueueId::All);
|
| H A D | quantum_dispatcher_core.h | 54 size_t size(IQueue::QueueType type, int queueId) const;
56 bool empty(IQueue::QueueType type, int queueId) const;
58 QueueStatistics stats(IQueue::QueueType type, int queueId);
|
| /dports/textproc/jade/jade-1.2.1/nsgmls/ |
| H A D | nsgmls_inst.cxx | 85 #pragma define_template IQueue<LinkRulePi>
88 #pragma define(IQueue<LinkRulePi>)
91 template class IQueue<LinkRulePi>;
93 typedef IQueue<LinkRulePi> Dummy_4;
|
| H A D | nsgmls_inst.m4 | 13 #include "IQueue.h"
28 __instantiate(IQueue<LinkRulePi>)
|
| /dports/textproc/opensp/OpenSP-1.5.2/nsgmls/ |
| H A D | nsgmls_inst.cxx | 85 #pragma define_template IQueue<LinkRulePi>
88 #pragma define(IQueue<LinkRulePi>)
91 template class IQueue<LinkRulePi>;
93 typedef IQueue<LinkRulePi> Dummy_4;
|
| H A D | nsgmls_inst.m4 | 13 #include "IQueue.h"
28 __instantiate(IQueue<LinkRulePi>)
|
| /dports/textproc/jade/jade-1.2.1/lib/ |
| H A D | EventQueue.h | 14 class EventQueue : public EventHandler, public IQueue<Event> {
39 IQueue<Event>::append(event); in append()
|
| H A D | parser_inst.cxx | 665 #pragma define_template IQueue<MessageEvent>
668 #pragma define(IQueue<MessageEvent>)
671 template class IQueue<MessageEvent>;
673 typedef IQueue<MessageEvent> Dummy_45;
678 #pragma define_template IQueue<Event>
681 #pragma define(IQueue<Event>)
684 template class IQueue<Event>;
686 typedef IQueue<Event> Dummy_46;
|
| /dports/textproc/opensp/OpenSP-1.5.2/lib/ |
| H A D | EventQueue.h | 14 class EventQueue : public EventHandler, public IQueue<Event> {
39 IQueue<Event>::append(event); in append()
|
| H A D | parser_inst.cxx | 665 #pragma define_template IQueue<MessageEvent>
668 #pragma define(IQueue<MessageEvent>)
671 template class IQueue<MessageEvent>;
673 typedef IQueue<MessageEvent> Dummy_45;
678 #pragma define_template IQueue<Event>
681 #pragma define(IQueue<Event>)
684 template class IQueue<Event>;
686 typedef IQueue<Event> Dummy_46;
|
| /dports/devel/quantum/quantum-2.2/quantum/util/impl/ |
| H A D | quantum_sequencer_impl.h | 44 …if (_controllerQueueId <= (int)IQueue::QueueId::Any || _controllerQueueId >= _dispatcher.getNumCor… in Sequencer()
66 (int)IQueue::QueueId::Any, in enqueue()
89 if (queueId < (int)IQueue::QueueId::Any) in enqueue()
121 (int)IQueue::QueueId::Any, in enqueue()
144 if (queueId < (int)IQueue::QueueId::Any) in enqueue()
173 (int)IQueue::QueueId::Any, in enqueueAll()
194 if (queueId < (int)IQueue::QueueId::Any) in enqueueAll()
|
| /dports/textproc/jade/jade-1.2.1/style/ |
| H A D | style_inst.cxx | 535 #pragma define_template IQueue<SaveFOTBuilder>
538 #pragma define(IQueue<SaveFOTBuilder>)
541 template class IQueue<SaveFOTBuilder>; variable
543 typedef IQueue<SaveFOTBuilder> Dummy_35;
548 #pragma define_template NCVector<IQueue<SaveFOTBuilder> >
551 #pragma define(NCVector<IQueue<SaveFOTBuilder> >)
554 template class NCVector<IQueue<SaveFOTBuilder> >;
556 typedef NCVector<IQueue<SaveFOTBuilder> > Dummy_36;
|
| H A D | ProcessContext.h | 83 IQueue<SaveFOTBuilder> saveQueue;
134 NCVector<IQueue<SaveFOTBuilder> > principalPortSaveQueues_;
|
| /dports/textproc/openjade/openjade-1.3.3-pre1/jade/ |
| H A D | MifFOTBuilder_inst.m4 | 5 #include "IQueue.h"
24 __instantiate(IQueue<MifFOTBuilder::DisplaySpaceInfo>)
|
| /dports/textproc/jade/jade-1.2.1/jade/ |
| H A D | MifFOTBuilder_inst.m4 | 5 #include "IQueue.h"
24 __instantiate(IQueue<MifFOTBuilder::DisplaySpaceInfo>)
|
| /dports/textproc/openjade/openjade-1.3.3-pre1/style/ |
| H A D | ProcessContext.h | 85 IQueue<SaveFOTBuilder> saveQueue;
136 NCVector<IQueue<SaveFOTBuilder> > principalPortSaveQueues_;
|
| /dports/cad/zcad/zcad-8b8a693/cad_source/other/AGraphLaz/Vectors/ |
| H A D | IQueue.pas | 3 unit IQueue; unit
|