| /external/libmojo/mojo/edk/system/ |
| handle_table.cc | 18 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) {
24 auto result = handles_.insert(std::make_pair(handle, Entry(dispatcher)));
31 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
45 std::make_pair(handle, Entry(dispatchers[i].dispatcher)));
53 scoped_refptr<Dispatcher> HandleTable::GetDispatcher(MojoHandle handle) const {
57 return it->second.dispatcher;
62 scoped_refptr<Dispatcher>* dispatcher) {
69 *dispatcher = it->second.dispatcher
[all...] |
| platform_handle_dispatcher_unittest.cc | 40 scoped_refptr<PlatformHandleDispatcher> dispatcher = local
43 EXPECT_EQ(Dispatcher::Type::PLATFORM_HANDLE, dispatcher->GetType());
45 h = dispatcher->PassPlatformHandle();
59 h = dispatcher->PassPlatformHandle();
62 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close());
76 scoped_refptr<PlatformHandleDispatcher> dispatcher = local
83 EXPECT_TRUE(dispatcher->BeginTransit());
84 dispatcher->StartSerialize(&num_bytes, &num_ports, &num_handles);
91 EXPECT_TRUE(dispatcher->EndSerialize(nullptr, nullptr, handles->data()))
[all...] |
| shared_buffer_dispatcher_unittest.cc | 15 #include "mojo/edk/system/dispatcher.h"
114 scoped_refptr<SharedBufferDispatcher> dispatcher; local
117 nullptr, 100, &dispatcher));
118 ASSERT_TRUE(dispatcher);
119 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType());
123 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(
132 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(
139 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close());
141 // Check that we can still read/write to mappings after the dispatcher ha
151 scoped_refptr<SharedBufferDispatcher> dispatcher; local
273 scoped_refptr<SharedBufferDispatcher> dispatcher; local
289 scoped_refptr<SharedBufferDispatcher> dispatcher; local
[all...] |
| handle_table.h | 14 #include "mojo/edk/system/dispatcher.h"
25 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
30 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
33 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle) const;
35 scoped_refptr<Dispatcher>* dispatcher);
43 std::vector<Dispatcher::DispatcherInTransit>* dispatchers);
46 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers);
48 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers)
59 scoped_refptr<Dispatcher> dispatcher; member in struct:mojo::edk::HandleTable::Entry
[all...] |
| core.cc | 164 scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) {
194 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) {
196 return handles_.AddDispatcher(dispatcher);
200 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
210 d.dispatcher->Close();
231 scoped_refptr<Dispatcher> d;
235 if (d->GetType() == Dispatcher::Type::PLATFORM_HANDLE) {
258 scoped_refptr<SharedBufferDispatcher> dispatcher;
260 platform_buffer, &dispatcher);
364 scoped_refptr<Dispatcher> dispatcher; local
422 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); local
431 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); local
658 auto dispatcher = GetDispatcher(message_pipe_handle); local
674 auto dispatcher = GetDispatcher(message_pipe_handle); local
699 auto dispatcher = GetDispatcher(message_pipe_handle); local
1046 scoped_refptr<Dispatcher> dispatcher; local
1103 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handles[i]); local
[all...] |
| wait_set_dispatcher.cc | 20 explicit Waiter(WaitSetDispatcher* dispatcher) : dispatcher_(dispatcher) {}
27 // Removes |this| from the dispatcher's list of waiters.
44 Dispatcher::Type WaitSetDispatcher::GetType() const {
61 entry.second.dispatcher->RemoveAwakable(waiter_.get(), nullptr);
72 const scoped_refptr<Dispatcher>& dispatcher,
75 if (dispatcher == this)
83 uintptr_t dispatcher_handle = reinterpret_cast<uintptr_t>(dispatcher.get());
89 const MojoResult result = dispatcher->AddAwakable(waiter_.get(), signals
[all...] |
| wait_set_dispatcher.h | 18 #include "mojo/edk/system/dispatcher.h"
24 class MOJO_SYSTEM_IMPL_EXPORT WaitSetDispatcher : public Dispatcher {
28 // Dispatcher:
31 MojoResult AddWaitingDispatcher(const scoped_refptr<Dispatcher>& dispatcher,
35 const scoped_refptr<Dispatcher>& dispatcher) override;
58 scoped_refptr<Dispatcher> dispatcher; member in struct:mojo::edk::WaitSetDispatcher::WaitState
67 // Signal that the dispatcher indexed by |context| has been woken up wit
[all...] |
| /frameworks/base/core/java/android/speech/tts/ |
| PlaybackQueueItem.java | 11 PlaybackQueueItem(TextToSpeechService.UtteranceProgressDispatcher dispatcher,
13 mDispatcher = dispatcher;
|
| SilencePlaybackQueueItem.java | 25 SilencePlaybackQueueItem(UtteranceProgressDispatcher dispatcher,
27 super(dispatcher, callerIdentity);
|
| AudioPlaybackQueueItem.java | 38 AudioPlaybackQueueItem(UtteranceProgressDispatcher dispatcher,
41 super(dispatcher, callerIdentity);
53 final UtteranceProgressDispatcher dispatcher = getDispatcher(); local
55 dispatcher.dispatchOnStart();
62 dispatcher.dispatchOnError(TextToSpeech.ERROR_OUTPUT);
93 dispatcher.dispatchOnSuccess();
95 dispatcher.dispatchOnStop();
|
| SynthesisPlaybackQueueItem.java | 74 int audioFormat, int channelCount, UtteranceProgressDispatcher dispatcher,
76 super(dispatcher, callerIdentity);
91 final UtteranceProgressDispatcher dispatcher = getDispatcher(); local
92 dispatcher.dispatchOnStart();
95 dispatcher.dispatchOnError(TextToSpeech.ERROR_OUTPUT);
124 dispatcher.dispatchOnSuccess();
126 dispatcher.dispatchOnStop();
128 dispatcher.dispatchOnError(mStatusCode);
|
| /external/autotest/site_utils/rpm_control_system/ |
| rpm_dispatcher_unittest.py | 16 FAKE_DISPATCHER_URI = 'fake-dispatcher'
24 Simple unit tests to verify that the RPM Dispatcher properly registers with
28 queue_request is the only public method of RPM Dispatcher, however its logic
46 self.dispatcher = rpm_dispatcher.RPMDispatcher(FAKE_DISPATCHER_URI,
52 Make sure that as a dispatcher is initialized it properly registered
64 controller1 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
65 controller2 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
75 controller1 = self.dispatcher._get_rpm_controller(DUT_SAME_RPM1)
76 controller2 = self.dispatcher._get_rpm_controller(DUT_DIFFERENT_RPM)
|
| /frameworks/native/services/vr/bufferhubd/ |
| bufferhubd.cpp | 15 std::unique_ptr<android::pdx::ServiceDispatcher> dispatcher; local
37 dispatcher = android::pdx::ServiceDispatcher::Create();
38 CHECK_ERROR(!dispatcher, error, "Failed to create service dispatcher\n");
42 dispatcher->AddService(service);
49 ret = dispatcher->EnterDispatchLoop();
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| DispatcherTest.java | 19 Dispatcher dispatcher = new Dispatcher(executor); field in class:DispatcherTest
20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
23 dispatcher.setMaxRequests(20);
24 dispatcher.setMaxRequestsPerHost(10);
29 dispatcher.setMaxRequests(0);
37 dispatcher.setMaxRequestsPerHost(0);
49 dispatcher.setMaxRequests(3);
58 dispatcher.setMaxRequestsPerHost(2)
[all...] |
| /prebuilts/tools/common/m2/repository/org/sonatype/plexus/plexus-sec-dispatcher/1.3/ |
| plexus-sec-dispatcher-1.3.jar | |
| /frameworks/base/core/java/com/android/internal/policy/ |
| PhoneFallbackEventHandler.java | 81 final KeyEvent.DispatcherState dispatcher = mView.getKeyDispatcherState(); local
115 if (getKeyguardManager().inKeyguardRestrictedInputMode() || dispatcher == null) {
119 dispatcher.startTracking(event, this);
120 } else if (event.isLongPress() && dispatcher.isTracking(event)) {
121 dispatcher.performedLongPress(event);
142 if (getKeyguardManager().inKeyguardRestrictedInputMode() || dispatcher == null) {
146 dispatcher.startTracking(event, this);
147 } else if (event.isLongPress() && dispatcher.isTracking(event)) {
148 dispatcher.performedLongPress(event);
167 if (getKeyguardManager().inKeyguardRestrictedInputMode() || dispatcher == null)
209 final KeyEvent.DispatcherState dispatcher = mView.getKeyDispatcherState(); local
[all...] |
| /frameworks/native/services/vr/performanced/ |
| main.cpp | 31 std::unique_ptr<android::pdx::ServiceDispatcher> dispatcher; local
61 dispatcher = android::pdx::ServiceDispatcher::Create();
62 CHECK_ERROR(!dispatcher, error, "Failed to create service dispatcher.");
66 dispatcher->AddService(service);
70 ret = dispatcher->EnterDispatchLoop();
|
| /external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| MockMethodDispatcher.java | 24 public static void set(String identifier, MockMethodDispatcher dispatcher) {
25 INSTANCE.putIfAbsent(identifier, dispatcher);
|
| MockMethodAdvice.java | 47 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(identifier, mock); local
48 if (dispatcher == null || !dispatcher.isMocked(mock) || !dispatcher.isOverridden(mock, origin)) {
51 return dispatcher.handle(mock, origin, arguments);
168 throw new MockitoException("Unexpected dispatcher for advice-based super call");
223 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(id, self); local
224 return dispatcher != null && dispatcher.isMock(self);
244 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(identifier, self) local
[all...] |
| /frameworks/support/dynamic-animation/src/android/support/animation/ |
| AnimationHandler.java | 56 * new frame has arrived. This dispatcher class then notifies all the on-going animations of
200 FrameCallbackProvider16(AnimationCallbackDispatcher dispatcher) {
201 super(dispatcher);
226 FrameCallbackProvider14(AnimationCallbackDispatcher dispatcher) {
227 super(dispatcher);
254 AnimationFrameCallbackProvider(AnimationCallbackDispatcher dispatcher) {
255 mDispatcher = dispatcher;
|
| /frameworks/base/media/java/android/media/midi/ |
| MidiDeviceServer.java | 154 MidiDispatcher dispatcher = mOutputPortDispatchers[portNumber]; local
155 synchronized (dispatcher) {
156 dispatcher.getSender().disconnect(mInputPort);
157 int openCount = dispatcher.getReceiverCount();
246 MidiDispatcher dispatcher = mOutputPortDispatchers[portNumber];
247 synchronized (dispatcher) {
248 dispatcher.getSender().connect(inputPort);
249 int openCount = dispatcher.getReceiverCount();
298 MidiDispatcher dispatcher = mOutputPortDispatchers[outputPortNumber];
299 synchronized (dispatcher) {
[all...] |
| /external/libvncserver/examples/ |
| 1instance.c | 78 int dispatch_event(single_instance_struct* str,event_dispatcher dispatcher,int usecs)
84 dispatcher(buffer);
89 int loop_if_server(single_instance_struct* str,event_dispatcher dispatcher)
94 dispatch_event(str,dispatcher,50);
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { local
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() { local
72 mockWebServer.setDispatcher(dispatcher);
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { local
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() { local
72 mockWebServer.setDispatcher(dispatcher);
|
| /external/autotest/client/common_lib/cros/bluetooth/ |
| bluetooth_gatt_server.py | 18 class BluetoothGATTServer(asyncore.dispatcher):
21 This class inherits asyncore.dispatcher to handle I/O on BLE socket.
37 asyncore.dispatcher.__init__(self, sock=sock)
71 from asyncore.dispatcher class.
|
