| /external/libchrome/mojo/core/ |
| D | handle_table.cc | 51 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher() argument
58 handles_.insert(std::make_pair(handle, Entry(std::move(dispatcher)))); in AddDispatcher()
78 if (dispatchers[i].dispatcher) { in AddDispatchersFromTransit()
81 std::make_pair(handle, Entry(dispatchers[i].dispatcher))); in AddDispatchersFromTransit()
94 return it->second.dispatcher; in GetDispatcher()
99 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher() argument
106 *dispatcher = std::move(it->second.dispatcher); in GetAndRemoveDispatcher()
125 d.dispatcher = it->second.dispatcher; in BeginTransit()
126 if (!d.dispatcher->BeginTransit()) in BeginTransit()
136 for (const auto& dispatcher : dispatchers) { in CompleteTransitAndClose() local
[all …]
|
| D | platform_handle_dispatcher_unittest.cc | 40 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
43 EXPECT_EQ(Dispatcher::Type::PLATFORM_HANDLE, dispatcher->GetType()); in TEST()
45 h = dispatcher->TakePlatformHandle(); in TEST()
59 auto internal_handle = dispatcher->TakePlatformHandle(); in TEST()
62 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); in TEST()
76 scoped_refptr<PlatformHandleDispatcher> dispatcher = in TEST() local
83 EXPECT_TRUE(dispatcher->BeginTransit()); in TEST()
84 dispatcher->StartSerialize(&num_bytes, &num_ports, &num_handles); in TEST()
91 EXPECT_TRUE(dispatcher->EndSerialize(nullptr, nullptr, &received_handle)); in TEST()
93 dispatcher->CompleteTransitAndClose(); in TEST()
[all …]
|
| D | shared_buffer_dispatcher_unittest.cc | 112 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
115 nullptr, 100, &dispatcher)); in TEST_F()
116 ASSERT_TRUE(dispatcher); in TEST_F()
117 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
121 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(0, 100, &mapping1)); in TEST_F()
129 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->MapBuffer(50, 50, &mapping2)); in TEST_F()
135 EXPECT_EQ(MOJO_RESULT_OK, dispatcher->Close()); in TEST_F()
147 scoped_refptr<SharedBufferDispatcher> dispatcher; in TEST_F() local
152 &dispatcher)); in TEST_F()
153 ASSERT_TRUE(dispatcher); in TEST_F()
[all …]
|
| D | core.cc | 166 scoped_refptr<Dispatcher> dispatcher; in GetAndRemoveDispatcher() local
168 handles_->GetAndRemoveDispatcher(handle, &dispatcher); in GetAndRemoveDispatcher()
169 return dispatcher; in GetAndRemoveDispatcher()
228 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher() argument
230 return handles_->AddDispatcher(dispatcher); in AddDispatcher()
244 if (d.dispatcher) in AddDispatchersFromTransit()
245 d.dispatcher->Close(); in AddDispatchersFromTransit()
293 scoped_refptr<Dispatcher> dispatcher; in Close() local
296 MojoResult rv = handles_->GetAndRemoveDispatcher(handle, &dispatcher); in Close()
300 dispatcher->Close(); in Close()
[all …]
|
| D | watcher_dispatcher.cc | 21 void WatcherDispatcher::NotifyHandleState(Dispatcher* dispatcher, in NotifyHandleState() argument
24 auto it = watched_handles_.find(dispatcher); in NotifyHandleState()
40 void WatcherDispatcher::NotifyHandleClosed(Dispatcher* dispatcher) { in NotifyHandleClosed() argument
44 auto it = watched_handles_.find(dispatcher); in NotifyHandleClosed()
112 entry.second->dispatcher()->RemoveWatcherRef(this, entry.first); in Close()
120 scoped_refptr<Dispatcher> dispatcher, in WatchDispatcher() argument
132 if (watches_.count(context) || watched_handles_.count(dispatcher.get())) in WatchDispatcher()
136 new Watch(this, dispatcher, context, signals, condition); in WatchDispatcher()
139 watched_handles_.insert(std::make_pair(dispatcher.get(), watch)); in WatchDispatcher()
143 MojoResult rv = dispatcher->AddWatcherRef(this, context); in WatchDispatcher()
[all …]
|
| D | handle_table.h | 32 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
42 scoped_refptr<Dispatcher>* dispatcher);
68 explicit Entry(scoped_refptr<Dispatcher> dispatcher);
72 scoped_refptr<Dispatcher> dispatcher; member
|
| D | data_pipe_consumer_dispatcher.cc | 58 scoped_refptr<DataPipeConsumerDispatcher> dispatcher) in PortObserverThunk() argument
59 : dispatcher_(dispatcher) {} in PortObserverThunk()
398 scoped_refptr<DataPipeConsumerDispatcher> dispatcher = in Deserialize() local
404 base::AutoLock lock(dispatcher->lock_); in Deserialize()
405 dispatcher->read_offset_ = state->read_offset; in Deserialize()
406 dispatcher->bytes_available_ = state->bytes_available; in Deserialize()
407 dispatcher->new_data_available_ = state->bytes_available > 0; in Deserialize()
408 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()
409 if (!dispatcher->InitializeNoLock()) in Deserialize()
411 dispatcher->UpdateSignalsStateNoLock(); in Deserialize()
[all …]
|
| D | data_pipe_producer_dispatcher.cc | 57 scoped_refptr<DataPipeProducerDispatcher> dispatcher) in PortObserverThunk() argument
58 : dispatcher_(dispatcher) {} in PortObserverThunk()
359 scoped_refptr<DataPipeProducerDispatcher> dispatcher = in Deserialize() local
365 base::AutoLock lock(dispatcher->lock_); in Deserialize()
366 dispatcher->write_offset_ = state->write_offset; in Deserialize()
367 dispatcher->available_capacity_ = state->available_capacity; in Deserialize()
368 dispatcher->peer_closed_ = state->flags & kFlagPeerClosed; in Deserialize()
369 if (!dispatcher->InitializeNoLock()) in Deserialize()
371 dispatcher->UpdateSignalsStateNoLock(); in Deserialize()
374 return dispatcher; in Deserialize()
|
| D | watcher_dispatcher.h | 34 void NotifyHandleState(Dispatcher* dispatcher,
36 void NotifyHandleClosed(Dispatcher* dispatcher);
48 MojoResult WatchDispatcher(scoped_refptr<Dispatcher> dispatcher,
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | DispatcherTest.java | 19 Dispatcher dispatcher = new Dispatcher(executor); field in DispatcherTest
20 OkHttpClient client = new OkHttpClient().setDispatcher(dispatcher);
23 dispatcher.setMaxRequests(20); in setUp()
24 dispatcher.setMaxRequestsPerHost(10); in setUp()
29 dispatcher.setMaxRequests(0); in maxRequestsZero()
37 dispatcher.setMaxRequestsPerHost(0); in maxPerHostZero()
49 dispatcher.setMaxRequests(3); in maxRequestsEnforced()
58 dispatcher.setMaxRequestsPerHost(2); in maxPerHostEnforced()
66 dispatcher.setMaxRequests(2); in increasingMaxRequestsPromotesJobsImmediately()
72 dispatcher.setMaxRequests(4); in increasingMaxRequestsPromotesJobsImmediately()
[all …]
|
| /external/dexmaker/dexmaker-mockito-inline/src/main/resources/ |
| D | README.txt | 1 dispatcher.jar is the classes.dex of the apk created by dexmaker-mockito-inline-dispatcher
4 unzip dexmaker-mockito-inline-dispatcher/build/outputs/apk/release/dexmaker-mockito-inline
5 -dispatcher-release-unsigned.apk classes.dex
6 jar -cf dexmaker-mockito-inline/src/main/resources/dispatcher.jar classes.dex
|
| /external/autotest/site_utils/rpm_control_system/ |
| D | rpm_dispatcher_unittest.py | 48 self.dispatcher = rpm_dispatcher.RPMDispatcher(FAKE_DISPATCHER_URI,
66 controller1 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
67 controller2 = self.dispatcher._get_rpm_controller(RPM_HOSTNAME)
77 controller1 = self.dispatcher._get_rpm_controller(DUT_SAME_RPM1)
78 controller2 = self.dispatcher._get_rpm_controller(DUT_DIFFERENT_RPM)
|
| /external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| D | MockMethodAdvice.java | 58 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(identifier, mock); in enter() local
59 … if (dispatcher == null || !dispatcher.isMocked(mock) || dispatcher.isOverridden(mock, origin)) { in enter()
62 return dispatcher.handle(mock, origin, arguments); in enter()
282 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(id, self); in enter() local
283 return dispatcher != null && dispatcher.isMock(self); in enter()
303 MockMethodDispatcher dispatcher = MockMethodDispatcher.get(identifier, self); in enter() local
304 return dispatcher != null && dispatcher.isMock(self); in enter()
|
| /external/mockwebserver/src/main/java/com/google/mockwebserver/ |
| D | MockWebServer.java | 93 private Dispatcher dispatcher = new QueueDispatcher(); field in MockWebServer
191 ((QueueDispatcher) dispatcher).enqueueResponse(response.clone()); in enqueue()
269 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in play()
307 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in serveConnection()
348 SocketPolicy socketPolicy = dispatcher.peek().getSocketPolicy(); in serveConnection()
368 MockResponse response = dispatcher.dispatch(request); in serveConnection()
424 dispatcher.dispatch(request); in dispatchBookkeepingRequest()
471 MockResponse throttlePolicy = dispatcher.peek(); in readRequest()
588 public void setDispatcher(Dispatcher dispatcher) { in setDispatcher() argument
589 if (dispatcher == null) { in setDispatcher()
[all …]
|
| /external/u-boot/doc/device-tree-bindings/net/ |
| D | altera_tse.txt | 10 "tx_csr": xDMA Tx dispatcher control and status space region
11 "tx_desc": MSGDMA Tx dispatcher descriptor space region
12 "rx_csr" : xDMA Rx dispatcher control and status space region
13 "rx_desc": MSGDMA Rx dispatcher descriptor space region
14 "rx_resp": MSGDMA Rx dispatcher response space region
18 "rx_irq": xDMA Rx dispatcher interrupt
19 "tx_irq": xDMA Tx dispatcher interrupt
|
| /external/v8/src/compiler-dispatcher/ |
| D | compiler-dispatcher.cc | 75 CompilerDispatcher* dispatcher);
88 CompilerDispatcher* dispatcher) in MemoryPressureTask() argument
89 : CancelableTask(task_manager), dispatcher_(dispatcher) {} in MemoryPressureTask()
102 CompilerDispatcher* dispatcher);
115 CompilerDispatcher* dispatcher) in AbortTask() argument
116 : CancelableTask(task_manager), dispatcher_(dispatcher) {} in AbortTask()
127 CompilerDispatcher* dispatcher);
140 CompilerDispatcher* dispatcher) in WorkerTask() argument
141 : CancelableTask(task_manager), dispatcher_(dispatcher) {} in WorkerTask()
151 IdleTask(CancelableTaskManager* task_manager, CompilerDispatcher* dispatcher);
[all …]
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | OkHttpClient.java | 121 private Dispatcher dispatcher; field in OkHttpClient
150 dispatcher = new Dispatcher(); in OkHttpClient()
155 this.dispatcher = okHttpClient.dispatcher; in OkHttpClient()
473 public OkHttpClient setDispatcher(Dispatcher dispatcher) { in setDispatcher() argument
474 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null"); in setDispatcher()
475 this.dispatcher = dispatcher; in setDispatcher()
480 return dispatcher; in getDispatcher()
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ServletPipelineRequestDispatcherTest.java | 110 final RequestDispatcher dispatcher = in testIncludeManagedServlet() local
113 assertNotNull(dispatcher); in testIncludeManagedServlet()
114 dispatcher.include(requestMock, createMock(HttpServletResponse.class)); in testIncludeManagedServlet()
177 final RequestDispatcher dispatcher = in testForwardToManagedServlet() local
180 assertNotNull(dispatcher); in testForwardToManagedServlet()
181 dispatcher.forward(requestMock, mockResponse); in testForwardToManagedServlet()
247 final RequestDispatcher dispatcher = in forwardToManagedServletFailureOnCommittedBuffer() local
250 assertNotNull(dispatcher); in forwardToManagedServletFailureOnCommittedBuffer()
253 dispatcher.forward(mockRequest, mockResponse); in forwardToManagedServletFailureOnCommittedBuffer()
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in testSimpleDispatch() local
48 mockWebServer.setDispatcher(dispatcher); in testSimpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in testOutOfOrderResponses() local
72 mockWebServer.setDispatcher(dispatcher); in testOutOfOrderResponses()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 177 final ResponseDispatcher dispatcher = new ResponseDispatcher(responseObserver); in fullDuplexCall() local
182 dispatcher.cancel(); in fullDuplexCall()
183 dispatcher.onError(Status.fromCodeValue(request.getResponseStatus().getCode()) in fullDuplexCall()
188 dispatcher.enqueue(toChunkQueue(request)); in fullDuplexCall()
193 if (!dispatcher.isCancelled()) { in fullDuplexCall()
195 dispatcher.completeInput(); in fullDuplexCall()
201 dispatcher.onError(cause); in fullDuplexCall()
213 final ResponseDispatcher dispatcher = new ResponseDispatcher(responseObserver);
224 dispatcher.enqueue(chunks).completeInput();
229 dispatcher.onError(cause);
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in simpleDispatch() local
48 mockWebServer.setDispatcher(dispatcher); in simpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in outOfOrderResponses() local
72 mockWebServer.setDispatcher(dispatcher); in outOfOrderResponses()
|
| /external/libchrome/libchrome_tools/patch/ |
| D | handle_table.patch | 70 - // Create entries for all relevant dispatcher types to ensure they are present
81 - // Count the number of each dispatcher type.
85 - ++handle_count[entry.second.dispatcher->GetType()];
102 +// // Create entries for all relevant dispatcher types to ensure they are present
113 +// // Count the number of each dispatcher type.
117 +// ++handle_count[entry.second.dispatcher->GetType()];
145 #include "mojo/core/dispatcher.h"
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | OkHttpClient.java | 124 private Dispatcher dispatcher; field in OkHttpClient
156 dispatcher = new Dispatcher(); in OkHttpClient()
161 this.dispatcher = okHttpClient.dispatcher; in OkHttpClient()
486 public OkHttpClient setDispatcher(Dispatcher dispatcher) { in setDispatcher() argument
487 if (dispatcher == null) throw new IllegalArgumentException("dispatcher == null"); in setDispatcher()
488 this.dispatcher = dispatcher; in setDispatcher()
493 return dispatcher; in getDispatcher()
|
| /external/python/cpython2/Lib/test/ |
| D | test_asyncore.py | 237 d = asyncore.dispatcher()
242 d = asyncore.dispatcher()
246 d = asyncore.dispatcher()
264 d = asyncore.dispatcher()
286 d = asyncore.dispatcher()
313 d = asyncore.dispatcher(socket.socket())
459 class BaseTestHandler(asyncore.dispatcher):
462 asyncore.dispatcher.__init__(self, sock)
481 class TCPServer(asyncore.dispatcher):
487 asyncore.dispatcher.__init__(self)
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | physicalsocketserver_unittest.cc | 43 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); in CreateAsyncSocket() local
44 if (dispatcher->Create(type)) { in CreateAsyncSocket()
45 return dispatcher; in CreateAsyncSocket()
47 delete dispatcher; in CreateAsyncSocket()
53 SocketDispatcher* dispatcher = new FakeSocketDispatcher(this); in CreateAsyncSocket() local
54 if (dispatcher->Create(family, type)) { in CreateAsyncSocket()
55 return dispatcher; in CreateAsyncSocket()
57 delete dispatcher; in CreateAsyncSocket()
|