Home
last modified time | relevance | path

Searched refs:messageQueue (Results 1 – 6 of 6) sorted by relevance

/external/nist-sip/java/gov/nist/javax/sip/stack/
DUDPMessageProcessor.java67 protected LinkedList messageQueue; field in UDPMessageProcessor
103 this.messageQueue = new LinkedList(); in UDPMessageProcessor()
204 if ( this.messageQueue.size() >= HIGHWAT) { in run()
211 … } else if ( this.messageQueue.size() > LOWAT && this .messageQueue.size() < HIGHWAT ) { in run()
213 … float threshold = ((float)(messageQueue.size() - LOWAT))/ ((float)(HIGHWAT - LOWAT)); in run()
238 synchronized (this.messageQueue) { in run()
240 this.messageQueue.add(packet); in run()
241 this.messageQueue.notify(); in run()
255 synchronized (this.messageQueue) { in run()
256 this.messageQueue.notifyAll(); in run()
[all …]
DUDPMessageChannel.java258 synchronized (((UDPMessageProcessor) messageProcessor).messageQueue) { in run()
259 while (((UDPMessageProcessor) messageProcessor).messageQueue in run()
278 ((UDPMessageProcessor) messageProcessor).messageQueue in run()
286 packet = (DatagramPacket) ((UDPMessageProcessor) messageProcessor).messageQueue in run()
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/
DJSDispatcher.kt30 internal val messageQueue = ScheduledMessageQueue() in <lambda>() constant in kotlinx.coroutines.SetTimeoutBasedDispatcher
35 messageQueue.enqueue(block) in <lambda>()
52 process.nextTick(messageQueue.processQueue) in scheduleQueueProcessing()
58 setTimeout(messageQueue.processQueue, 0) in scheduleQueueProcessing()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java719 InputStream message = serverStreamListener.messageQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in basicStream()
732 assertNull("no additional message expected", serverStreamListener.messageQueue.poll()); in basicStream()
771 message = clientStreamListener.messageQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); in basicStream()
796 assertNull("no additional message expected", clientStreamListener.messageQueue.poll()); in basicStream()
1257 int serverReceived = verifyMessageCountAndClose(serverStreamListener.messageQueue, 1); in flowControlPushBack()
1281 int clientReceived = verifyMessageCountAndClose(clientStreamListener.messageQueue, 1); in flowControlPushBack()
1286 clientReceived += verifyMessageCountAndClose(clientStreamListener.messageQueue, 3); in flowControlPushBack()
1287 serverReceived += verifyMessageCountAndClose(serverStreamListener.messageQueue, 3); in flowControlPushBack()
1293 verifyMessageCountAndClose(clientStreamListener.messageQueue, serverSent - clientReceived); in flowControlPushBack()
1295 verifyMessageCountAndClose(serverStreamListener.messageQueue, clientSent - serverReceived); in flowControlPushBack()
[all …]
/external/webrtc/examples/objc/AppRTCMobile/
DARDAppClient+Internal.h31 @property(nonatomic, strong) NSMutableArray *messageQueue;
DARDAppClient.m123 @synthesize messageQueue = _messageQueue;
281 [strongSelf.messageQueue insertObject:message atIndex:0];
283 [strongSelf.messageQueue addObject:message];