/external/libmojo/mojo/edk/system/ |
H A D | handle_table.cc | 18 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 D | 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())); 92 dispatcher [all...] |
H A D | 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 has 151 scoped_refptr<SharedBufferDispatcher> dispatcher; local 273 scoped_refptr<SharedBufferDispatcher> dispatcher; local 289 scoped_refptr<SharedBufferDispatcher> dispatcher; local [all...] |
H A D | handle_table.h | 14 #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 D | core.cc | 194 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 D | wait_set_dispatcher.cc | 20 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 D | wait_set_dispatcher.h | 18 #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 D | waiter_test_utils.cc | 26 WaiterThread::WaiterThread(scoped_refptr<Dispatcher> dispatcher, argument 35 dispatcher_(dispatcher),
|
H A D | data_pipe_consumer_dispatcher.cc | 53 // 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 D | data_pipe_producer_dispatcher.cc | 52 // 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 D | dispatcher.h | 49 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 D | rpm_dispatcher_unittest.py | 16 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 D | 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); 66 dispatcher.setMaxRequests(2); 72 dispatcher [all...] |
/external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
H A D | MockMethodDispatcher.java | 24 public static void set(String identifier, MockMethodDispatcher dispatcher) { argument 25 INSTANCE.putIfAbsent(identifier, dispatcher);
|
H A D | MockMethodAdvice.java | 47 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 D | optimizing-compile-dispatcher.cc | 5 #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 D | 1instance.c | 78 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 D | CustomDispatcherTest.java | 40 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 D | CustomDispatcherTest.java | 40 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 D | 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.
|
/external/guice/extensions/struts2/example/src/com/google/inject/struts2/example/ |
H A D | ExampleListener.java | 19 import org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter;
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
H A D | ServletPipelineRequestDispatcherTest.java | 116 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 D | OkHttpClient.java | 121 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 D | ManagedFilterPipeline.java | 129 * 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 D | MockWebServer.java | 93 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...] |