Home
last modified time | relevance | path

Searched refs:Dispatcher (Results 1 – 25 of 69) sorted by relevance

123

/external/libmojo/mojo/edk/system/
Ddispatcher.cc18 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 …]
Ddispatcher.h33 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 …]
Dhandle_table.h25 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;
Dhandle_table.cc18 MojoHandle HandleTable::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
31 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
53 scoped_refptr<Dispatcher> HandleTable::GetDispatcher(MojoHandle handle) const { in GetDispatcher()
62 scoped_refptr<Dispatcher>* dispatcher) { in GetAndRemoveDispatcher()
77 std::vector<Dispatcher::DispatcherInTransit>* dispatchers) { in BeginTransit()
87 Dispatcher::DispatcherInTransit d; in BeginTransit()
99 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CompleteTransitAndClose()
109 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers) { in CancelTransit()
126 HandleTable::Entry::Entry(scoped_refptr<Dispatcher> dispatcher) in Entry()
Dcore.cc164 scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) { in GetDispatcher()
194 MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) { in AddDispatcher()
200 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers, in AddDispatchersFromTransit()
231 scoped_refptr<Dispatcher> d; in PassWrappedPlatformHandle()
235 if (d->GetType() == Dispatcher::Type::PLATFORM_HANDLE) { in PassWrappedPlatformHandle()
278 scoped_refptr<Dispatcher> dispatcher; in PassSharedMemoryHandle()
286 if (!dispatcher || dispatcher->GetType() != Dispatcher::Type::SHARED_BUFFER) in PassSharedMemoryHandle()
364 scoped_refptr<Dispatcher> dispatcher; in Close()
422 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in Watch()
431 scoped_refptr<Dispatcher> dispatcher = GetDispatcher(handle); in CancelWatch()
[all …]
Dshared_buffer_dispatcher_unittest.cc119 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()
Dwait_set_dispatcher.h24 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;
Dplatform_handle_dispatcher_unittest.cc43 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()
Dmessage_for_transit.cc29 const Dispatcher::DispatcherInTransit* dispatchers, in Create()
48 Dispatcher* d = dispatchers[i].dispatcher.get(); in Create()
91 Dispatcher* d = dispatchers[i].dispatcher.get(); in Create()
Dwaiter_test_utils.h73 WaiterThread(scoped_refptr<Dispatcher> dispatcher,
86 const scoped_refptr<Dispatcher> dispatcher_;
Dwait_set_dispatcher_unittest.cc43 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()
Dshared_buffer_dispatcher.h26 class MOJO_SYSTEM_IMPL_EXPORT SharedBufferDispatcher final : public Dispatcher {
75 scoped_refptr<Dispatcher>* new_dispatcher) override;
Dmessage_pipe_dispatcher.h26 class MessagePipeDispatcher : public Dispatcher {
81 static scoped_refptr<Dispatcher> Deserialize(
Dcore.h52 scoped_refptr<Dispatcher> GetDispatcher(MojoHandle handle);
78 MojoHandle AddDispatcher(scoped_refptr<Dispatcher> dispatcher);
83 const std::vector<Dispatcher::DispatcherInTransit>& dispatchers,
Dwait_set_dispatcher.cc44 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/
Dwrapped_handler.hpp27 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/
Dphysicalsocketserver.h42 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 {
Dphysicalsocketserver.cc764 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/
DCustomDispatcherTest.java40 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/
DCustomDispatcherTest.java40 final Dispatcher dispatcher = new Dispatcher() { in simpleDispatch()
63 final Dispatcher dispatcher = new Dispatcher() { in outOfOrderResponses()
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DDispatcher.java36 public final class Dispatcher { class
52 public Dispatcher(ExecutorService executorService) { in Dispatcher() method in Dispatcher
56 public Dispatcher() { in Dispatcher() method in Dispatcher
/external/mockito/lib/
Dbyte-buddy-1.6.9.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/maven/ META- ...
/external/v8/src/inspector/
Dv8-inspector-session-impl.cc74 protocol::Runtime::Dispatcher::wire(&m_dispatcher, m_runtimeAgent.get()); in V8InspectorSessionImpl()
78 protocol::Debugger::Dispatcher::wire(&m_dispatcher, m_debuggerAgent.get()); in V8InspectorSessionImpl()
82 protocol::Profiler::Dispatcher::wire(&m_dispatcher, m_profilerAgent.get()); in V8InspectorSessionImpl()
86 protocol::HeapProfiler::Dispatcher::wire(&m_dispatcher, in V8InspectorSessionImpl()
91 protocol::Console::Dispatcher::wire(&m_dispatcher, m_consoleAgent.get()); in V8InspectorSessionImpl()
95 protocol::Schema::Dispatcher::wire(&m_dispatcher, m_schemaAgent.get()); in V8InspectorSessionImpl()
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DOkHttpAsync.java19 import com.squareup.okhttp.Dispatcher;
52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, in prepare()
/external/okhttp/mockwebserver/
DREADME.md114 #### Dispatcher subsubsection
117 Dispatcher to handle requests using another policy. One natural policy is to
122 final Dispatcher dispatcher = new Dispatcher() {

123