/external/chromium_org/mojo/system/ |
local_message_pipe_endpoint.cc | 68 DispatcherVector* dispatchers, 72 DCHECK(!dispatchers || dispatchers->empty()); 93 if (DispatcherVector* queued_dispatchers = message->dispatchers()) { 100 DCHECK(dispatchers); 101 dispatchers->swap(*queued_dispatchers);
|
core.cc | 221 // does not transfer dispatchers from one handle to another, even when sending a 246 // validity, even for dispatchers that don't support |WriteMessage()| and will 254 // We'll need to hold on to the dispatchers so that we can pass them on to 261 // When we pass handles, we have to try to take all their dispatchers' locks 314 DispatcherVector dispatchers; local 316 bytes, num_bytes, &dispatchers, &num_handles_value, flags); 317 if (!dispatchers.empty()) { 320 DCHECK_LE(dispatchers.size(), static_cast<size_t>(num_handles_value)); 324 dispatchers.size()); 328 dispatchers, handles_writer.GetPointer()) 558 DispatcherVector dispatchers; local [all...] |
local_message_pipe_endpoint.h | 36 DispatcherVector* dispatchers,
|
message_pipe_endpoint.h | 47 // a) Dispatchers have been vetted and cloned/attached to the message. 64 DispatcherVector* dispatchers,
|
transport_data.cc | 63 TransportData::TransportData(scoped_ptr<DispatcherVector> dispatchers, 65 DCHECK(dispatchers); 68 const size_t num_handles = dispatchers->size(); 85 if (Dispatcher* dispatcher = (*dispatchers)[i].get()) { 136 Dispatcher* dispatcher = (*dispatchers)[i].get(); 324 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector(num_handles)); 338 (*dispatchers)[i] = Dispatcher::TransportDataAccess::Deserialize( 342 return dispatchers.Pass();
|
handle_table.cc | 76 bool HandleTable::AddDispatcherVector(const DispatcherVector& dispatchers, 78 DCHECK_LE(dispatchers.size(), kMaxMessageNumHandles); 88 if (handle_to_entry_map_.size() + dispatchers.size() > kMaxHandleTableSize) 91 for (size_t i = 0; i < dispatchers.size(); i++) { 92 if (dispatchers[i].get()) { 93 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]); 115 // First verify all the handles and get their dispatchers.
|
message_pipe.cc | 109 DispatcherVector* dispatchers, 118 bytes, num_bytes, dispatchers, num_dispatchers, flags); 206 // Owned by the dispatchers. The owning dispatchers should only release us via 272 // Clone the dispatchers and attach them to the message. (This must be done as 273 // a separate loop, since we want to leave the dispatchers alone on failure.) 274 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector()); 275 dispatchers->reserve(transports->size()); 278 dispatchers->push_back( 282 dispatchers->push_back(scoped_refptr<Dispatcher>()) [all...] |
handle_table.h | 65 // Adds a pair of dispatchers (which must be valid), return a pair of handles 73 // Adds the given vector of dispatchers (of size at most 75 // |dispatchers.size()|. Unlike the other |AddDispatcher...()| functions, some 76 // of the dispatchers may be invalid (null). Returns true on success and false 78 // |handles[...]| untouched (and all dispatchers unadded). 79 bool AddDispatcherVector(const DispatcherVector& dispatchers, 113 // all the dispatchers for the handles that it is sending (and fail with
|
transport_data.h | 35 // - Serialize these dispatchers into the |TransportData|: First, for each 38 // - During the serialization of the dispatchers, |PlatformHandle|s may be 39 // detached from the dispatchers and attached to the |TransportData|. 66 // |PlatformHandle|s (and detaching them). Attach these dispatchers to the 69 // (primarily the data payload) and the attached dispatchers; the 72 // dispatchers to the (global, "core") handle table, getting handles; give 92 TransportData(scoped_ptr<DispatcherVector> dispatchers, Channel* channel); 142 // Deserializes dispatchers from the given (serialized) transport data buffer
|
message_in_transit.h | 161 // Makes this message "own" the given set of dispatchers. The dispatchers must 164 // message must not already have dispatchers. 165 void SetDispatchers(scoped_ptr<DispatcherVector> dispatchers); 168 // there are no dispatchers and no existing |TransportData|. 171 // Serializes any dispatchers to the secondary buffer. This message must not 205 // Gets the dispatchers attached to this message; this may return null if 206 // there are none. Note that the caller may mutate the set of dispatchers 207 // (e.g., take ownership of all the dispatchers, leaving the vector empty). 208 DispatcherVector* dispatchers() { return dispatchers_.get(); function in class:mojo::system::MessageInTransit [all...] |
multiprocess_message_pipe_unittest.cc | 237 DispatcherVector dispatchers; local 242 &dispatchers, 250 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypeSharedBuffer); 253 static_cast<SharedBufferDispatcher*>(dispatchers[0].get())); 429 DispatcherVector dispatchers; local 434 &dispatchers, 444 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypePlatformHandle); 447 static_cast<PlatformHandleDispatcher*>(dispatchers[0].get()));
|
message_pipe.h | 75 DispatcherVector* dispatchers, 110 // dispatchers attached.
|
message_pipe_dispatcher.h | 87 DispatcherVector* dispatchers,
|
core_test_base.cc | 65 DispatcherVector* dispatchers, 73 if (dispatchers) { 75 dispatchers->resize(1);
|
message_in_transit.cc | 163 scoped_ptr<DispatcherVector> dispatchers) { 164 DCHECK(dispatchers); 168 dispatchers_ = dispatchers.Pass(); 209 // Note: If dispatchers are subsequently attached, then |total_size| will have
|
dispatcher.cc | 35 // We shouldn't race with things that close dispatchers, since closing can 122 DispatcherVector* dispatchers, 126 (dispatchers && dispatchers->empty())); 133 bytes, num_bytes, dispatchers, num_dispatchers, flags); 258 // By default, waiting isn't supported. Only dispatchers that can be waited on 265 // This may not need to do anything. Dispatchers should override this to do 276 // By default, not supported. Only needed for message pipe dispatchers. 283 DispatcherVector* /*dispatchers*/, 288 // By default, not supported. Only needed for message pipe dispatchers [all...] |
dispatcher.h | 86 // dispatchers in |transports| must have been moved to a closed state; on 92 // |dispatchers| must be non-null but empty, if |num_dispatchers| is non-null 93 // and nonzero. On success, it will be set to the dispatchers to be received 97 DispatcherVector* dispatchers, 177 // A |TransportData| may serialize dispatchers that are given to it (and which 181 // dispatchers, so there are no locking issues. (There's no lock ordering 192 // dispatchers. (|channel| is the |Channel| to which the dispatcher is to be 242 DispatcherVector* dispatchers, 277 // These implement the API used to serialize dispatchers to a |Channel| 325 // API to serialize dispatchers to a |Channel|, exposed to onl [all...] |
message_pipe_dispatcher.cc | 204 DispatcherVector* dispatchers, 209 port_, bytes, num_bytes, dispatchers, num_dispatchers, flags);
|
/external/chromium_org/third_party/tlslite/tlslite/integration/ |
xmlrpcserver.py | 53 self.dispatchers = {}
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
SimpleXMLRPCServer.py | 616 self.dispatchers = {} 621 self.dispatchers[path] = dispatcher 625 return self.dispatchers[path] 629 response = self.dispatchers[path]._marshaled_dispatch(
|
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
SimpleXMLRPCServer.py | 616 self.dispatchers = {} 621 self.dispatchers[path] = dispatcher 625 return self.dispatchers[path] 629 response = self.dispatchers[path]._marshaled_dispatch(
|
/external/skia/gm/rebaseline_server/ |
server.py | 431 dispatchers = { 435 dispatcher = dispatchers[dispatcher_name] 507 dispatchers = { 511 dispatcher = dispatchers[normpath]
|
/external/chromium_org/third_party/skia/gm/rebaseline_server/ |
server.py | 546 dispatchers = { 552 dispatcher = dispatchers[dispatcher_name] 691 dispatchers = { 696 dispatcher = dispatchers[normpath] [all...] |
/libcore/luni/src/test/java/org/apache/harmony/luni/tests/internal/net/www/protocol/https/ |
HttpsURLConnectionTest.java | [all...] |
/external/chromium_org/ui/events/platform/ |
platform_event_source_unittest.cc | 179 // Tests that dispatchers receive events in the correct order. 183 ScopedVector<TestPlatformEventDispatcher> dispatchers; local 185 dispatchers.push_back( 195 // Tests that if a dispatcher consumes the event, the subsequent dispatchers do 253 // Tests that observers and dispatchers receive events in the correct order. 267 // dispatchers. 289 // Tests that an overridden dispatcher can request that the default dispatchers 392 // event should reach all three dispatchers in the list. 411 // |second| removes itself during dispatch. So both dispatchers will have 431 // event should reach all three dispatchers [all...] |