| // Copyright 2022 The Fuchsia Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include <lib/fidl/llcpp/internal/client_details.h> |
| |
| namespace fidl::internal { |
| |
| fidl::Status SyncEventHandler::HandleOneEventImpl_(zx::unowned_channel channel, |
| ChannelMessageStorageView storage, |
| IncomingEventDispatcherBase& dispatcher) { |
| zx_status_t status = channel->wait_one(ZX_CHANNEL_READABLE | ZX_CHANNEL_PEER_CLOSED, |
| ::zx::time::infinite(), nullptr); |
| if (status != ZX_OK) { |
| return fidl::Status::TransportError(status, kErrorWaitOneFailed); |
| } |
| fidl::IncomingMessage msg = fidl::MessageRead(channel, storage, ReadOptions{.discardable = true}); |
| if (msg.status() == ZX_ERR_BUFFER_TOO_SMALL) { |
| // Message size is unexpectedly larger than calculated. |
| // This can only be due to a newer version of the protocol defining a new event, |
| // whose size exceeds the maximum of known events in the current protocol. |
| return fidl::Status::UnexpectedMessage(ZX_ERR_BUFFER_TOO_SMALL, kErrorSyncEventBufferTooSmall); |
| } |
| if (!msg.ok()) { |
| return msg; |
| } |
| got_transitional_ = false; |
| fidl::Status dispatch_status = dispatcher.DispatchEvent(msg, &storage); |
| if (got_transitional_) { |
| return fidl::Status::UnexpectedMessage(ZX_ERR_NOT_SUPPORTED, |
| kErrorSyncEventUnhandledTransitionalEvent); |
| } |
| return dispatch_status; |
| } |
| |
| void SyncEventHandler::OnTransitionalEvent_() { |
| ZX_DEBUG_ASSERT(!got_transitional_); |
| got_transitional_ = true; |
| } |
| |
| fidl::Status IncomingEventDispatcherBase::DispatchEvent( |
| fidl::IncomingMessage& msg, internal::MessageStorageViewBase* storage_view) { |
| return fidl::Status::UnknownOrdinal(); |
| } |
| |
| } // namespace fidl::internal |
