| /external/chromium_org/mojo/system/ |
| D | core.cc | 314 DispatcherVector dispatchers; in ReadMessage() local
316 bytes, num_bytes, &dispatchers, &num_handles_value, flags); in ReadMessage()
317 if (!dispatchers.empty()) { in ReadMessage()
320 DCHECK_LE(dispatchers.size(), static_cast<size_t>(num_handles_value)); in ReadMessage()
324 dispatchers.size()); in ReadMessage()
328 dispatchers, handles_writer.GetPointer()); in ReadMessage()
333 LOG(ERROR) << "Received message with " << dispatchers.size() in ReadMessage()
336 for (size_t i = 0; i < dispatchers.size(); i++) { in ReadMessage()
337 if (dispatchers[i].get()) in ReadMessage()
338 dispatchers[i]->Close(); in ReadMessage()
[all …]
|
| D | local_message_pipe_endpoint.cc | 68 DispatcherVector* dispatchers, in ReadMessage() argument
72 DCHECK(!dispatchers || dispatchers->empty()); in ReadMessage()
93 if (DispatcherVector* queued_dispatchers = message->dispatchers()) { in ReadMessage()
100 DCHECK(dispatchers); in ReadMessage()
101 dispatchers->swap(*queued_dispatchers); in ReadMessage()
|
| D | transport_data.cc | 63 TransportData::TransportData(scoped_ptr<DispatcherVector> dispatchers, in TransportData() argument
65 DCHECK(dispatchers); in TransportData()
68 const size_t num_handles = dispatchers->size(); in TransportData()
85 if (Dispatcher* dispatcher = (*dispatchers)[i].get()) { in TransportData()
136 Dispatcher* dispatcher = (*dispatchers)[i].get(); in TransportData()
324 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector(num_handles)); in DeserializeDispatchers() local
338 (*dispatchers)[i] = Dispatcher::TransportDataAccess::Deserialize( in DeserializeDispatchers()
342 return dispatchers.Pass(); in DeserializeDispatchers()
|
| D | handle_table.cc | 76 bool HandleTable::AddDispatcherVector(const DispatcherVector& dispatchers, in AddDispatcherVector() argument
78 DCHECK_LE(dispatchers.size(), kMaxMessageNumHandles); in AddDispatcherVector()
88 if (handle_to_entry_map_.size() + dispatchers.size() > kMaxHandleTableSize) in AddDispatcherVector()
91 for (size_t i = 0; i < dispatchers.size(); i++) { in AddDispatcherVector()
92 if (dispatchers[i].get()) { in AddDispatcherVector()
93 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]); in AddDispatcherVector()
|
| D | message_pipe.cc | 109 DispatcherVector* dispatchers, in ReadMessage() argument
118 bytes, num_bytes, dispatchers, num_dispatchers, flags); in ReadMessage()
274 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector()); in AttachTransportsNoLock() local
275 dispatchers->reserve(transports->size()); in AttachTransportsNoLock()
278 dispatchers->push_back( in AttachTransportsNoLock()
282 dispatchers->push_back(scoped_refptr<Dispatcher>()); in AttachTransportsNoLock()
285 message->SetDispatchers(dispatchers.Pass()); in AttachTransportsNoLock()
|
| D | multiprocess_message_pipe_unittest.cc | 237 DispatcherVector dispatchers; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN() local
242 &dispatchers, in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
250 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypeSharedBuffer); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
253 static_cast<SharedBufferDispatcher*>(dispatchers[0].get())); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
429 DispatcherVector dispatchers; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN() local
434 &dispatchers, in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
444 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypePlatformHandle); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
447 static_cast<PlatformHandleDispatcher*>(dispatchers[0].get())); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
|
| D | message_in_transit.cc | 163 scoped_ptr<DispatcherVector> dispatchers) { in SetDispatchers() argument
164 DCHECK(dispatchers); in SetDispatchers()
168 dispatchers_ = dispatchers.Pass(); in SetDispatchers()
|
| D | core_test_base.cc | 65 DispatcherVector* dispatchers, in ReadMessageImplNoLock() argument
73 if (dispatchers) { in ReadMessageImplNoLock()
75 dispatchers->resize(1); in ReadMessageImplNoLock()
|
| D | dispatcher.cc | 122 DispatcherVector* dispatchers, in ReadMessage() argument
126 (dispatchers && dispatchers->empty())); in ReadMessage()
133 bytes, num_bytes, dispatchers, num_dispatchers, flags); in ReadMessage()
|
| D | message_in_transit.h | 165 void SetDispatchers(scoped_ptr<DispatcherVector> dispatchers);
208 DispatcherVector* dispatchers() { return dispatchers_.get(); } in dispatchers() function
|
| D | message_pipe_dispatcher.cc | 204 DispatcherVector* dispatchers, in ReadMessageImplNoLock() argument
209 port_, bytes, num_bytes, dispatchers, num_dispatchers, flags); in ReadMessageImplNoLock()
|
| D | message_pipe_endpoint.h | 64 DispatcherVector* dispatchers,
|
| D | local_message_pipe_endpoint.h | 36 DispatcherVector* dispatchers,
|
| D | transport_data.h | 92 TransportData(scoped_ptr<DispatcherVector> dispatchers, Channel* channel);
|
| D | handle_table.h | 79 bool AddDispatcherVector(const DispatcherVector& dispatchers,
|
| D | dispatcher.h | 97 DispatcherVector* dispatchers,
242 DispatcherVector* dispatchers,
|
| D | message_pipe.h | 75 DispatcherVector* dispatchers,
|
| D | message_pipe_dispatcher.h | 87 DispatcherVector* dispatchers,
|
| /external/skia/gm/rebaseline_server/ |
| D | server.py | 431 dispatchers = {
435 dispatcher = dispatchers[dispatcher_name]
507 dispatchers = {
511 dispatcher = dispatchers[normpath]
|
| /external/chromium_org/third_party/tlslite/tlslite/integration/ |
| D | xmlrpcserver.py | 53 self.dispatchers = {}
|
| /external/chromium_org/third_party/skia/gm/rebaseline_server/ |
| D | server.py | 546 dispatchers = {
552 dispatcher = dispatchers[dispatcher_name]
691 dispatchers = {
696 dispatcher = dispatchers[normpath]
|
| /external/chromium_org/ui/events/platform/ |
| D | platform_event_source_unittest.cc | 183 ScopedVector<TestPlatformEventDispatcher> dispatchers; in TEST_F() local
185 dispatchers.push_back( in TEST_F()
|