| /external/libmojo/mojo/edk/system/ |
| D | dispatcher.cc | 18 Dispatcher::DispatcherInTransit::DispatcherInTransit() {} in DispatcherInTransit()
20 Dispatcher::DispatcherInTransit::DispatcherInTransit(
23 Dispatcher::DispatcherInTransit::~DispatcherInTransit() {} in ~DispatcherInTransit()
25 MojoResult Dispatcher::Watch(MojoHandleSignals signals, in Watch()
31 MojoResult Dispatcher::CancelWatch(uintptr_t context) { in CancelWatch()
35 MojoResult Dispatcher::WriteMessage(std::unique_ptr<MessageForTransit> message, in WriteMessage()
40 MojoResult Dispatcher::ReadMessage(std::unique_ptr<MessageForTransit>* message, in ReadMessage()
49 MojoResult Dispatcher::DuplicateBufferHandle( in DuplicateBufferHandle()
51 scoped_refptr<Dispatcher>* new_dispatcher) { in DuplicateBufferHandle()
55 MojoResult Dispatcher::MapBuffer( in MapBuffer()
[all …]
|
| D | dispatcher.h | 33 class Dispatcher; variable
36 using DispatcherVector = std::vector<scoped_refptr<Dispatcher>>;
41 class MOJO_SYSTEM_IMPL_EXPORT Dispatcher
42 : public base::RefCountedThreadSafe<Dispatcher> {
49 scoped_refptr<Dispatcher> dispatcher;
97 scoped_refptr<Dispatcher>* new_dispatcher);
136 const scoped_refptr<Dispatcher>& dispatcher,
143 const scoped_refptr<Dispatcher>& dispatcher);
231 static scoped_refptr<Dispatcher> Deserialize(
241 friend class base::RefCountedThreadSafe<Dispatcher>;
[all …]
|
| D | handle_table.h | 25 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
30 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
33 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle) const;
35 scoped_refptr<Dispatcher>* dispatcher);
43 std::vector<Dispatcher::DispatcherInTransit>* dispatchers);
46 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers);
48 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers);
55 explicit Entry(scoped_refptr<Dispatcher> dispatcher);
59 scoped_refptr<Dispatcher> dispatcher;
|
| D | core.cc | 164 scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) { in GetDispatcher()
216 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
222 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
253 scoped_refptr<Dispatcher> d; in PassWrappedPlatformHandle()
257 if (d->GetType() == Dispatcher::Type::PLATFORM_HANDLE) { in PassWrappedPlatformHandle()
300 scoped_refptr<Dispatcher> dispatcher; in PassSharedMemoryHandle()
308 if (!dispatcher || dispatcher->GetType() != Dispatcher::Type::SHARED_BUFFER) in PassSharedMemoryHandle()
378 scoped_refptr<Dispatcher> dispatcher; in Close()
436 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in Watch()
445 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in CancelWatch()
[all …]
|
| D | handle_table.cc | 18 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
32 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
54 scoped_refptr<Dispatcher> HandleTable::GetDispatcher(MojoHandle handle) const { in GetDispatcher()
63 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher()
78 std::vector<Dispatcher::DispatcherInTransit>* dispatchers) { in BeginTransit()
88 Dispatcher::DispatcherInTransit d; in BeginTransit()
100 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CompleteTransitAndClose()
110 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CancelTransit()
127 HandleTable::Entry::Entry(scoped_refptr<Dispatcher> dispatcher) in Entry()
|
| D | shared_buffer_dispatcher_unittest.cc | 119 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
156 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher->GetType()); in TEST_F()
198 scoped_refptr<Dispatcher> dispatcher2; in TEST_F()
202 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher2->GetType()); in TEST_F()
227 scoped_refptr<Dispatcher> dispatcher2; in TEST_F()
231 EXPECT_EQ(Dispatcher::Type::SHARED_BUFFER, dispatcher2->GetType()); in TEST_F()
252 scoped_refptr<Dispatcher> dispatcher2; in TEST_F()
262 scoped_refptr<Dispatcher> dispatcher2; in TEST_F()
|
| D | wait_set_dispatcher.h | 24 class MOJO_SYSTEM_IMPL_EXPORT WaitSetDispatcher : public Dispatcher {
31 MojoResult AddWaitingDispatcher(const scoped_refptr<Dispatcher>& dispatcher,
35 const scoped_refptr<Dispatcher>& dispatcher) override;
58 scoped_refptr<Dispatcher> dispatcher;
|
| D | platform_handle_dispatcher_unittest.cc | 43 EXPECT_EQ(Dispatcher::Type::PLATFORM_HANDLE, dispatcher->GetType()); in TEST()
102 Dispatcher::Deserialize(Dispatcher::Type::PLATFORM_HANDLE, nullptr, in TEST()
107 EXPECT_TRUE(dispatcher->GetType() == Dispatcher::Type::PLATFORM_HANDLE); in TEST()
|
| D | message_for_transit.cc | 29 const Dispatcher::DispatcherInTransit* dispatchers, in Create()
48 Dispatcher* d = dispatchers[i].dispatcher.get(); in Create()
91 Dispatcher* d = dispatchers[i].dispatcher.get(); in Create()
|
| D | wait_set_dispatcher_unittest.cc | 43 scoped_refptr<Dispatcher>* ready_dispatcher, in GetOneReadyDispatcher()
74 void CloseOnShutdown(const scoped_refptr<Dispatcher>& dispatcher) { in CloseOnShutdown()
145 scoped_refptr<Dispatcher> woken_dispatcher; in TEST_F()
209 scoped_refptr<Dispatcher> woken_dispatcher; in TEST_F()
277 scoped_refptr<Dispatcher> woken_dispatcher; in TEST_F()
434 scoped_refptr<Dispatcher> woken_dispatcher; in TEST_F()
483 scoped_refptr<Dispatcher> woken_dispatcher; in TEST_F()
|
| D | waiter_test_utils.h | 73 WaiterThread(scoped_refptr<Dispatcher> dispatcher,
86 const scoped_refptr<Dispatcher> dispatcher_;
|
| D | shared_buffer_dispatcher.h | 25 class MOJO_SYSTEM_IMPL_EXPORT SharedBufferDispatcher final : public Dispatcher {
74 scoped_refptr<Dispatcher>* new_dispatcher) override;
|
| D | message_pipe_dispatcher.h | 25 class MessagePipeDispatcher : public Dispatcher {
80 static scoped_refptr<Dispatcher> Deserialize(
|
| D | core.h | 53 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle);
89 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
94 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
|
| D | wait_set_dispatcher.cc | 44 Dispatcher::Type WaitSetDispatcher::GetType() const { in GetType()
72 const scoped_refptr<Dispatcher>& dispatcher, in AddWaitingDispatcher()
110 const scoped_refptr<Dispatcher>& dispatcher) { in RemoveWaitingDispatcher()
|
| /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/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
|
| D | OkHttpClient.java | 121 private Dispatcher dispatcher;
150 dispatcher = new Dispatcher(); in OkHttpClient()
473 public OkHttpClient setDispatcher(Dispatcher dispatcher) { in setDispatcher()
479 public Dispatcher getDispatcher() { in getDispatcher()
|
| /external/libchrome/base/ |
| D | observer_list_threadsafe.h | 61 struct Dispatcher;
64 struct Dispatcher<ObserverType, void(ReceiverType::*)(Params...)> {
146 Bind(&internal::Dispatcher<ObserverType, Method>::Run,
|
| /external/v8/src/inspector/ |
| D | v8-inspector-session-impl.cc | 79 protocol::Runtime::Dispatcher::wire(&m_dispatcher, m_runtimeAgent.get()); in V8InspectorSessionImpl()
83 protocol::Debugger::Dispatcher::wire(&m_dispatcher, m_debuggerAgent.get()); in V8InspectorSessionImpl()
87 protocol::Profiler::Dispatcher::wire(&m_dispatcher, m_profilerAgent.get()); in V8InspectorSessionImpl()
91 protocol::HeapProfiler::Dispatcher::wire(&m_dispatcher, in V8InspectorSessionImpl()
96 protocol::Console::Dispatcher::wire(&m_dispatcher, m_consoleAgent.get()); in V8InspectorSessionImpl()
100 protocol::Schema::Dispatcher::wire(&m_dispatcher, m_schemaAgent.get()); in V8InspectorSessionImpl()
|
| /external/okhttp/mockwebserver/ |
| D | README.md | 114 #### Dispatcher subsubsection
117 Dispatcher to handle requests using another policy. One natural policy is to
122 final Dispatcher dispatcher = new Dispatcher() {
|