Home
last modified time | relevance | path

Searched refs:msgQueue (Results 1 – 25 of 53) sorted by relevance

123

/dports/lang/spidermonkey78/firefox-78.9.0/dom/midi/
H A DMIDIPlatformService.cpp79 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 DMIDIPlatformService.cpp79 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 DMIDIPlatformService.cpp85 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 DMIDIPlatformService.cpp89 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 DMIDIPlatformService.cpp85 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 Dbehavior_asynclogger.go47 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 Dbehavior_adaptivelogger.go93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() {
98 return true, asnAdaptiveLogger.msgQueue.Len()
102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
H A Dbehavior_asynclooplogger.go49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/
H A Dbehavior_asynclogger.go47 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 Dbehavior_adaptivelogger.go93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() {
98 return true, asnAdaptiveLogger.msgQueue.Len()
102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
H A Dbehavior_asynclooplogger.go49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/
H A Dbehavior_asynclogger.go47 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 Dbehavior_adaptivelogger.go93 for asnAdaptiveLogger.msgQueue.Len() == 0 && !asnAdaptiveLogger.Closed() {
98 return true, asnAdaptiveLogger.msgQueue.Len()
102 return false, asnAdaptiveLogger.msgQueue.Len() - 1
H A Dbehavior_asynclooplogger.go49 for asnLoopLogger.msgQueue.Len() == 0 && !asnLoopLogger.Closed() {
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/cihub/seelog/
H A Dbehavior_asynclogger.go47 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 Dbehavior_adaptivelogger.go93 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 Dqtransportauth_qws.cpp815 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 Dqtransportauth_qws.h233 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 Dbppsendthread.cpp68 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 Dbppsendthread.cpp68 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 Dindex.ts24 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 Dindex.ts24 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 DIntegerProducer.java39 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 DUDPConnection.cpp355 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 DUDPConnection.h89 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

123