| /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 | 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 | 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.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,
|
| /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/rtc_base/ |
| D | physical_socket_server.h | 47 class Dispatcher {
49 virtual ~Dispatcher() {} in ~Dispatcher()
80 void Add(Dispatcher* dispatcher);
81 void Remove(Dispatcher* dispatcher);
82 void Update(Dispatcher* dispatcher);
88 typedef std::set<Dispatcher*> DispatcherSet;
96 void AddEpoll(Dispatcher* dispatcher);
97 void RemoveEpoll(Dispatcher* dispatcher);
98 void UpdateEpoll(Dispatcher* dispatcher);
100 bool WaitPoll(int cms, Dispatcher* dispatcher);
[all …]
|
| D | physical_socket_server.cc | 909 class EventDispatcher : public Dispatcher {
977 class EventDispatcher : public Dispatcher {
1101 void PhysicalSocketServer::Add(Dispatcher* pdispatcher) { in Add()
1120 void PhysicalSocketServer::Remove(Dispatcher* pdispatcher) { in Remove()
1149 void PhysicalSocketServer::Update(Dispatcher* pdispatcher) { in Update()
1166 for (Dispatcher* pdispatcher : pending_add_dispatchers_) { in AddRemovePendingDispatchers()
1173 for (Dispatcher* pdispatcher : pending_remove_dispatchers_) { in AddRemovePendingDispatchers()
1196 static void ProcessEvents(Dispatcher* dispatcher, in ProcessEvents()
1284 for (Dispatcher* pdispatcher : dispatchers_) { in WaitSelect()
1327 for (Dispatcher* pdispatcher : dispatchers_) { in WaitSelect()
[all …]
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 34 abstract class Dispatcher { class
46 static Dispatcher perThreadDispatchQueue() { in perThreadDispatchQueue()
56 static Dispatcher legacyAsync() { in legacyAsync()
65 static Dispatcher immediate() { in immediate()
73 private static final class PerThreadQueuedDispatcher extends Dispatcher {
130 private static final class LegacyAsyncDispatcher extends Dispatcher {
179 private static final class ImmediateDispatcher extends Dispatcher {
|
| D | AsyncEventBus.java | 39 super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
52 super("default", executor, Dispatcher.legacyAsync(), subscriberExceptionHandler); in AsyncEventBus()
62 super("default", executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
|
| D | EventBus.java | 105 private final Dispatcher dispatcher;
122 Dispatcher.perThreadDispatchQueue(), in EventBus()
136 Dispatcher.perThreadDispatchQueue(), in EventBus()
143 Dispatcher dispatcher, in EventBus()
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | Dispatcher.java | 34 abstract class Dispatcher { class
46 static Dispatcher perThreadDispatchQueue() { in perThreadDispatchQueue()
56 static Dispatcher legacyAsync() { in legacyAsync()
65 static Dispatcher immediate() { in immediate()
73 private static final class PerThreadQueuedDispatcher extends Dispatcher {
130 private static final class LegacyAsyncDispatcher extends Dispatcher {
179 private static final class ImmediateDispatcher extends Dispatcher {
|
| D | AsyncEventBus.java | 39 super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
52 super("default", executor, Dispatcher.legacyAsync(), subscriberExceptionHandler); in AsyncEventBus()
62 super("default", executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
|
| D | EventBus.java | 105 private final Dispatcher dispatcher;
122 Dispatcher.perThreadDispatchQueue(), in EventBus()
136 Dispatcher.perThreadDispatchQueue(), in EventBus()
143 Dispatcher dispatcher, in EventBus()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | ReactiveStreamTckTest.kt | 17 fun createTests(dispatcher: Dispatcher): Array<Any> { in createTests()
22 …public fun dispatchers(): Array<Array<Any>> = Dispatcher.values().map { arrayOf<Any>(it) }.toTyped… in <lambda>()
26 private val dispatcher: Dispatcher
48 enum class Dispatcher(val dispatcher: CoroutineDispatcher) { class
|
| /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/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 58 private Dispatcher dispatcher;
61 dispatcher = Dispatcher.perThreadDispatchQueue(); in testPerThreadQueuedDispatcher()
80 dispatcher = Dispatcher.legacyAsync(); in testLegacyAsyncDispatcher()
126 dispatcher = Dispatcher.immediate(); in testImmediateDispatcher()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | DispatcherTest.java | 58 private Dispatcher dispatcher;
61 dispatcher = Dispatcher.perThreadDispatchQueue(); in testPerThreadQueuedDispatcher()
80 dispatcher = Dispatcher.legacyAsync(); in testLegacyAsyncDispatcher()
126 dispatcher = Dispatcher.immediate(); in testImmediateDispatcher()
|