| /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 | 183 // does not transfer dispatchers from one handle to another, even when sending a
208 // validity, even for dispatchers that don't support |WriteMessage()| and will
216 // We'll need to hold on to the dispatchers so that we can pass them on to
223 // When we pass handles, we have to try to take all their dispatchers' locks
274 DispatcherVector dispatchers;
276 &dispatchers, num_handles,
278 if (!dispatchers.empty()) {
281 DCHECK_LE(dispatchers.size(), static_cast<size_t>(*num_handles));
286 success = handle_table_.AddDispatcherVector(dispatchers, handles);
289 LOG(ERROR) << "Received message with " << dispatchers.size(
520 DispatcherVector dispatchers; local
[all...] |
| message_pipe.cc | 88 DispatcherVector* dispatchers,
96 return endpoints_[port]->ReadMessage(bytes, num_bytes, dispatchers,
193 // Owned by the dispatchers. The owning dispatchers should only release us via
259 // Clone the dispatchers and attach them to the message. (This must be done as
260 // a separate loop, since we want to leave the dispatchers alone on failure.)
261 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector());
262 dispatchers->reserve(transports->size());
265 dispatchers->push_back(
269 dispatchers->push_back(scoped_refptr<Dispatcher>())
[all...] |
| local_message_pipe_endpoint.h | 36 DispatcherVector* dispatchers,
|
| message_pipe_endpoint.h | 49 // a) Dispatchers have been vetted and cloned/attached to the message.
66 DispatcherVector* dispatchers,
|
| transport_data.cc | 65 TransportData::TransportData(scoped_ptr<DispatcherVector> dispatchers,
67 DCHECK(dispatchers);
70 const size_t num_handles = dispatchers->size();
87 if (Dispatcher* dispatcher = (*dispatchers)[i].get()) {
139 Dispatcher* dispatcher = (*dispatchers)[i].get();
323 scoped_ptr<DispatcherVector> dispatchers(new DispatcherVector(num_handles));
337 (*dispatchers)[i] = Dispatcher::TransportDataAccess::Deserialize(
341 return dispatchers.Pass();
|
| handle_table.cc | 79 bool HandleTable::AddDispatcherVector(const DispatcherVector& dispatchers,
81 DCHECK_LE(dispatchers.size(), kMaxMessageNumHandles);
91 if (handle_to_entry_map_.size() + dispatchers.size() > kMaxHandleTableSize)
94 for (size_t i = 0; i < dispatchers.size(); i++) {
95 if (dispatchers[i]) {
96 handles[i] = AddDispatcherNoSizeCheck(dispatchers[i]);
118 // First verify all the handles and get their dispatchers.
|
| 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 | 153 // Makes this message "own" the given set of dispatchers. The dispatchers must
156 // message must not already have dispatchers.
157 void SetDispatchers(scoped_ptr<DispatcherVector> dispatchers);
160 // there are no dispatchers and no existing |TransportData|.
163 // Serializes any dispatchers to the secondary buffer. This message must not
197 // Gets the dispatchers attached to this message; this may return null if
198 // there are none. Note that the caller may mutate the set of dispatchers
199 // (e.g., take ownership of all the dispatchers, leaving the vector empty).
200 DispatcherVector* dispatchers() { return dispatchers_.get(); function in class:mojo::system::MessageInTransit
[all...] |
| multiprocess_message_pipe_unittest.cc | 303 DispatcherVector dispatchers; local
307 &dispatchers, &num_dispatchers,
314 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypeSharedBuffer);
317 static_cast<SharedBufferDispatcher*>(dispatchers[0].get()));
469 DispatcherVector dispatchers; local
473 &dispatchers, &num_dispatchers,
482 CHECK_EQ(dispatchers[0]->GetType(), Dispatcher::kTypePlatformHandle);
485 static_cast<PlatformHandleDispatcher*>(dispatchers[0].get()));
|
| dispatcher.cc | 36 // We shouldn't race with things that close dispatchers, since closing can
125 DispatcherVector* dispatchers,
129 (dispatchers && dispatchers->empty()));
135 return ReadMessageImplNoLock(bytes, num_bytes, dispatchers, num_dispatchers,
246 // By default, waiting isn't supported. Only dispatchers that can be waited on
253 // This may not need to do anything. Dispatchers should override this to do
264 // By default, not supported. Only needed for message pipe dispatchers.
270 DispatcherVector* /*dispatchers*/,
275 // By default, not supported. Only needed for message pipe dispatchers
[all...] |
| message_pipe.h | 64 DispatcherVector* dispatchers,
96 // dispatchers attached.
|
| message_pipe_dispatcher.h | 88 DispatcherVector* dispatchers,
|
| message_in_transit.cc | 104 // Note: If dispatchers are subsequently attached, then |total_size| will have
162 scoped_ptr<DispatcherVector> dispatchers) {
163 DCHECK(dispatchers);
167 dispatchers_ = dispatchers.Pass();
|
| dispatcher.h | 80 // dispatchers in |transports| must have been moved to a closed state; on
86 // |dispatchers| must be non-null but empty, if |num_dispatchers| is non-null
87 // and nonzero. On success, it will be set to the dispatchers to be received
91 DispatcherVector* dispatchers,
156 // A |TransportData| may serialize dispatchers that are given to it (and which
160 // dispatchers, so there are no locking issues. (There's no lock ordering
171 // dispatchers. (|channel| is the |Channel| to which the dispatcher is to be
221 DispatcherVector* dispatchers,
251 // These implement the API used to serialize dispatchers to a |Channel|
299 // API to serialize dispatchers to a |Channel|, exposed to onl
[all...] |
| message_pipe_dispatcher.cc | 203 DispatcherVector* dispatchers,
215 return message_pipe_->ReadMessage(port_, bytes, num_bytes, dispatchers,
|
| /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/chromium_org/third_party/skia/gm/rebaseline_server/ |
| server.py | 431 dispatchers = {
435 dispatcher = dispatchers[dispatcher_name]
507 dispatchers = {
511 dispatcher = dispatchers[normpath]
|
| /external/skia/gm/rebaseline_server/ |
| server.py | 431 dispatchers = {
435 dispatcher = dispatchers[dispatcher_name]
507 dispatchers = {
511 dispatcher = dispatchers[normpath]
|
| /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...] |
| /prebuilts/tools/common/m2/repository/org/gradle/gradle-tooling-api/1.10/ |
| gradle-tooling-api-1.10.jar | |
