Searched refs:receiver (Results 1 - 15 of 15) sorted by relevance

/fuchsia/zircon/system/ulib/async/include/lib/async/
H A Dreceiver.h17 async_receiver_t* receiver,
21 // Holds content for a packet receiver and its handler.
23 // After successfully queuing packets to the receiver, the client is responsible
28 // Multiple packets may be delivered to the same receiver concurrently.
37 // Enqueues a packet of data for delivery to a receiver.
47 zx_status_t async_queue_packet(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
H A Ddispatcher.h96 zx_status_t (*queue_packet)(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
/fuchsia/zircon/system/utest/async/
H A Dreceiver_tests.cpp5 #include <lib/async/cpp/receiver.h>
19 zx_status_t QueuePacket(async_receiver_t* receiver,
22 last_receiver = receiver;
44 void Handler(async_dispatcher_t* dispatcher, async::ReceiverBase* receiver, argument
47 last_receiver = receiver;
52 virtual async::ReceiverBase& receiver() = 0;
62 async::ReceiverBase& receiver() override { return receiver_; }
65 async::Receiver receiver_{[this](async_dispatcher_t* dispatcher, async::Receiver* receiver, variable
67 Handler(dispatcher, receiver, status, data);
73 async::ReceiverBase& receiver() overrid
83 async::Receiver receiver; local
[all...]
/fuchsia/zircon/system/ulib/async/include/lib/async/cpp/
H A Dreceiver.h8 #include <lib/async/receiver.h>
12 // Holds content for a packet receiver and its handler.
14 // After successfully queuing packets to the receiver, the client is responsible
19 // Multiple packets may be delivered to the same receiver concurrently.
34 // Enqueues a packet of data for delivery to a receiver.
46 static T* Dispatch(async_receiver_t* receiver) { argument
48 auto self = reinterpret_cast<ReceiverBase*>(receiver);
56 // A receiver whose handler is bound to a |async::Task::Handler| function.
67 async::Receiver* receiver,
78 static void CallHandler(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
102 CallHandler(async_dispatcher_t* dispatcher, async_receiver_t* receiver, zx_status_t status, const zx_packet_user_t* data) argument
[all...]
H A Dexception.h12 // Holds content for an exception packet receiver and its handler.
18 // Multiple packets may be delivered to the same receiver concurrently.
63 // A receiver whose handler is bound to a |async::Task::Handler| function.
89 // A receiver whose handler is bound to a fixed class member function.
94 // void Handle(async_dispatcher_t* dispatcher, async::ExceptionBase* receiver, zx_status_t status,
99 void (Class::*method)(async_dispatcher_t* dispatcher, async::ExceptionBase* receiver,
/fuchsia/zircon/system/ulib/async/
H A Dreceiver.cpp5 #include <lib/async/cpp/receiver.h>
23 void Receiver::CallHandler(async_dispatcher_t* dispatcher, async_receiver_t* receiver, argument
25 auto self = Dispatch<Receiver>(receiver);
H A Dops.c5 #include <lib/async/receiver.h>
31 zx_status_t async_queue_packet(async_dispatcher_t* dispatcher, async_receiver_t* receiver, argument
33 return dispatcher->ops->v1.queue_packet(dispatcher, receiver, data);
H A Drules.mk25 $(LOCAL_INC)/receiver.h \
51 $(LOCAL_DIR)/receiver.cpp \
59 $(LOCAL_INC)/cpp/receiver.h \
/fuchsia/zircon/third_party/ulib/jemalloc/test/unit/
H A Dmq.c67 thd_t receiver; local
73 thd_create(&receiver, thd_receiver_start, (void *)&mq);
77 thd_join(receiver, NULL);
/fuchsia/zircon/system/ulib/async-testutils/
H A Ddispatcher_stub.cpp31 zx_status_t stub_queue_packet(async_dispatcher_t* dispatcher, async_receiver_t* receiver, argument
33 return static_cast<DispatcherStub*>(dispatcher)->QueuePacket(receiver, data);
97 zx_status_t DispatcherStub::QueuePacket(async_receiver_t* receiver, argument
/fuchsia/zircon/system/ulib/async-testutils/include/lib/async-testutils/
H A Ddispatcher_stub.h23 virtual zx_status_t QueuePacket(async_receiver_t* receiver,
/fuchsia/zircon/system/ulib/async-loop/
H A Dloop.c21 #include <lib/async/receiver.h>
34 static zx_status_t async_loop_queue_packet(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
96 static zx_status_t async_loop_dispatch_packet(async_loop_t* loop, async_receiver_t* receiver,
283 async_receiver_t* receiver = (void*)(uintptr_t)packet.key; local
284 return async_loop_dispatch_packet(loop, receiver, packet.status, &packet.user);
397 static zx_status_t async_loop_dispatch_packet(async_loop_t* loop, async_receiver_t* receiver, argument
401 receiver->handler((async_dispatcher_t*)loop, receiver, status, data);
591 static zx_status_t async_loop_queue_packet(async_dispatcher_t* async, async_receiver_t* receiver, argument
595 ZX_DEBUG_ASSERT(receiver);
[all...]
/fuchsia/zircon/system/utest/async-loop/
H A Dloop_tests.cpp14 #include <lib/async/receiver.h>
243 static void CallHandler(async_dispatcher_t* dispatcher, async_receiver_t* receiver, argument
245 static_cast<TestReceiver*>(receiver)->Handle(dispatcher, status, data);
286 async_exception_t* receiver,
289 static_cast<TestException*>(receiver)->Handle(dispatcher, status, report);
778 TestReceiver receiver; local
779 EXPECT_EQ(ZX_ERR_BAD_STATE, receiver.QueuePacket(loop.dispatcher(), nullptr), "queue after shutdown");
780 EXPECT_EQ(0u, receiver.run_count, "run count 1");
956 // This receiver's handler will run concurrently on multiple threads
979 // This receiver'
285 CallHandler(async_dispatcher_t* dispatcher, async_exception_t* receiver, zx_status_t status, const zx_port_packet_t* report) argument
[all...]
/fuchsia/zircon/system/host/fidl/lib/
H A Dc_generator.cpp282 StringView receiver,
286 *file << kIndent << "uint32_t _next = sizeof(*" << receiver << ");\n"; local
291 *file << kIndent << "memcpy(" << receiver << "->" << name << ", "
292 << name << ", sizeof(" << receiver << "->" << name << "));\n";
295 *file << kIndent << receiver << "->" << name << ".data = &" << bytes << "[_next];\n";
296 *file << kIndent << receiver << "->" << name << ".count = " << name << "_count;\n";
297 *file << kIndent << "memcpy(" << receiver << "->" << name << ".data, " << name << "_data, sizeof(*" << name << "_data) * " << name << "_count);\n";
301 *file << kIndent << receiver << "->" << name << ".data = &" << bytes << "[_next];\n";
302 *file << kIndent << receiver << "->" << name << ".size = " << name << "_size;\n";
303 *file << kIndent << "memcpy(" << receiver << "
281 EmitLinearizeMessage(std::ostream* file, StringView receiver, StringView bytes, const std::vector<CGenerator::Member>& request) argument
[all...]
/fuchsia/zircon/system/dev/display/display/
H A Dclient.h14 #include <lib/async/cpp/receiver.h>

Completed in 109 milliseconds