Searched refs:dispatcher (Results 1 - 25 of 81) sorted by relevance

1234

/external/libmojo/mojo/edk/system/
H A Dhandle_table.cc18 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { argument
24 auto result = handles_.insert(std::make_pair(handle, Entry(dispatcher)));
45 std::make_pair(handle, Entry(dispatchers[i].dispatcher)));
57 return it->second.dispatcher;
62 scoped_refptr<Dispatcher>* dispatcher) {
69 *dispatcher = it->second.dispatcher;
89 d.dispatcher = it->second.dispatcher;
90 if (!d.dispatcher
60 GetAndRemoveDispatcher( MojoHandle handle, scoped_refptr<Dispatcher>* dispatcher) argument
126 Entry(scoped_refptr<Dispatcher> dispatcher) argument
[all...]
H A Dplatform_handle_dispatcher_unittest.cc40 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()));
92 dispatcher
[all...]
H A Dshared_buffer_dispatcher_unittest.cc15 #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 has
151 scoped_refptr<SharedBufferDispatcher> dispatcher; local
273 scoped_refptr<SharedBufferDispatcher> dispatcher; local
289 scoped_refptr<SharedBufferDispatcher> dispatcher; local
[all...]
H A Dhandle_table.h14 #include "mojo/edk/system/dispatcher.h"
25 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
35 scoped_refptr<Dispatcher>* dispatcher);
55 explicit Entry(scoped_refptr<Dispatcher> dispatcher);
59 scoped_refptr<Dispatcher> dispatcher; member in struct:mojo::edk::HandleTable::Entry
H A Dcore.cc194 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { argument
196 return handles_.AddDispatcher(dispatcher);
210 d.dispatcher->Close();
258 scoped_refptr<SharedBufferDispatcher> dispatcher;
260 platform_buffer, &dispatcher);
263 MojoHandle h = AddDispatcher(dispatcher);
278 scoped_refptr<Dispatcher> dispatcher;
282 // Get the dispatcher and check it before removing it from the handle table
283 // to ensure that the dispatcher is of the correct type. This ensures we
284 // don't close and remove the wrong type of 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...]
H A Dwait_set_dispatcher.cc20 explicit Waiter(WaitSetDispatcher* dispatcher) : dispatcher_(dispatcher) {} argument
27 // Removes |this| from the dispatcher's list of waiters.
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,
99 state.dispatcher = dispatcher;
71 AddWaitingDispatcher( const scoped_refptr<Dispatcher>& dispatcher, MojoHandleSignals signals, uintptr_t context) argument
109 RemoveWaitingDispatcher( const scoped_refptr<Dispatcher>& dispatcher) argument
[all...]
H A Dwait_set_dispatcher.h18 #include "mojo/edk/system/dispatcher.h"
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 with
83 // List of dispatchers that have been woken up. Any dispatcher in this queue
H A Dwaiter_test_utils.cc26 WaiterThread::WaiterThread(scoped_refptr<Dispatcher> dispatcher, argument
35 dispatcher_(dispatcher),
H A Ddata_pipe_consumer_dispatcher.cc53 // reference to the dispatcher to ensure it lives as long as the observed port.
58 scoped_refptr<DataPipeConsumerDispatcher> dispatcher)
59 : dispatcher_(dispatcher) {}
413 scoped_refptr<DataPipeConsumerDispatcher> dispatcher = local
419 base::AutoLock lock(dispatcher->lock_);
420 dispatcher->read_offset_ = state->read_offset;
421 dispatcher->bytes_available_ = state->bytes_available;
422 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed;
423 dispatcher->InitializeNoLock();
426 return dispatcher;
57 PortObserverThunk( scoped_refptr<DataPipeConsumerDispatcher> dispatcher) argument
[all...]
H A Ddata_pipe_producer_dispatcher.cc52 // reference to the dispatcher to ensure it lives as long as the observed port.
57 scoped_refptr<DataPipeProducerDispatcher> dispatcher)
58 : dispatcher_(dispatcher) {}
395 scoped_refptr<DataPipeProducerDispatcher> dispatcher = local
401 base::AutoLock lock(dispatcher->lock_);
402 dispatcher->write_offset_ = state->write_offset;
403 dispatcher->available_capacity_ = state->available_capacity;
404 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed;
405 dispatcher->InitializeNoLock();
408 return dispatcher;
56 PortObserverThunk( scoped_refptr<DataPipeProducerDispatcher> dispatcher) argument
[all...]
H A Ddispatcher.h49 scoped_refptr<Dispatcher> dispatcher; member in struct:mojo::edk::Dispatcher::DispatcherInTransit
93 // |*new_dispatcher| should be null (and will contain the dispatcher for the
131 // Adds a dispatcher to wait on. When the dispatcher satisfies |signals|, it
133 // |dispatcher| has been added, it must be removed before adding again,
136 const scoped_refptr<Dispatcher>& dispatcher,
140 // Removes a dispatcher to wait on. If |dispatcher| has not been added,
143 const scoped_refptr<Dispatcher>& dispatcher);
161 // Adds an awakable to this dispatcher, whic
[all...]
/external/autotest/site_utils/rpm_control_system/
H A Drpm_dispatcher_unittest.py16 FAKE_DISPATCHER_URI = 'fake-dispatcher'
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)
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
H A DDispatcherTest.java19 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);
66 dispatcher.setMaxRequests(2);
72 dispatcher
[all...]
/external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/
H A DMockMethodDispatcher.java24 public static void set(String identifier, MockMethodDispatcher dispatcher) { argument
25 INSTANCE.putIfAbsent(identifier, dispatcher);
H A DMockMethodAdvice.java47 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(identifier, mock);
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);
224 return dispatcher != null && dispatcher.isMock(self);
244 MockMethodDispatcher dispatcher
[all...]
/external/v8/src/compiler-dispatcher/
H A Doptimizing-compile-dispatcher.cc5 #include "src/compiler-dispatcher/optimizing-compile-dispatcher.h"
37 OptimizingCompileDispatcher* dispatcher = local
39 base::LockGuard<base::Mutex> lock_guard(&dispatcher->ref_count_mutex_);
40 ++dispatcher->ref_count_;
52 OptimizingCompileDispatcher* dispatcher = variable
60 if (dispatcher->recompilation_delay_ != 0) {
62 dispatcher->recompilation_delay_));
65 dispatcher->CompileNext(dispatcher
[all...]
/external/libvncserver/examples/
H A D1instance.c78 int dispatch_event(single_instance_struct* str,event_dispatcher dispatcher,int usecs) argument
84 dispatcher(buffer);
89 int loop_if_server(single_instance_struct* str,event_dispatcher dispatcher) argument
94 dispatch_event(str,dispatcher,50);
/external/mockwebserver/src/test/java/com/google/mockwebserver/
H A DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() {
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() {
72 mockWebServer.setDispatcher(dispatcher);
/external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/
H A DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() {
48 mockWebServer.setDispatcher(dispatcher);
52 // Make sure our dispatcher got the request.
63 final Dispatcher dispatcher = new Dispatcher() {
72 mockWebServer.setDispatcher(dispatcher);
/external/autotest/client/common_lib/cros/bluetooth/
H A Dbluetooth_gatt_server.py18 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.
/external/guice/extensions/struts2/example/src/com/google/inject/struts2/example/
H A DExampleListener.java19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
/external/guice/extensions/servlet/test/com/google/inject/servlet/
H A DServletPipelineRequestDispatcherTest.java116 final RequestDispatcher dispatcher = new ManagedServletPipeline(
120 assertNotNull(dispatcher);
121 dispatcher.include(requestMock, createMock(HttpServletResponse.class));
186 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector)
189 assertNotNull(dispatcher);
190 dispatcher.forward(requestMock, mockResponse);
258 final RequestDispatcher dispatcher = new ManagedServletPipeline(injector)
261 assertNotNull(dispatcher);
264 dispatcher.forward(mockRequest, mockResponse);
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
H A DOkHttpClient.java121 private Dispatcher dispatcher; field in class:OkHttpClient
150 dispatcher = new Dispatcher();
155 this.dispatcher = okHttpClient.dispatcher;
470 * Sets the dispatcher used to set policy and execute asynchronous requests.
473 public OkHttpClient setDispatcher(Dispatcher dispatcher) { argument
474 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null");
475 this.dispatcher = dispatcher;
[all...]
/external/guice/extensions/servlet/src/com/google/inject/servlet/
H A DManagedFilterPipeline.java129 * is not called again). However, we can wrap requests with our own dispatcher to forward the
152 final RequestDispatcher dispatcher = servletPipeline.getRequestDispatcher(path);
154 return (null != dispatcher) ? dispatcher : super.getRequestDispatcher(path);
/external/mockwebserver/src/main/java/com/google/mockwebserver/
H A DMockWebServer.java93 private Dispatcher dispatcher = new QueueDispatcher(); field in class:MockWebServer
187 * @throws ClassCastException if the default dispatcher has been replaced
191 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone());
269 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
307 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
348 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy();
368 MockResponse response = dispatcher.dispatch(request);
386 // request. The retry handler may call dispatcher.dispatch(request) before the
388 // Setting workerThreads = 1 ensures that the dispatcher is called for requests in
424 dispatcher
588 setDispatcher(Dispatcher dispatcher) argument
[all...]

Completed in 484 milliseconds

1234