/dports/lang/spidermonkey78/firefox-78.9.0/dom/midi/ |
H A D | MIDIPlatformService.cpp | 79 msgQueue->Add(aMsgs); in QueueMessages() 101 MIDIMessageQueue* msgQueue = in Clear() local 103 if (msgQueue) { in Clear() 104 msgQueue->Clear(); in Clear() 157 MIDIMessageQueue* msgQueue = in Close() local 159 if (msgQueue) { in Close() 160 msgQueue->ClearAfterNow(); in Close() 235 MIDIMessageQueue* msgQueue; in GetMessages() local 236 if (!mMessageQueues.Get(aPortId, &msgQueue)) { in GetMessages() 239 msgQueue->GetMessages(aMsgs); in GetMessages() [all …]
|
/dports/lang/spidermonkey60/firefox-60.9.0/dom/midi/ |
H A D | MIDIPlatformService.cpp | 79 msgQueue->Add(aMsgs); in QueueMessages() 101 MIDIMessageQueue* msgQueue = in Clear() local 103 if (msgQueue) { in Clear() 104 msgQueue->Clear(); in Clear() 157 MIDIMessageQueue* msgQueue = in Close() local 159 if (msgQueue) { in Close() 160 msgQueue->ClearAfterNow(); in Close() 235 MIDIMessageQueue* msgQueue; in GetMessages() local 236 if (!mMessageQueues.Get(aPortId, &msgQueue)) { in GetMessages() 239 msgQueue->GetMessages(aMsgs); in GetMessages() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/dom/midi/ |
H A D | MIDIPlatformService.cpp | 85 msgQueue->Add(aMsgs); in QueueMessages() 107 MIDIMessageQueue* msgQueue = in Clear() local 109 if (msgQueue) { in Clear() 110 msgQueue->Clear(); in Clear() 163 MIDIMessageQueue* msgQueue = in Close() local 165 if (msgQueue) { in Close() 166 msgQueue->ClearAfterNow(); in Close() 241 MIDIMessageQueue* msgQueue; in GetMessages() local 242 if (!mMessageQueues.Get(aPortId, &msgQueue)) { in GetMessages() 245 msgQueue->GetMessages(aMsgs); in GetMessages() [all …]
|
/dports/www/firefox/firefox-99.0/dom/midi/ |
H A D | MIDIPlatformService.cpp | 89 msgQueue->Add(aMsgs); in QueueMessages() 112 MIDIMessageQueue* msgQueue = in Clear() local 114 if (msgQueue) { in Clear() 115 msgQueue->Clear(); in Clear() 168 MIDIMessageQueue* msgQueue = in Close() local 170 if (msgQueue) { in Close() 171 msgQueue->ClearAfterNow(); in Close() 243 MIDIMessageQueue* msgQueue; in GetMessages() local 244 if (!mMessageQueues.Get(aPortId, &msgQueue)) { in GetMessages() 247 msgQueue->GetMessages(aMsgs); in GetMessages() [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/dom/midi/ |
H A D | MIDIPlatformService.cpp | 85 msgQueue->Add(aMsgs); in QueueMessages() 107 MIDIMessageQueue* msgQueue = in Clear() local 109 if (msgQueue) { in Clear() 110 msgQueue->Clear(); in Clear() 163 MIDIMessageQueue* msgQueue = in Close() local 165 if (msgQueue) { in Close() 166 msgQueue->ClearAfterNow(); in Close() 241 MIDIMessageQueue* msgQueue; in GetMessages() local 242 if (!mMessageQueues.Get(aPortId, &msgQueue)) { in GetMessages() 245 msgQueue->GetMessages(aMsgs); in GetMessages() [all …]
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
H A D | behavior_asynclogger.go | 47 msgQueue *list.List member 55 asnLogger.msgQueue = list.New() 106 for asnLogger.msgQueue.Len() > 0 { 112 if asnLogger.msgQueue.Len() > 0 { 113 backElement := asnLogger.msgQueue.Front() 116 asnLogger.msgQueue.Remove(backElement) 129 if asnLogger.msgQueue.Len() >= MaxQueueSize { 136 asnLogger.msgQueue.PushBack(queueItem)
|
H A D | behavior_adaptivelogger.go | 93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() { 98 return true, asnAdaptiveLogger.msgQueue.Len() 102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
|
H A D | behavior_asynclooplogger.go | 49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
H A D | behavior_asynclogger.go | 47 msgQueue *list.List member 55 asnLogger.msgQueue = list.New() 106 for asnLogger.msgQueue.Len() > 0 { 112 if asnLogger.msgQueue.Len() > 0 { 113 backElement := asnLogger.msgQueue.Front() 116 asnLogger.msgQueue.Remove(backElement) 129 if asnLogger.msgQueue.Len() >= MaxQueueSize { 136 asnLogger.msgQueue.PushBack(queueItem)
|
H A D | behavior_adaptivelogger.go | 93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() { 98 return true, asnAdaptiveLogger.msgQueue.Len() 102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
|
H A D | behavior_asynclooplogger.go | 49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
H A D | behavior_asynclogger.go | 47 msgQueue *list.List 55 asnLogger.msgQueue = list.New() 106 for asnLogger.msgQueue.Len() > 0 { 112 if asnLogger.msgQueue.Len() > 0 { 113 backElement := asnLogger.msgQueue.Front() 116 asnLogger.msgQueue.Remove(backElement) 129 if asnLogger.msgQueue.Len() >= MaxQueueSize { 136 asnLogger.msgQueue.PushBack(queueItem)
|
H A D | behavior_adaptivelogger.go | 93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() { 98 return true, asnAdaptiveLogger.msgQueue.Len() 102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
|
H A D | behavior_asynclooplogger.go | 49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/ |
H A D | behavior_asynclogger.go | 47 msgQueue *list.List member 55 asnLogger.msgQueue = list.New() 106 for asnLogger.msgQueue.Len() > 0 { 112 if asnLogger.msgQueue.Len() > 0 { 113 backElement := asnLogger.msgQueue.Front() 116 asnLogger.msgQueue.Remove(backElement) 129 if asnLogger.msgQueue.Len() >= MaxQueueSize { 136 asnLogger.msgQueue.PushBack(queueItem)
|
H A D | behavior_adaptivelogger.go | 93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() { 98 return true, asnAdaptiveLogger.msgQueue.Len() 102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
|
/dports/converters/wkhtmltopdf/qt-5db36ec/src/gui/embedded/ |
H A D | qtransportauth_qws.cpp | 815 QBuffer cmdBuf( msgQueue ); in analyze() 823 *msgQueue = msgQueue->mid( sizeof(int) ); in analyze() 850 Q_UNUSED(msgQueue); in analyze() 1005 if ( msgQueue.size() == 0 ) in readData() 1010 msgQueue.size() > 500 ? 500 : msgQueue.size() ); in readData() 1017 msgQueue = msgQueue.mid( bytes ); in readData() 1043 msgQueue.append( msg.bytes() ); in recvReadyRead() 1056 msgQueue.size() > 500 ? 500 : msgQueue.size() ); in recvReadyRead() 1069 if ( !QTransportAuth::getInstance()->authFromMessage( *d, msgQueue, msgQueue.size() )) in recvReadyRead() 1087 msgQueue = msgQueue.mid( QSXE_HEADER_LEN ); in recvReadyRead() [all …]
|
H A D | qtransportauth_qws.h | 233 QByteArray msgQueue; variable 252 return msgQueue.isEmpty(); in atEnd() 265 return msgQueue.size(); in bytesToWrite() 270 return msgQueue; in buffer()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/ |
H A D | bppsendthread.cpp | 68 return ((msgQueue.size() < sizeThreshold && currentByteSize < maxByteSize) in okToProceed() 69 || msgQueue.size() < 3) && !die; in okToProceed() 83 msgQueue.push(msg); in sendResult() 137 msgQueue.push(msgs[i]); in sendResults() 183 if (msgQueue.empty() && !die) in mainLoop() 191 msgCount = (msgQueue.size() > msgCap ? msgCap : msgQueue.size()); in mainLoop() 195 msg[i] = msgQueue.front(); in mainLoop() 196 msgQueue.pop(); in mainLoop()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/primitives/primproc/ |
H A D | bppsendthread.cpp | 68 return ((msgQueue.size() < sizeThreshold && currentByteSize < maxByteSize) in okToProceed() 69 || msgQueue.size() < 3) && !die; in okToProceed() 83 msgQueue.push(msg); in sendResult() 137 msgQueue.push(msgs[i]); in sendResults() 183 if (msgQueue.empty() && !die) in mainLoop() 191 msgCount = (msgQueue.size() > msgCap ? msgCap : msgQueue.size()); in mainLoop() 195 msg[i] = msgQueue.front(); in mainLoop() 196 msgQueue.pop(); in mainLoop()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/ui/src/engine/ |
H A D | index.ts | 24 const msgQueue: MessageEvent[] = []; constant 26 msgQueue.push(msg); 38 while (msg = msgQueue.shift()) {
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/ui/src/engine/ |
H A D | index.ts | 24 const msgQueue: MessageEvent[] = []; constant 26 msgQueue.push(msg); 38 while (msg = msgQueue.shift()) {
|
/dports/benchmarks/py-zopkio/Zopkio-0.2.5/test/samples/producer_consumer/Producer/src/ |
H A D | IntegerProducer.java | 39 private static LinkedList<Integer> msgQueue; field in IntegerProducer 43 msgQueue = new LinkedList<Integer>(); in main() 50 msgQueue.add(new Integer(i)); in main() 61 Integer msg = msgQueue.remove(); in main()
|
/dports/games/spring/spring_98.0/rts/System/Net/ |
H A D | UDPConnection.cpp | 355 if (ahead < msgQueue.size()) in Peek() 356 return msgQueue[ahead]; in Peek() 367 if (!msgQueue.empty()) { in GetData() 368 boost::shared_ptr<const RawPacket> msg = msgQueue.front(); in GetData() 369 msgQueue.pop_front(); in GetData() 385 if (!msgQueue.empty()) { in GetData() 386 boost::shared_ptr<const RawPacket> msg = msgQueue.front(); in GetData() 387 msgQueue.pop_front(); in GetData() 399 if (index < msgQueue.size()) { in DeleteBufferPacketAt() 400 msgQueue.erase(msgQueue.begin() + index); in DeleteBufferPacketAt() [all …]
|
H A D | UDPConnection.h | 89 bool HasIncomingData() const { return !msgQueue.empty(); } in HasIncomingData() 100 unsigned int GetPacketQueueSize() const { return msgQueue.size(); } in GetPacketQueueSize() 188 std::deque< boost::shared_ptr<const RawPacket> > msgQueue; variable
|