| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netschedule/ |
| H A D | ns_queue_param_accessor.hpp | 46 m_Queue(queue), m_Guard(queue.m_ParamLock) in CQueueParamAccessor()
50 { return m_Queue.m_FailedRetries; } in GetFailedRetries()
53 { return m_Queue.m_MaxInputSize; } in GetMaxInputSize()
56 { return m_Queue.m_MaxOutputSize; } in GetMaxOutputSize()
91 case 0: return to_string(m_Queue.m_Timeout.Sec()); in GetParamValue()
96 case 5: return to_string(m_Queue.m_DumpBufferSize); in GetParamValue()
99 case 8: return to_string(m_Queue.m_FailedRetries); in GetParamValue()
103 case 12: return to_string(m_Queue.m_MaxInputSize); in GetParamValue()
104 case 13: return to_string(m_Queue.m_MaxOutputSize); in GetParamValue()
106 case 15: return m_Queue.m_SubmHosts.Print("", ","); in GetParamValue()
[all …]
|
| /dports/lang/mono-basic/mono-basic-4.7/vbnc/rt/source/ |
| H A D | TestExecutor.vb | 63 Return m_Queue
75 Return m_Queue.Count
103 SyncLock m_Queue
134 SyncLock m_Queue
152 SyncLock m_Queue
183 SyncLock m_Queue
226 SyncLock m_Queue
239 SyncLock m_Queue
241 m_Queue.Clear()
250 SyncLock m_Queue
[all …]
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/objtools/data_loaders/genbank/impl/ |
| H A D | gbload_util.hpp | 266 if ( !m_Queue.empty() && m_Queue.begin()->first != key ) { in Get()
267 m_Queue.clear(); in Get()
270 if ( m_Queue.empty() ) { in Get()
292 m_Queue.erase(ins.first->second); in Get()
295 m_Queue.splice(m_Queue.begin(), m_Queue, ins.first->second); in Get()
299 _ASSERT(m_Queue.begin()->first == key); in Get()
300 ins.first->second = m_Queue.begin(); in Get()
306 return m_Queue.begin()->second; in Get()
318 m_Queue.clear(); in Clear()
336 m_Queue.pop_back(); in x_GC()
[all …]
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/objtools/data_loaders/genbank/impl/ |
| H A D | gbload_util.hpp | 266 if ( !m_Queue.empty() && m_Queue.begin()->first != key ) { in Get()
267 m_Queue.clear(); in Get()
270 if ( m_Queue.empty() ) { in Get()
292 m_Queue.erase(ins.first->second); in Get()
295 m_Queue.splice(m_Queue.begin(), m_Queue, ins.first->second); in Get()
299 _ASSERT(m_Queue.begin()->first == key); in Get()
300 ins.first->second = m_Queue.begin(); in Get()
306 return m_Queue.begin()->second; in Get()
318 m_Queue.clear(); in Clear()
336 m_Queue.pop_back(); in x_GC()
[all …]
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/tools/mediaserver/upnpsdk/Platinum/Source/Core/ |
| H A D | PltTaskManager.cpp | 47 m_Queue(NULL), in PLT_TaskManager()
101 if (m_Queue) { in Abort()
103 while(NPT_SUCCEEDED(m_Queue->Pop(val, 0))) delete val; in Abort()
105 delete m_Queue; in Abort()
106 m_Queue = NULL; in Abort()
159 if (!m_Queue) { in AddTask()
160 m_Queue = new NPT_Queue<int>(m_MaxTasks); in AddTask()
165 result = m_Queue->Push(val, 20); in AddTask()
214 if (m_Queue) { in RemoveTask()
216 result = m_Queue->Pop(val, 100); in RemoveTask()
|
| /dports/multimedia/kodi/xbmc-19.3-Matrix/lib/libUPnP/Platinum/Source/Core/ |
| H A D | PltTaskManager.cpp | 47 m_Queue(NULL), in PLT_TaskManager()
101 if (m_Queue) { in Abort()
103 while(NPT_SUCCEEDED(m_Queue->Pop(val, 0))) delete val; in Abort()
105 delete m_Queue; in Abort()
106 m_Queue = NULL; in Abort()
159 if (!m_Queue) { in AddTask()
160 m_Queue = new NPT_Queue<int>(m_MaxTasks); in AddTask()
165 result = m_Queue->Push(val, 20); in AddTask()
214 if (m_Queue) { in RemoveTask()
216 result = m_Queue->Pop(val, 100); in RemoveTask()
|
| /dports/net/nepenthes/nepenthes-0.2.2/modules/dnsresolve-adns/ |
| H A D | dnsresolve-adns.cpp | 66 m_Queue = 0; in DNSResolverADNS()
105 if (m_Queue == 0) in resolveDNS()
115 m_Queue++; in resolveDNS()
122 if (m_Queue == 0) in resolveTXT()
132 m_Queue++; in resolveTXT()
174 logSpam("%i DNS Resolves in Queue\n", m_Queue); in callBack()
188 m_Queue--; in callBack()
190 logDebug("resolved dns %s (%i left) \n", query->getDNS().c_str(),m_Queue); in callBack()
209 m_Queue--; in callBack()
210 logWarn("resolving %s failed (%i left) \n", answer->cname, m_Queue); in callBack()
[all …]
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/objmgr/impl/ |
| H A D | scope_info.hpp | 107 _ASSERT(m_Queue.size() == m_Index.size()); in Contains()
115 _ASSERT(m_Queue.size() == m_Index.size()); in Get()
119 m_Queue.erase(iter->second); in Get()
128 _ASSERT(m_Queue.size() == m_Index.size()); in Erase()
131 m_Queue.erase(iter->second); in Erase()
143 m_Queue.insert(m_Queue.end(), TQueueValue(key, value)); in Put()
154 m_Queue.pop_front(); in Put()
165 m_Queue.insert(m_Queue.end(), TQueueValue(key, value)); in Put()
176 m_Queue.pop_front(); in Put()
188 m_Queue.clear(); in Clear()
[all …]
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/objmgr/impl/ |
| H A D | scope_info.hpp | 107 _ASSERT(m_Queue.size() == m_Index.size()); in Contains()
115 _ASSERT(m_Queue.size() == m_Index.size()); in Get()
119 m_Queue.erase(iter->second); in Get()
128 _ASSERT(m_Queue.size() == m_Index.size()); in Erase()
131 m_Queue.erase(iter->second); in Erase()
143 m_Queue.insert(m_Queue.end(), TQueueValue(key, value)); in Put()
154 m_Queue.pop_front(); in Put()
165 m_Queue.insert(m_Queue.end(), TQueueValue(key, value)); in Put()
176 m_Queue.pop_front(); in Put()
188 m_Queue.clear(); in Clear()
[all …]
|
| /dports/graphics/digikam/digikam-7.4.0/core/dplugins/generic/tools/mediaserver/upnpsdk/Neptune/Source/Core/ |
| H A D | NptMessaging.h | 181 NPT_MessageReceiver() : m_Queue(NULL), m_Handler(NULL) {} in NPT_MessageReceiver()
183 m_Queue(NULL), m_Handler(handler) {} in NPT_MessageReceiver()
185 m_Queue(queue), m_Handler(NULL) {} in NPT_MessageReceiver()
188 m_Queue(queue), m_Handler(handler) {} in NPT_MessageReceiver()
191 m_Queue = queue; in SetQueue()
199 if (m_Queue) { in PostMessage()
200 return m_Queue->QueueMessage(message, m_Handler); in PostMessage()
208 NPT_MessageQueue* m_Queue;
|
| /dports/audio/drumstick/drumstick-2.5.0/library/alsa/ |
| H A D | playthread.cpp | 70 m_Queue(nullptr), in SequencerOutputThread()
78 m_Queue = m_MidiClient->getQueue(); in SequencerOutputThread()
79 m_QueueId = m_Queue->getId(); in SequencerOutputThread()
177 m_Queue->start(); in run()
179 m_Queue->setTickPosition(last_tick); in run()
180 m_Queue->continueRunning(); in run()
195 m_Queue->clear(); in run()
205 m_Queue->stop(); in run()
|
| H A D | alsaclient.cpp | 220 m_Queue(nullptr), in MidiClientPrivate()
273 delete d->m_Queue; in ~MidiClient()
1101 return d->m_Queue; in getQueue()
1112 delete d->m_Queue; in createQueue()
1115 return d->m_Queue; in createQueue()
1128 delete d->m_Queue; in createQueue()
1131 return d->m_Queue; in createQueue()
1148 return d->m_Queue; in useQueue()
1168 return d->m_Queue; in useQueue()
1184 d->m_Queue = queue; in useQueue()
[all …]
|
| /dports/multimedia/gpac-libgpac/gpac-1.0.0/extra_lib/include/platinum/ |
| H A D | NptMessaging.h | 181 NPT_MessageReceiver() : m_Queue(NULL), m_Handler(NULL) {} in NPT_MessageReceiver()
183 m_Queue(NULL), m_Handler(handler) {} in NPT_MessageReceiver()
185 m_Queue(queue), m_Handler(NULL) {} in NPT_MessageReceiver()
188 m_Queue(queue), m_Handler(handler) {} in NPT_MessageReceiver()
191 m_Queue = queue; in SetQueue()
199 if (m_Queue) { in PostMessage()
200 return m_Queue->QueueMessage(message, m_Handler); in PostMessage()
208 NPT_MessageQueue* m_Queue;
|
| /dports/multimedia/gpac-mp4box/gpac-1.0.0/extra_lib/include/platinum/ |
| H A D | NptMessaging.h | 181 NPT_MessageReceiver() : m_Queue(NULL), m_Handler(NULL) {} in NPT_MessageReceiver()
183 m_Queue(NULL), m_Handler(handler) {} in NPT_MessageReceiver()
185 m_Queue(queue), m_Handler(NULL) {} in NPT_MessageReceiver()
188 m_Queue(queue), m_Handler(handler) {} in NPT_MessageReceiver()
191 m_Queue = queue; in SetQueue()
199 if (m_Queue) { in PostMessage()
200 return m_Queue->QueueMessage(message, m_Handler); in PostMessage()
208 NPT_MessageQueue* m_Queue;
|
| /dports/security/i2pd/i2pd-2.40.0/libi2pd/ |
| H A D | Queue.h | 32 m_Queue.push (std::move(e)); in Put()
43 m_Queue.push (std::move(it)); in Put()
87 return m_Queue.empty (); in IsEmpty()
93 return m_Queue.size (); in GetSize()
114 if (!m_Queue.empty ())
116 auto el = m_Queue.front ();
118 m_Queue.pop ();
126 std::queue<Element> m_Queue;
|
| /dports/multimedia/kodi/xbmc-19.3-Matrix/lib/libUPnP/Neptune/Source/Core/ |
| H A D | NptMessaging.h | 181 NPT_MessageReceiver() : m_Queue(NULL), m_Handler(NULL) {} in NPT_MessageReceiver()
183 m_Queue(NULL), m_Handler(handler) {} in NPT_MessageReceiver()
185 m_Queue(queue), m_Handler(NULL) {} in NPT_MessageReceiver()
188 m_Queue(queue), m_Handler(handler) {} in NPT_MessageReceiver()
191 m_Queue = queue; in SetQueue()
199 if (m_Queue) { in PostMessage()
200 return m_Queue->QueueMessage(message, m_Handler); in PostMessage()
208 NPT_MessageQueue* m_Queue;
|
| /dports/graphics/electricsheep/electricsheep-37ba0fd692d6581f8fe009ed11c9650cd8174123/client_generic/Runtime/Scripts/ |
| H A D | pq.lua | 18 return setmetatable( { m_Queue = {} }, pq_mt )
43 return self.m_Queue.right == nil
55 _M:skew_merge( self.m_Queue.right, v, self.m_Queue )
60 local r = self.m_Queue.right
62 self:skew_merge( r.left, r.right, self.m_Queue )
|
| /dports/science/InsightToolkit/ITK-5.0.1/Modules/Core/Common/include/ |
| H A D | itkLevelOrderTreeIterator.hxx | 35 m_Queue.push(start); in LevelOrderTreeIterator()
42 m_Queue.push( dynamic_cast< const TreeNodeType * >( tree->GetRoot() ) ); in LevelOrderTreeIterator()
59 m_Queue.push(start); in LevelOrderTreeIterator()
66 m_Queue.push( dynamic_cast< const TreeNodeType * >( tree->GetRoot() ) ); in LevelOrderTreeIterator()
191 if ( m_Queue.empty() ) in FindNextNodeHelp()
196 const TreeNodeType *currentNode = m_Queue.front(); in FindNextNodeHelp()
197 m_Queue.pop(); in FindNextNodeHelp()
211 m_Queue.push(child); in FindNextNodeHelp()
|
| /dports/games/0ad/0ad-0.0.23b-alpha/source/tools/atlas/GameInterface/ |
| H A D | MessagePasserImpl.cpp | 91 m_Queue.push(msg); in Add()
105 if (! m_Queue.empty()) in Retrieve()
107 msg = m_Queue.front(); in Retrieve()
108 m_Queue.pop(); in Retrieve()
131 m_Queue.push(qry); in Query()
189 return m_Queue.empty(); in IsEmpty()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/util/ |
| H A D | thread_pool_old.hpp | 267 volatile TRealQueue m_Queue; ///< The queue member in CBlockingQueue
470 { m_Queue.Withdraw(handle); } in Withdraw()
474 { return m_Queue.GetSize(); } in GetQueueSize()
516 TQueue m_Queue; member in CPoolOfThreads
704 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in Put()
772 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in GetHandle()
842 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in SetUserPriority()
972 handle.Reset(m_Pool->m_Queue.GetHandle()); in x_HandleOneRequest()
1119 if (m_Queue.IsFull()) { in HasImmediateRoom()
1129 m_Queue.WaitForHunger(0); in HasImmediateRoom()
[all …]
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/util/ |
| H A D | thread_pool_old.hpp | 267 volatile TRealQueue m_Queue; ///< The queue member in CBlockingQueue
470 { m_Queue.Withdraw(handle); } in Withdraw()
474 { return m_Queue.GetSize(); } in GetQueueSize()
516 TQueue m_Queue; member in CPoolOfThreads
704 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in Put()
772 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in GetHandle()
842 TRealQueue& q = const_cast<TRealQueue&>(m_Queue); in SetUserPriority()
972 handle.Reset(m_Pool->m_Queue.GetHandle()); in x_HandleOneRequest()
1119 if (m_Queue.IsFull()) { in HasImmediateRoom()
1129 m_Queue.WaitForHunger(0); in HasImmediateRoom()
[all …]
|
| /dports/editors/libreoffice/libreoffice-7.2.6.2/helpcompiler/source/ |
| H A D | BasCodeTagger.cxx | 21 m_Queue.push_back( m_pCurrentNode->xmlChildrenNode ); in LibXmlTreeWalker()
31 m_pCurrentNode = m_Queue.front(); in nextNode()
32 m_Queue.pop_front(); in nextNode()
38 m_Queue.push_back( m_pCurrentNode->xmlChildrenNode ); in nextNode()
44 m_Queue.pop_back(); in ignoreCurrNodesChildren()
49 return m_pCurrentNode->next == nullptr && m_Queue.empty(); in end()
|
| /dports/editors/libreoffice6/libreoffice-6.4.7.2/helpcompiler/source/ |
| H A D | BasCodeTagger.cxx | 21 m_Queue.push_back( m_pCurrentNode->xmlChildrenNode ); in LibXmlTreeWalker()
31 m_pCurrentNode = m_Queue.front(); in nextNode()
32 m_Queue.pop_front(); in nextNode()
38 m_Queue.push_back( m_pCurrentNode->xmlChildrenNode ); in nextNode()
44 m_Queue.pop_back(); in ignoreCurrNodesChildren()
49 return m_pCurrentNode->next == nullptr && m_Queue.empty(); in end()
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/connect/ |
| H A D | ncbi_usage_report.cpp | 421 if ((unsigned)m_Queue.size() >= m_MaxQueueSize) { in x_SendAsync()
436 m_Queue.push_back(job_ptr); in x_SendAsync()
473 return (unsigned)m_Queue.size(); in GetQueueSize()
491 for (auto& job : m_Queue) { in x_ClearQueue()
495 m_Queue.clear(); in x_ClearQueue()
533 if (m_Queue.empty()) { in Wait()
579 if (!m_Queue.empty()) { in x_ThreadHandler()
581 job = m_Queue.front(); in x_ThreadHandler()
582 m_Queue.pop_front(); in x_ThreadHandler()
|
| /dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/connect/ |
| H A D | ncbi_usage_report.cpp | 421 if ((unsigned)m_Queue.size() >= m_MaxQueueSize) { in x_SendAsync()
436 m_Queue.push_back(job_ptr); in x_SendAsync()
473 return (unsigned)m_Queue.size(); in GetQueueSize()
491 for (auto& job : m_Queue) { in x_ClearQueue()
495 m_Queue.clear(); in x_ClearQueue()
533 if (m_Queue.empty()) { in Wait()
579 if (!m_Queue.empty()) { in x_ThreadHandler()
581 job = m_Queue.front(); in x_ThreadHandler()
582 m_Queue.pop_front(); in x_ThreadHandler()
|