| /external/chromium_org/mojo/system/ |
| 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 | core.cc | 274 DispatcherVector dispatchers; in ReadMessage() local
276 &dispatchers, num_handles, in ReadMessage()
278 if (!dispatchers.empty()) { in ReadMessage()
281 DCHECK_LE(dispatchers.size(), static_cast<size_t>(*num_handles)); in ReadMessage()
286 success = handle_table_.AddDispatcherVector(dispatchers, handles); in ReadMessage()
289 LOG(ERROR) << "Received message with " << dispatchers.size() in ReadMessage()
292 for (size_t i = 0; i < dispatchers.size(); i++) { in ReadMessage()
293 if (dispatchers[i]) in ReadMessage()
294 dispatchers[i]->Close(); in ReadMessage()
520 DispatcherVector dispatchers; in WaitManyInternal() local
[all …]
|
| D | transport_data.cc | 65 TransportData::TransportData(scoped_ptr<DispatcherVector> dispatchers, in TransportData() argument
67 DCHECK(dispatchers); in TransportData()
70 const size_t num_handles = dispatchers->size(); in TransportData()
87 if (Dispatcher* dispatcher = (*dispatchers)[i].get()) { in TransportData()
139 Dispatcher* dispatcher = (*dispatchers)[i].get(); in TransportData()
323 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector(num_handles)); in DeserializeDispatchers() local
337 (*dispatchers)[i] = Dispatcher::TransportDataAccess::Deserialize( in DeserializeDispatchers()
341 return dispatchers.Pass(); in DeserializeDispatchers()
|
| D | message_pipe.cc | 88 DispatcherVector* dispatchers, in ReadMessage() argument
96 return endpoints_[port]->ReadMessage(bytes, num_bytes, dispatchers, in ReadMessage()
261 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector()); in AttachTransportsNoLock() local
262 dispatchers->reserve(transports->size()); in AttachTransportsNoLock()
265 dispatchers->push_back( in AttachTransportsNoLock()
269 dispatchers->push_back(scoped_refptr<Dispatcher>()); in AttachTransportsNoLock()
272 message->SetDispatchers(dispatchers.Pass()); in AttachTransportsNoLock()
|
| D | handle_table.cc | 79 bool HandleTable::AddDispatcherVector(const DispatcherVector& dispatchers, in AddDispatcherVector() argument
81 DCHECK_LE(dispatchers.size(), kMaxMessageNumHandles); in AddDispatcherVector()
91 if (handle_to_entry_map_.size() + dispatchers.size() > kMaxHandleTableSize) in AddDispatcherVector()
94 for (size_t i = 0; i < dispatchers.size(); i++) { in AddDispatcherVector()
95 if (dispatchers[i]) { in AddDispatcherVector()
96 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]); in AddDispatcherVector()
|
| D | multiprocess_message_pipe_unittest.cc | 303 DispatcherVector dispatchers; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN() local
307 &dispatchers, &num_dispatchers, in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
314 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypeSharedBuffer); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
317 static_cast<SharedBufferDispatcher*>(dispatchers[0].get())); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
469 DispatcherVector dispatchers; in MOJO_MULTIPROCESS_TEST_CHILD_MAIN() local
473 &dispatchers, &num_dispatchers, in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
482 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypePlatformHandle); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
485 static_cast<PlatformHandleDispatcher*>(dispatchers[0].get())); in MOJO_MULTIPROCESS_TEST_CHILD_MAIN()
|
| D | message_in_transit.cc | 162 scoped_ptr<DispatcherVector> dispatchers) { in SetDispatchers() argument
163 DCHECK(dispatchers); in SetDispatchers()
167 dispatchers_ = dispatchers.Pass(); in SetDispatchers()
|
| D | dispatcher.cc | 125 DispatcherVector* dispatchers, in ReadMessage() argument
129 (dispatchers && dispatchers->empty())); in ReadMessage()
135 return ReadMessageImplNoLock(bytes, num_bytes, dispatchers, num_dispatchers, in ReadMessage()
|
| D | message_in_transit.h | 157 void SetDispatchers(scoped_ptr<DispatcherVector> dispatchers);
200 DispatcherVector* dispatchers() { return dispatchers_.get(); } in dispatchers() function
|
| D | message_pipe_dispatcher.cc | 203 DispatcherVector* dispatchers, in ReadMessageImplNoLock() argument
215 return message_pipe_->ReadMessage(port_, bytes, num_bytes, dispatchers, in ReadMessageImplNoLock()
|
| D | message_pipe_endpoint.h | 66 DispatcherVector* dispatchers,
|
| D | local_message_pipe_endpoint.h | 36 DispatcherVector* dispatchers,
|
| D | dispatcher.h | 91 DispatcherVector* dispatchers,
221 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 | message_pipe.h | 64 DispatcherVector* dispatchers,
|
| D | message_pipe_dispatcher.h | 88 DispatcherVector* dispatchers,
|
| /external/chromium_org/third_party/skia/gm/rebaseline_server/ |
| D | server.py | 431 dispatchers = {
435 dispatcher = dispatchers[dispatcher_name]
507 dispatchers = {
511 dispatcher = dispatchers[normpath]
|
| /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/ui/events/platform/ |
| D | platform_event_source_unittest.cc | 183 ScopedVector<TestPlatformEventDispatcher> dispatchers; in TEST_F() local
185 dispatchers.push_back( in TEST_F()
|