/fuchsia/zircon/system/ulib/async/include/lib/async/ |
H A D | receiver.h | 17 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 D | dispatcher.h | 96 zx_status_t (*queue_packet)(async_dispatcher_t* dispatcher, async_receiver_t* receiver,
|
/fuchsia/zircon/system/utest/async/ |
H A D | receiver_tests.cpp | 5 #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 D | receiver.h | 8 #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 D | exception.h | 12 // 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 D | receiver.cpp | 5 #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 D | ops.c | 5 #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 D | rules.mk | 25 $(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 D | mq.c | 67 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 D | dispatcher_stub.cpp | 31 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 D | dispatcher_stub.h | 23 virtual zx_status_t QueuePacket(async_receiver_t* receiver,
|
/fuchsia/zircon/system/ulib/async-loop/ |
H A D | loop.c | 21 #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 D | loop_tests.cpp | 14 #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 D | c_generator.cpp | 282 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 D | client.h | 14 #include <lib/async/cpp/receiver.h>
|