| /external/libchrome/mojo/core/ |
| D | dispatcher.cc | 19 Dispatcher::DispatcherInTransit::DispatcherInTransit() {} in DispatcherInTransit()
21 Dispatcher::DispatcherInTransit::DispatcherInTransit(
24 Dispatcher::DispatcherInTransit::~DispatcherInTransit() {} in ~DispatcherInTransit()
26 MojoResult Dispatcher::WatchDispatcher(scoped_refptr<Dispatcher> dispatcher, in WatchDispatcher()
33 MojoResult Dispatcher::CancelWatch(uintptr_t context) { in CancelWatch()
37 MojoResult Dispatcher::Arm(uint32_t* num_blocking_events, in Arm()
42 MojoResult Dispatcher::WriteMessage( in WriteMessage()
47 MojoResult Dispatcher::ReadMessage( in ReadMessage()
52 MojoResult Dispatcher::DuplicateBufferHandle( in DuplicateBufferHandle()
54 scoped_refptr<Dispatcher>* new_dispatcher) { in DuplicateBufferHandle()
[all …]
|
| D | dispatcher.h | 39 class Dispatcher; variable
42 using DispatcherVector = std::vector<scoped_refptr<Dispatcher>>;
46 class MOJO_SYSTEM_IMPL_EXPORT Dispatcher
47 : public base::RefCountedThreadSafe<Dispatcher> {
54 scoped_refptr<Dispatcher> dispatcher;
78 virtual MojoResult WatchDispatcher(scoped_refptr<Dispatcher> dispatcher,
101 scoped_refptr<Dispatcher>* new_dispatcher);
207 static scoped_refptr<Dispatcher> Deserialize(Type type,
216 friend class base::RefCountedThreadSafe<Dispatcher>;
218 Dispatcher();
[all …]
|
| D | handle_table.h | 32 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
37 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
40 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle) const;
42 scoped_refptr<Dispatcher>* dispatcher);
50 std::vector<Dispatcher::DispatcherInTransit>* dispatchers);
53 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers);
55 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers);
68 explicit Entry(scoped_refptr<Dispatcher> dispatcher);
72 scoped_refptr<Dispatcher> dispatcher;
|
| D | handle_table.cc | 51 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
65 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
90 scoped_refptr<Dispatcher> HandleTable::GetDispatcher(MojoHandle handle) const { in GetDispatcher()
99 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher()
114 std::vector<Dispatcher::DispatcherInTransit>* dispatchers) { in BeginTransit()
123 Dispatcher::DispatcherInTransit d; in BeginTransit()
135 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CompleteTransitAndClose()
145 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CancelTransit()
196 HandleTable::Entry::Entry(scoped_refptr<Dispatcher> dispatcher) in Entry()
|
| D | core.cc | 160 scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) { in GetDispatcher()
165 scoped_refptr<Dispatcher> Core::GetAndRemoveDispatcher(MojoHandle handle) { in GetAndRemoveDispatcher()
166 scoped_refptr<Dispatcher> dispatcher; in GetAndRemoveDispatcher()
228 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
234 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
255 std::vector<Dispatcher::DispatcherInTransit>* dispatchers) { in AcquireDispatchersForTransit()
264 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in ReleaseDispatchersForTransit()
293 scoped_refptr<Dispatcher> dispatcher; in Close()
308 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in QueryHandleSignalsState()
340 scoped_refptr<Dispatcher> watcher = GetDispatcher(trap_handle); in AddTrigger()
[all …]
|
| D | shared_buffer_dispatcher_unittest.cc | 117 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
154 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
193 scoped_refptr<Dispatcher> dispatcher2; in TEST_F()
197 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher2->GetType()); in TEST_F()
226 scoped_refptr<Dispatcher> writable_duped_dispatcher1; in TEST_F()
227 scoped_refptr<Dispatcher> read_only_duped_dispatcher1; in TEST_F()
231 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, in TEST_F()
243 scoped_refptr<Dispatcher> read_only_duped_dispatcher2; in TEST_F()
244 scoped_refptr<Dispatcher> writable_duped_dispatcher2; in TEST_F()
249 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, in TEST_F()
[all …]
|
| D | watcher_dispatcher.h | 27 class WatcherDispatcher : public Dispatcher {
34 void NotifyHandleState(Dispatcher* dispatcher,
36 void NotifyHandleClosed(Dispatcher* dispatcher);
48 MojoResult WatchDispatcher(scoped_refptr<Dispatcher> dispatcher,
80 base::flat_map<Dispatcher*, scoped_refptr<Watch>> watched_handles_;
|
| D | watch.h | 18 class Dispatcher; variable
32 const scoped_refptr<Dispatcher>& dispatcher,
66 const scoped_refptr<Dispatcher>& dispatcher() const { return dispatcher_; } in dispatcher()
97 const scoped_refptr<Dispatcher> dispatcher_;
|
| D | platform_handle_dispatcher_unittest.cc | 43 EXPECT_EQ(Dispatcher::Type::PLATFORM_HANDLE, dispatcher->GetType()); in TEST()
103 Dispatcher::Deserialize(Dispatcher::Type::PLATFORM_HANDLE, nullptr, in TEST()
109 EXPECT_TRUE(dispatcher->GetType() == Dispatcher::Type::PLATFORM_HANDLE); in TEST()
|
| D | core.h | 59 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle);
60 scoped_refptr<Dispatcher> GetAndRemoveDispatcher(MojoHandle handle);
122 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
127 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
137 std::vector<Dispatcher::DispatcherInTransit>* dispatchers);
147 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
|
| D | watcher_dispatcher.cc | 21 void WatcherDispatcher::NotifyHandleState(Dispatcher* dispatcher, in NotifyHandleState()
40 void WatcherDispatcher::NotifyHandleClosed(Dispatcher* dispatcher) { in NotifyHandleClosed()
93 Dispatcher::Type WatcherDispatcher::GetType() const { in GetType()
120 scoped_refptr<Dispatcher> dispatcher, in WatchDispatcher()
|
| D | user_message_impl.cc | 80 const Dispatcher::DispatcherInTransit* new_dispatchers, in CreateOrExtendSerializedEventMessage()
124 Dispatcher* d = new_dispatchers[i].dispatcher.get(); in CreateOrExtendSerializedEventMessage()
214 Dispatcher* d = new_dispatchers[i].dispatcher.get(); in CreateOrExtendSerializedEventMessage()
351 const Dispatcher::DispatcherInTransit* dispatchers, in CreateEventForNewSerializedMessage()
456 std::vector<Dispatcher::DispatcherInTransit> dispatchers; in AppendData()
575 std::vector<Dispatcher::DispatcherInTransit> dispatchers( in ExtractSerializedHandles()
596 auto type = static_cast<Dispatcher::Type>(dh.type); in ExtractSerializedHandles()
623 dispatchers[i].dispatcher = Dispatcher::Deserialize( in ExtractSerializedHandles()
|
| D | watcher_set.h | 26 explicit WatcherSet(Dispatcher* owner);
60 Dispatcher* const owner_;
|
| D | handle_table_unittest.cc | 28 class FakeMessagePipeDispatcher : public Dispatcher {
59 scoped_refptr<Dispatcher> dispatcher(new FakeMessagePipeDispatcher); in TEST()
|
| D | shared_buffer_dispatcher.h | 25 class MOJO_SYSTEM_IMPL_EXPORT SharedBufferDispatcher final : public Dispatcher {
79 scoped_refptr<Dispatcher>* new_dispatcher) override;
|
| D | message_pipe_dispatcher.h | 25 class MessagePipeDispatcher : public Dispatcher {
74 static scoped_refptr<Dispatcher> Deserialize(const void* data,
|
| /external/libchrome/libchrome_tools/patch/ |
| D | handle_table.patch | 17 -const char* GetNameForDispatcherType(Dispatcher::Type type) {
19 - case Dispatcher::Type::UNKNOWN:
21 - case Dispatcher::Type::MESSAGE_PIPE:
23 - case Dispatcher::Type::DATA_PIPE_PRODUCER:
25 - case Dispatcher::Type::DATA_PIPE_CONSUMER:
27 - case Dispatcher::Type::SHARED_BUFFER:
29 - case Dispatcher::Type::WATCHER:
31 - case Dispatcher::Type::PLATFORM_HANDLE:
33 - case Dispatcher::Type::INVITATION:
39 +// const char* GetNameForDispatcherType(Dispatcher::Type type) {
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | wrapped_handler.hpp | 27 template <typename Dispatcher, typename Handler>
28 bool operator()(Dispatcher&, Handler& handler) const in operator ()()
36 template <typename Dispatcher, typename Handler>
37 bool operator()(Dispatcher& dispatcher, Handler&) const in operator ()()
43 template <typename Dispatcher, typename Handler,
50 wrapped_handler(Dispatcher dispatcher, Handler& handler) in wrapped_handler()
149 Dispatcher dispatcher_;
196 template <typename Dispatcher, typename Handler, typename IsContinuation>
198 wrapped_handler<Dispatcher, Handler, IsContinuation>* this_handler) in asio_handler_allocate() argument
204 template <typename Dispatcher, typename Handler, typename IsContinuation>
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | physicalsocketserver.h | 42 class Dispatcher {
44 virtual ~Dispatcher() {} in ~Dispatcher()
78 void Add(Dispatcher* dispatcher);
79 void Remove(Dispatcher* dispatcher);
97 Dispatcher* signal_dispatcher();
101 typedef std::vector<Dispatcher*> DispatcherList;
185 class SocketDispatcher : public Dispatcher, public PhysicalSocket {
|
| D | physicalsocketserver.cc | 764 class EventDispatcher : public Dispatcher {
930 class PosixSignalDispatcher : public Dispatcher {
999 class FileDispatcher: public Dispatcher, public AsyncFile {
1070 class EventDispatcher : public Dispatcher {
1192 void PhysicalSocketServer::Add(Dispatcher *pdispatcher) { in Add()
1203 void PhysicalSocketServer::Remove(Dispatcher *pdispatcher) { in Remove()
1272 Dispatcher *pdispatcher = dispatchers_[i]; in Wait()
1311 Dispatcher *pdispatcher = dispatchers_[i]; in Wait()
1415 Dispatcher* PhysicalSocketServer::signal_dispatcher() { in signal_dispatcher()
1452 std::vector<Dispatcher *> event_owners; in Wait()
[all …]
|
| /external/mockwebserver/src/test/java/com/google/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in testSimpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in testOutOfOrderResponses()
|
| /external/okhttp/mockwebserver/src/test/java/com/squareup/okhttp/mockwebserver/ |
| D | CustomDispatcherTest.java | 40 final Dispatcher dispatcher = new Dispatcher() { in simpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in outOfOrderResponses()
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/ |
| D | Dispatcher.java | 38 public final class Dispatcher { class
54 public Dispatcher(ExecutorService executorService) { in Dispatcher() method in Dispatcher
58 public Dispatcher() { in Dispatcher() method in Dispatcher
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Dispatcher.java | 36 public final class Dispatcher { class
52 public Dispatcher(ExecutorService executorService) { in Dispatcher() method in Dispatcher
56 public Dispatcher() { in Dispatcher() method in Dispatcher
|
| /external/libchrome/base/ |
| D | observer_list_threadsafe.h | 66 struct Dispatcher;
69 struct Dispatcher<ObserverType, void (ReceiverType::*)(Params...)> {
164 Bind(&Dispatcher<ObserverType, Method>::Run, m,
|