blob: 528ad8f1ea0f6ffd0b8b70863b1b26c5d92cb34c [file] [log] [blame]
// WARNING: This file is machine generated by fidlgen.
#include <fidl/test.nullable/cpp/wire_messaging.h>
#include <memory>
namespace test_nullable {
[[maybe_unused]] constexpr uint64_t kSimpleProtocol_Add_Ordinal = 9142761280038437494lu;
[[maybe_unused]] constexpr ::fidl::MessageDynamicFlags kSimpleProtocol_Add_DynamicFlags = ::fidl::MessageDynamicFlags::kStrictMethod;
extern "C" const fidl_type_t test_nullable_SimpleProtocolAddRequestTable;
extern "C" const fidl_type_t test_nullable_SimpleProtocolAddTopResponseTable;
#ifdef __Fuchsia__
} // namespace test_nullable
::fidl::WireResult<::test_nullable::SimpleProtocol::Add>::WireResult(
::fidl::UnownedClientEnd<::test_nullable::SimpleProtocol> client,
::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>* request, std::optional<zx::time> deadline) {
FIDL_INTERNAL_DISABLE_AUTO_VAR_INIT
::fidl::unstable::OwnedEncodedMessage<::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>, ::fidl::internal::ChannelTransport> request_message(
::fidl::internal::AllowUnownedInputRef{}, request);
auto& outgoing = request_message.GetOutgoingMessage();
::fidl::internal::IncomingMessageHandleStorage<::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>> handle_storage;
::fidl::unstable::DecodedMessage<::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>> decoded{
outgoing.Call(
client.handle(), handle_storage.view(bytes_.view()),
deadline.has_value() ? fidl::CallOptions{.deadline = deadline->get()} : fidl::CallOptions{})};
SetStatus(decoded);
if (ok()) {
decoded_ = decoded.Take();
}
}
namespace test_nullable {
#endif // __Fuchsia__
#ifdef __Fuchsia__
} // namespace test_nullable
::fidl::WireUnownedResult<::test_nullable::SimpleProtocol::Add>::WireUnownedResult(::fidl::UnownedClientEnd<::test_nullable::SimpleProtocol> client_end, ::fidl::internal::AnyBufferAllocator& allocator, ::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>* request) {
constexpr uint32_t buffer_size = ::fidl::SyncClientMethodBufferSizeInChannel<::test_nullable::SimpleProtocol::Add>();
::fitx::result<::fidl::Error, ::fidl::BufferSpan> allocation = allocator.TryAllocate(buffer_size);
if (!allocation.is_ok()) {
SetStatus(allocation.error_value());
return;
}
uint8_t* buffer = allocation->data;
constexpr uint32_t request_byte_capacity = ::fidl::MaxSizeInChannel<
::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>, ::fidl::MessageDirection::kSending>();
uint8_t* request_bytes = buffer;
static_assert(buffer_size > request_byte_capacity);
uint32_t response_byte_capacity = buffer_size - request_byte_capacity;
uint8_t* response_bytes = &buffer[request_byte_capacity];
::fidl::unstable::UnownedEncodedMessage<::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>> request_message(
request_bytes, request_byte_capacity, request);
auto& outgoing = request_message.GetOutgoingMessage();
::fidl::internal::IncomingMessageHandleStorage<::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>> handle_storage;
::fidl::unstable::DecodedMessage<::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>> decoded{
outgoing.Call(
client_end.handle(),
handle_storage.view(fidl::BufferSpan(response_bytes, response_byte_capacity)))};
SetStatus(decoded);
if (ok()) {
decoded_ = decoded.Take();
}
}
namespace test_nullable {
#endif // __Fuchsia__
} // namespace test_nullable
#ifdef __Fuchsia__
::fidl::internal::WireThenable<::test_nullable::SimpleProtocol::Add> fidl::internal::WireWeakAsyncClientImpl<::test_nullable::SimpleProtocol>::Add(int32_t a, int32_t b) {
::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add> _request{a, b};
return ::fidl::internal::WireThenable<::test_nullable::SimpleProtocol::Add>{
_client_base(), ::fidl::WriteOptions{}, ::fidl::internal::AllowUnownedInputRef{}, &_request};
}
::fidl::internal::WireBufferThenable<::test_nullable::SimpleProtocol::Add> fidl::internal::WireWeakAsyncBufferClientImpl<::test_nullable::SimpleProtocol>::Add(int32_t a, int32_t b) {
constexpr uint32_t _buffer_size = ::fidl::AsyncClientMethodBufferSizeInChannel<::test_nullable::SimpleProtocol::Add>();
::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add> _request{a, b};
return ::fidl::internal::WireBufferThenable<::test_nullable::SimpleProtocol::Add>{
_client_base(), ::fidl::WriteOptions{}, _allocator(), _buffer_size, &_request};
}
::fidl::WireResult<::test_nullable::SimpleProtocol::Add>
fidl::internal::WireWeakSyncClientImpl<::test_nullable::SimpleProtocol>::Add(int32_t a, int32_t b) {
return _client_base()->MakeSyncCallWith(
[&](std::shared_ptr<::fidl::internal::AnyTransport> _transport) {
::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add> _request{a, b};
return ::fidl::WireResult<::test_nullable::SimpleProtocol::Add>(::fidl::UnownedClientEnd<::test_nullable::SimpleProtocol>(_transport->get<::fidl::internal::ChannelTransport>()), &_request);
});
}
#endif // __Fuchsia__
#ifdef __Fuchsia__
::fidl::Status fidl::WireSyncEventHandler<::test_nullable::SimpleProtocol>::HandleOneEvent(
::fidl::UnownedClientEnd<::test_nullable::SimpleProtocol> client_end) {
::fidl::internal::IncomingEventsStorage<::test_nullable::SimpleProtocol> event_storage;
fidl::internal::WireEventDispatcher<::test_nullable::SimpleProtocol> dispatcher{this};
return HandleOneEventImpl_(client_end.channel(), event_storage.view(), dispatcher);
}
#endif // __Fuchsia__
#ifdef __Fuchsia__
constexpr ::fidl::internal::MethodEntry fidl::internal::WireServerDispatcher<::test_nullable::SimpleProtocol>::entries_[] = {
{
::test_nullable::kSimpleProtocol_Add_Ordinal,
[](void* interface, ::fidl::IncomingMessage&& msg,
internal::MessageStorageViewBase* storage_view, ::fidl::Transaction* txn) {
::fidl::unstable::DecodedMessage<::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>> decoded{std::move(msg)};
if (unlikely(!decoded.ok())) {
return ::fidl::Status{decoded};
}
auto* primary = &decoded.PrimaryObject()->body;
::fidl::internal::WireCompleter<::test_nullable::SimpleProtocol::Add>::Sync completer(txn);
reinterpret_cast<::fidl::WireServer<::test_nullable::SimpleProtocol>*>(interface)->Add(
primary, completer);
return ::fidl::Status::Ok();
},
},
};
const ::fidl::internal::MethodEntry* fidl::internal::WireServerDispatcher<::test_nullable::SimpleProtocol>::entries_end_ =
&entries_[1];
::fidl::DispatchResult fidl::internal::WireServerDispatcher<::test_nullable::SimpleProtocol>::TryDispatch(
::fidl::WireServer<::test_nullable::SimpleProtocol>* impl, ::fidl::IncomingMessage& msg,
internal::MessageStorageViewBase* storage_view, ::fidl::Transaction* txn) {
return ::fidl::internal::TryDispatch(
impl, msg, storage_view, txn, entries_, entries_end_);
}
void fidl::internal::WireServerDispatcher<::test_nullable::SimpleProtocol>::Dispatch(::fidl::WireServer<::test_nullable::SimpleProtocol>* impl, ::fidl::IncomingMessage&& msg,
internal::MessageStorageViewBase* storage_view, ::fidl::Transaction* txn) {
::fidl::internal::Dispatch(impl, msg, storage_view, txn, entries_, entries_end_);
}
void fidl::WireServer<::test_nullable::SimpleProtocol>::dispatch_message(
::fidl::IncomingMessage&& msg, ::fidl::Transaction* txn,
::fidl::internal::MessageStorageViewBase* storage_view) {
::fidl::internal::WireServerDispatcher<::test_nullable::SimpleProtocol>::Dispatch(this, std::move(msg), storage_view, txn);
}
#endif // __Fuchsia__
#ifdef __Fuchsia__
void fidl::internal::WireCompleterImpl<::test_nullable::SimpleProtocol::Add>::Reply(int32_t sum) {
return MakeReply(sum);
}
void fidl::internal::WireCompleterImpl<::test_nullable::SimpleProtocol::Add>::MakeReply(int32_t sum) {
::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add> _response{sum};
FIDL_INTERNAL_DISABLE_AUTO_VAR_INIT
::fidl::unstable::OwnedEncodedMessage<
::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>, ::fidl::internal::ChannelTransport>
_response_message{
::fidl::internal::AllowUnownedInputRef{}, &_response};
return _core()->SendReply(&_response_message.GetOutgoingMessage(),
::fidl::internal::OutgoingTransportContext());
}
void fidl::internal::WireBufferCompleterImpl<::test_nullable::SimpleProtocol::Add>::Reply(int32_t sum) {
return MakeReply(sum);
}
void fidl::internal::WireBufferCompleterImpl<::test_nullable::SimpleProtocol::Add>::MakeReply(int32_t sum) {
::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add> _response{sum};
constexpr uint32_t _buffer_size = ::fidl::ServerReplyBufferSizeInChannel<::test_nullable::SimpleProtocol::Add>();
::fitx::result<::fidl::Error, ::fidl::BufferSpan> _allocation =
_allocator().TryAllocate(_buffer_size);
if (!_allocation.is_ok()) {
::fidl::OutgoingMessage _failure{_allocation.error_value()};
return _core()->SendReply(&_failure, ::fidl::internal::OutgoingTransportContext());
}
::fidl::unstable::UnownedEncodedMessage<
::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>, ::fidl::internal::ChannelTransport>
_response_message(
_allocation->data, _buffer_size, &_response);
return _core()->SendReply(&_response_message.GetOutgoingMessage(),
::fidl::internal::OutgoingTransportContext());
}
#endif // __Fuchsia__
void ::fidl::internal::TransactionalRequest<::test_nullable::SimpleProtocol::Add>::_InitHeader() {
::fidl::InitTxnHeader(&header, 0, ::test_nullable::kSimpleProtocol_Add_Ordinal, ::test_nullable::kSimpleProtocol_Add_DynamicFlags);
}
void ::fidl::internal::TransactionalResponse<::test_nullable::SimpleProtocol::Add>::_InitHeader() {
::fidl::InitTxnHeader(&header, 0, ::test_nullable::kSimpleProtocol_Add_Ordinal, ::test_nullable::kSimpleProtocol_Add_DynamicFlags);
}
#ifdef __Fuchsia__
#endif // __Fuchsia__