| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| UDPMessageProcessor.java | 67 protected LinkedList messageQueue;
103 this.messageQueue = new LinkedList();
204 if ( this.messageQueue.size() >= HIGHWAT) {
211 } else if ( this.messageQueue.size() > LOWAT && this .messageQueue.size() < HIGHWAT ) {
213 float threshold = ((float)(messageQueue.size() - LOWAT))/ ((float)(HIGHWAT - LOWAT));
233 // synchronizing on the messageQueue member is that it is
238 synchronized (this.messageQueue) {
240 this.messageQueue.add(packet);
241 this.messageQueue.notify()
[all...] |
| UDPMessageChannel.java | 258 synchronized (((UDPMessageProcessor) messageProcessor).messageQueue) {
259 while (((UDPMessageProcessor) messageProcessor).messageQueue
278 ((UDPMessageProcessor) messageProcessor).messageQueue
286 packet = (DatagramPacket) ((UDPMessageProcessor) messageProcessor).messageQueue
[all...] |
| /frameworks/base/core/jni/ |
| android_view_DisplayEventReceiver.cpp | 50 jobject receiverWeak, const sp<MessageQueue>& messageQueue, jint vsyncSource);
59 sp<MessageQueue> mMessageQueue;
68 jobject receiverWeak, const sp<MessageQueue>& messageQueue, jint vsyncSource) :
69 DisplayEventDispatcher(messageQueue->getLooper(),
72 mMessageQueue(messageQueue) {
118 sp<MessageQueue> messageQueue = android_os_MessageQueue_getMessageQueue(env, messageQueueObj);
119 if (messageQueue == NULL)
[all...] |
| android_app_NativeActivity.cpp | 140 if (messageQueue != NULL && mainWorkRead >= 0) {
141 messageQueue->getLooper()->removeFd(mainWorkRead);
178 sp<MessageQueue> messageQueue;
237 code->messageQueue->raiseAndClearException(code->env, "finish");
242 code->messageQueue->raiseAndClearException(code->env, "setWindowFormat");
247 code->messageQueue->raiseAndClearException(code->env, "setWindowFlags");
252 code->messageQueue->raiseAndClearException(code->env, "showIme");
257 code->messageQueue->raiseAndClearException(code->env, "hideIme");
273 jobject messageQueue, jstring internalDataDir, jstring obbDir
[all...] |
| android_view_InputEventSender.cpp | 56 const sp<MessageQueue>& messageQueue);
69 sp<MessageQueue> mMessageQueue;
84 const sp<MessageQueue>& messageQueue) :
86 mInputPublisher(inputChannel), mMessageQueue(messageQueue),
248 sp<MessageQueue> messageQueue = android_os_MessageQueue_getMessageQueue(env, messageQueueObj);
249 if (messageQueue == NULL) {
250 jniThrowRuntimeException(env, "MessageQueue is not initialized.")
[all...] |
| android_view_InputEventReceiver.cpp | 56 const sp<MessageQueue>& messageQueue);
75 sp<MessageQueue> mMessageQueue;
93 const sp<MessageQueue>& messageQueue) :
95 mInputConsumer(inputChannel), mMessageQueue(messageQueue),
348 sp<MessageQueue> messageQueue = android_os_MessageQueue_getMessageQueue(env, messageQueueObj);
349 if (messageQueue == NULL) {
350 jniThrowRuntimeException(env, "MessageQueue is not initialized.")
[all...] |
| android_view_InputQueue.cpp | 199 sp<MessageQueue> messageQueue = android_os_MessageQueue_getMessageQueue(env, jMsgQueue);
200 if (messageQueue == NULL) {
201 jniThrowRuntimeException(env, "MessageQueue is not initialized.");
204 sp<InputQueue> queue = InputQueue::createQueue(queueWeak, messageQueue->getLooper());
252 { "nativeInit", "(Ljava/lang/ref/WeakReference;Landroid/os/MessageQueue;)J",
|
| android_hardware_SensorManager.cpp | 295 sp<MessageQueue> mMessageQueue;
301 const sp<MessageQueue>& messageQueue,
305 mMessageQueue = messageQueue;
435 sp<MessageQueue> messageQueue = android_os_MessageQueue_getMessageQueue(env, msgQ);
436 if (messageQueue == NULL) {
437 jniThrowRuntimeException(env, "MessageQueue is not initialized.");
441 sp<Receiver> receiver = new Receiver(queue, messageQueue, eventQWeak);
521 "(JLjava/lang/ref/WeakReference;Landroid/os/MessageQueue;Ljava/lang/String;ILjava/lang/String;)J"
[all...] |
| android_view_ThreadedRenderer.cpp | 70 jfieldID messageQueue;
545 observer, gFrameMetricsObserverClassInfo.messageQueue);
612 sp<MessageQueue> mMessageQueue;
[all...] |
| /packages/apps/Dialer/java/com/android/dialer/simulator/impl/ |
| RttChatBot.java | 83 private final List<String> messageQueue = new ArrayList<>();
120 if (messageQueue.isEmpty()) {
122 messageQueue.add(text);
124 currentTypingMessage = messageQueue.remove(0);
|
| /packages/apps/Dialer/java/com/android/dialer/persistentlog/ |
| PersistentLogger.java | 64 private static final LinkedBlockingQueue<byte[]> messageQueue = new LinkedBlockingQueue<>();
78 if (messageQueue.isEmpty()) {
83 messageQueue.drainTo(messages);
110 messageQueue.add(data);
|
| /frameworks/base/core/java/android/view/ |
| DisplayEventReceiver.java | 20 import android.os.MessageQueue;
63 private MessageQueue mMessageQueue;
66 MessageQueue messageQueue, int vsyncSource);
|
| InputEventSender.java | 20 import android.os.MessageQueue;
41 private MessageQueue mMessageQueue;
44 InputChannel inputChannel, MessageQueue messageQueue);
|
| InputEventReceiver.java | 20 import android.os.MessageQueue;
42 private MessageQueue mMessageQueue;
48 InputChannel inputChannel, MessageQueue messageQueue);
|
| InputQueue.java | 20 import android.os.MessageQueue;
44 MessageQueue messageQueue);
|
| /test/vti/dashboard/src/main/java/com/android/vts/job/ |
| VtsInactivityJobServlet.java | 169 List<Message> messageQueue = new ArrayList<>();
177 notifyIfInactive(status, lastRunTime, link, emails, messageQueue);
178 if (messageQueue.size() > 0) {
179 EmailHelper.sendAll(messageQueue);
|
| VtsCoverageAlertJobServlet.java | 311 List<Message> messageQueue = new ArrayList<>();
314 newStatus = getTestCoverageStatus(status, testRunKey, link, emails, messageQueue);
335 EmailHelper.sendAll(messageQueue);
|
| VtsAlertJobServlet.java | 533 List<Message> messageQueue = new ArrayList<>();
542 getTestStatus(testRuns, link, failedTestcaseMap, testAcks, emails, messageQueue);
562 EmailHelper.sendAll(messageQueue);
|
| /external/webrtc/webrtc/examples/objc/AppRTCDemo/ |
| ARDAppClient+Internal.h | 33 @property(nonatomic, strong) NSMutableArray *messageQueue;
|
| ARDAppClient.m | 106 @synthesize messageQueue = _messageQueue;
251 [strongSelf.messageQueue insertObject:message atIndex:0];
253 [strongSelf.messageQueue addObject:message];
|
| /frameworks/base/services/core/jni/ |
| com_android_server_hdmi_HdmiCecController.cpp | 344 sp<MessageQueue> messageQueue =
350 messageQueue->getLooper());
437 "(Lcom/android/server/hdmi/HdmiCecController;Landroid/os/MessageQueue;)J",
|
| com_android_server_tv_TvInputHal.cpp | 587 sp<MessageQueue> messageQueue =
589 return (jlong)JTvInputHal::createInstance(env, thiz, messageQueue->getLooper());
650 { "nativeOpen", "(Landroid/os/MessageQueue;)J",
|
| com_android_server_input_InputManagerService.cpp | [all...] |
| /frameworks/base/services/core/java/com/android/server/hdmi/ |
| HdmiCecController.java | 24 import android.os.MessageQueue;
672 private static native long nativeInit(HdmiCecController handler, MessageQueue messageQueue);
|
| /frameworks/base/services/core/java/com/android/server/input/ |
| InputManagerService.java | 77 import android.os.MessageQueue;
189 Context context, MessageQueue messageQueue);
[all...] |
