| // Copyright 2016 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 <assert.h> |
| #include <fcntl.h> |
| #include <fuchsia/device/c/fidl.h> |
| #include <fuchsia/device/llcpp/fidl.h> |
| #include <fuchsia/device/manager/c/fidl.h> |
| #include <fuchsia/device/manager/llcpp/fidl.h> |
| #include <fuchsia/io/c/fidl.h> |
| #include <lib/fdio/io.h> |
| #include <lib/fdio/vfs.h> |
| #include <lib/fidl/coding.h> |
| #include <lib/fidl/txn_header.h> |
| #include <lib/sync/completion.h> |
| #include <lib/zircon-internal/debug.h> |
| #include <lib/zx/channel.h> |
| #include <stdbool.h> |
| #include <stdio.h> |
| #include <stdlib.h> |
| #include <string.h> |
| #include <threads.h> |
| #include <zircon/device/vfs.h> |
| #include <zircon/processargs.h> |
| #include <zircon/status.h> |
| #include <zircon/syscalls.h> |
| #include <zircon/types.h> |
| |
| #include <array> |
| #include <new> |
| #include <utility> |
| |
| #include <ddk/device.h> |
| #include <ddk/driver.h> |
| #include <fbl/auto_lock.h> |
| #include <src/storage/deprecated-fs-fidl-handler/fidl-handler.h> |
| |
| #include "devfs-connection.h" |
| #include "devhost.h" |
| #include "zx-device.h" |
| |
| namespace devmgr { |
| |
| namespace { |
| |
| // A one-way message which may be emitted by the server without an |
| // accompanying request. Optionally used as a part of the Open handshake. |
| struct OnOpenMsg { |
| fuchsia_io_NodeOnOpenEvent primary; |
| fuchsia_io_NodeInfo extra; |
| }; |
| |
| zx_status_t SendOnOpenEvent(zx_handle_t ch, OnOpenMsg msg, zx_handle_t* handles, |
| uint32_t num_handles) { |
| msg.primary.hdr.flags[0] |= FIDL_TXN_HEADER_UNION_FROM_XUNION_FLAG; |
| auto contains_nodeinfo = bool(msg.primary.info); |
| uint32_t msg_size = contains_nodeinfo ? sizeof(msg) : sizeof(msg.primary); |
| fidl::Message fidl_msg(fidl::BytePart(reinterpret_cast<uint8_t*>(&msg), msg_size, msg_size), |
| fidl::HandlePart(handles, num_handles, num_handles)); |
| return fidl_msg.WriteTransformV1(ch, 0, &fuchsia_io_NodeOnOpenEventTable); |
| } |
| |
| } // namespace |
| |
| #define ZXDEBUG 0 |
| |
| #define CAN_WRITE(conn) (conn->flags & ZX_FS_RIGHT_WRITABLE) |
| #define CAN_READ(conn) (conn->flags & ZX_FS_RIGHT_READABLE) |
| |
| void describe_error(zx::channel h, zx_status_t status) { |
| OnOpenMsg msg; |
| memset(&msg, 0, sizeof(msg)); |
| fidl_init_txn_header(&msg.primary.hdr, 0, fuchsia_io_NodeOnOpenOrdinal); |
| msg.primary.s = status; |
| SendOnOpenEvent(h.get(), msg, nullptr, 0); |
| } |
| |
| static zx_status_t create_description(const fbl::RefPtr<zx_device_t>& dev, OnOpenMsg* msg, |
| zx::eventpair* handle) { |
| memset(msg, 0, sizeof(*msg)); |
| fidl_init_txn_header(&msg->primary.hdr, 0, fuchsia_io_NodeOnOpenOrdinal); |
| msg->extra.tag = fuchsia_io_NodeInfoTag_device; |
| msg->primary.s = ZX_OK; |
| msg->primary.info = (fuchsia_io_NodeInfo*)FIDL_ALLOC_PRESENT; |
| handle->reset(); |
| zx_handle_t* event = &msg->extra.device.event; |
| if (dev->event.is_valid()) { |
| zx_status_t r; |
| if ((r = dev->event.duplicate(ZX_RIGHTS_BASIC, handle)) != ZX_OK) { |
| msg->primary.s = r; |
| return r; |
| } |
| *event = FIDL_HANDLE_PRESENT; |
| } else { |
| *event = FIDL_HANDLE_ABSENT; |
| } |
| |
| return ZX_OK; |
| } |
| |
| zx_status_t devhost_device_connect(const fbl::RefPtr<zx_device_t>& dev, uint32_t flags, |
| zx::channel rh) { |
| zx_status_t r; |
| // detect response directives and discard all other |
| // protocol flags |
| bool describe = flags & ZX_FS_FLAG_DESCRIBE; |
| flags &= (~ZX_FS_FLAG_DESCRIBE); |
| |
| auto newconn = fbl::MakeRefCounted<DevfsConnection>(); |
| if (!newconn) { |
| r = ZX_ERR_NO_MEMORY; |
| if (describe) { |
| describe_error(std::move(rh), r); |
| } |
| return r; |
| } |
| |
| newconn->flags = flags; |
| |
| fbl::RefPtr<zx_device_t> new_dev; |
| r = device_open(dev, &new_dev, flags); |
| if (r != ZX_OK) { |
| goto fail; |
| } |
| newconn->dev = new_dev; |
| |
| if (describe) { |
| OnOpenMsg info; |
| zx::eventpair handle; |
| if ((r = create_description(new_dev, &info, &handle)) != ZX_OK) { |
| goto fail_open; |
| } |
| uint32_t hcount = (handle.is_valid()) ? 1 : 0; |
| zx_handle_t raw_handles[] = { |
| handle.release(), |
| }; |
| |
| r = SendOnOpenEvent(rh.get(), info, raw_handles, hcount); |
| if (r != ZX_OK) { |
| goto fail_open; |
| } |
| } |
| |
| // If we can't add the new conn and handle to the dispatcher our only option |
| // is to give up and tear down. In practice, this should never happen. |
| if ((r = devhost_start_connection(std::move(newconn), std::move(rh))) != ZX_OK) { |
| // TODO(teisenbe/kulakowski): Should this be goto fail_open? |
| goto fail; |
| } |
| return ZX_OK; |
| |
| fail_open: |
| device_close(std::move(new_dev), flags); |
| fail: |
| if (describe) { |
| describe_error(std::move(rh), r); |
| } |
| return r; |
| } |
| |
| #define DO_READ 0 |
| #define DO_WRITE 1 |
| |
| static ssize_t do_sync_io(const fbl::RefPtr<zx_device_t>& dev, uint32_t opcode, void* buf, |
| size_t count, zx_off_t off) { |
| size_t actual; |
| zx_status_t r; |
| if (opcode == DO_READ) { |
| r = dev->ReadOp(buf, count, off, &actual); |
| } else { |
| r = dev->WriteOp(buf, count, off, &actual); |
| } |
| if (r < 0) { |
| return r; |
| } else { |
| return actual; |
| } |
| } |
| |
| static zx_status_t fidl_node_clone(void* ctx, uint32_t flags, zx_handle_t object) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| zx::channel c(object); |
| flags = conn->flags | (flags & ZX_FS_FLAG_DESCRIBE); |
| devhost_device_connect(conn->dev, flags, std::move(c)); |
| return ZX_OK; |
| } |
| |
| static zx_status_t fidl_node_close(void* ctx, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| // Call device_close to let the driver execute its close hook. This may |
| // be the last reference to the device, causing it to be destroyed. |
| device_close(conn->dev, conn->flags); |
| |
| fuchsia_io_NodeClose_reply(txn, ZX_OK); |
| return ERR_DISPATCHER_DONE; |
| } |
| |
| static zx_status_t fidl_node_describe(void* ctx, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| const auto& dev = conn->dev; |
| fuchsia_io_NodeInfo info; |
| memset(&info, 0, sizeof(info)); |
| info.tag = fuchsia_io_NodeInfoTag_device; |
| if (dev->event != ZX_HANDLE_INVALID) { |
| zx::eventpair event; |
| zx_status_t status = dev->event.duplicate(ZX_RIGHTS_BASIC, &event); |
| if (status != ZX_OK) { |
| return status; |
| } |
| zx_handle_t* event_handle = &info.device.event; |
| *event_handle = event.release(); |
| } |
| return fuchsia_io_NodeDescribe_reply(txn, &info); |
| } |
| |
| static zx_status_t fidl_directory_open(void* ctx, uint32_t flags, uint32_t mode, |
| const char* path_data, size_t path_size, |
| zx_handle_t object) { |
| zx_handle_close(object); |
| return ZX_ERR_NOT_SUPPORTED; |
| } |
| |
| static zx_status_t fidl_directory_unlink(void* ctx, const char* path_data, size_t path_size, |
| fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryUnlink_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_readdirents(void* ctx, uint64_t max_out, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryReadDirents_reply(txn, ZX_ERR_NOT_SUPPORTED, nullptr, 0); |
| } |
| |
| static zx_status_t fidl_directory_rewind(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryRewind_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_gettoken(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryGetToken_reply(txn, ZX_ERR_NOT_SUPPORTED, ZX_HANDLE_INVALID); |
| } |
| |
| static zx_status_t fidl_directory_rename(void* ctx, const char* src_data, size_t src_size, |
| zx_handle_t dst_parent_token, const char* dst_data, |
| size_t dst_size, fidl_txn_t* txn) { |
| zx_handle_close(dst_parent_token); |
| return fuchsia_io_DirectoryRename_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_link(void* ctx, const char* src_data, size_t src_size, |
| zx_handle_t dst_parent_token, const char* dst_data, |
| size_t dst_size, fidl_txn_t* txn) { |
| zx_handle_close(dst_parent_token); |
| return fuchsia_io_DirectoryLink_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_watch(void* ctx, uint32_t mask, uint32_t options, |
| zx_handle_t raw_watcher, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| auto dev = conn->dev; |
| zx::channel watcher(raw_watcher); |
| |
| const zx::channel& rpc = *dev->coordinator_rpc; |
| if (!rpc.is_valid()) { |
| return fuchsia_io_DirectoryWatch_reply(txn, ZX_ERR_INTERNAL); |
| } |
| |
| auto response = fuchsia::device::manager::Coordinator::Call::DirectoryWatch( |
| zx::unowned_channel(rpc.get()), mask, options, std::move(watcher)); |
| zx_status_t status = response.status(); |
| zx_status_t call_status = ZX_OK; |
| if (status == ZX_OK && response.Unwrap()->result.is_err()) { |
| call_status = response.Unwrap()->result.err(); |
| } |
| |
| return fuchsia_io_DirectoryWatch_reply(txn, status != ZX_OK ? status : call_status); |
| } |
| |
| static const fuchsia_io_Directory_ops_t kDirectoryOps = []() { |
| fuchsia_io_Directory_ops_t ops; |
| ops.Open = fidl_directory_open; |
| ops.Unlink = fidl_directory_unlink; |
| ops.ReadDirents = fidl_directory_readdirents; |
| ops.Rewind = fidl_directory_rewind; |
| ops.GetToken = fidl_directory_gettoken; |
| ops.Rename = fidl_directory_rename; |
| ops.Link = fidl_directory_link; |
| ops.Watch = fidl_directory_watch; |
| return ops; |
| }(); |
| |
| static zx_status_t fidl_directory_admin_mount(void* ctx, zx_handle_t h, fidl_txn_t* txn) { |
| zx_handle_close(h); |
| return fuchsia_io_DirectoryAdminMount_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_admin_mount_and_create(void* ctx, zx_handle_t h, const char* name, |
| size_t len, uint32_t flags, |
| fidl_txn_t* txn) { |
| zx_handle_close(h); |
| return fuchsia_io_DirectoryAdminMountAndCreate_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_admin_unmount(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryAdminUnmount_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_directory_admin_unmount_node(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryAdminUnmountNode_reply(txn, ZX_ERR_NOT_SUPPORTED, ZX_HANDLE_INVALID); |
| } |
| |
| static zx_status_t fidl_directory_admin_query_filesystem(void* ctx, fidl_txn_t* txn) { |
| fuchsia_io_FilesystemInfo info; |
| memset(&info, 0, sizeof(info)); |
| const char* devhost_name = "devfs:host"; |
| strlcpy((char*)info.name, devhost_name, fuchsia_io_MAX_FS_NAME_BUFFER); |
| return fuchsia_io_DirectoryAdminQueryFilesystem_reply(txn, ZX_OK, &info); |
| } |
| |
| static zx_status_t fidl_directory_admin_get_device_path(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_DirectoryAdminGetDevicePath_reply(txn, ZX_ERR_NOT_SUPPORTED, NULL, 0); |
| } |
| |
| static const fuchsia_io_DirectoryAdmin_ops_t kDirectoryAdminOps = []() { |
| fuchsia_io_DirectoryAdmin_ops_t ops; |
| ops.Mount = fidl_directory_admin_mount; |
| ops.MountAndCreate = fidl_directory_admin_mount_and_create; |
| ops.Unmount = fidl_directory_admin_unmount; |
| ops.UnmountNode = fidl_directory_admin_unmount_node; |
| ops.QueryFilesystem = fidl_directory_admin_query_filesystem; |
| ops.GetDevicePath = fidl_directory_admin_get_device_path; |
| return ops; |
| }(); |
| |
| static zx_status_t fidl_file_read(void* ctx, uint64_t count, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| const auto& dev = conn->dev; |
| if (!CAN_READ(conn)) { |
| return fuchsia_io_FileRead_reply(txn, ZX_ERR_ACCESS_DENIED, nullptr, 0); |
| } else if (count > ZXFIDL_MAX_MSG_BYTES) { |
| return fuchsia_io_FileRead_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0); |
| } |
| |
| uint8_t data[count]; |
| size_t actual = 0; |
| zx_status_t status = ZX_OK; |
| ssize_t r = do_sync_io(dev, DO_READ, data, count, conn->io_off); |
| if (r >= 0) { |
| conn->io_off += r; |
| actual = r; |
| } else { |
| status = static_cast<zx_status_t>(r); |
| } |
| return fuchsia_io_FileRead_reply(txn, status, data, actual); |
| } |
| |
| static zx_status_t fidl_file_readat(void* ctx, uint64_t count, uint64_t offset, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| if (!CAN_READ(conn)) { |
| return fuchsia_io_FileReadAt_reply(txn, ZX_ERR_ACCESS_DENIED, nullptr, 0); |
| } else if (count > ZXFIDL_MAX_MSG_BYTES) { |
| return fuchsia_io_FileReadAt_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0); |
| } |
| |
| uint8_t data[count]; |
| size_t actual = 0; |
| zx_status_t status = ZX_OK; |
| ssize_t r = do_sync_io(conn->dev, DO_READ, data, count, offset); |
| if (r >= 0) { |
| actual = r; |
| } else { |
| status = static_cast<zx_status_t>(r); |
| } |
| return fuchsia_io_FileReadAt_reply(txn, status, data, actual); |
| } |
| |
| static zx_status_t fidl_file_write(void* ctx, const uint8_t* data, size_t count, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| if (!CAN_WRITE(conn)) { |
| return fuchsia_io_FileWrite_reply(txn, ZX_ERR_ACCESS_DENIED, 0); |
| } |
| size_t actual = 0; |
| zx_status_t status = ZX_OK; |
| ssize_t r = do_sync_io(conn->dev, DO_WRITE, (uint8_t*)data, count, conn->io_off); |
| if (r >= 0) { |
| conn->io_off += r; |
| actual = r; |
| } else { |
| status = static_cast<zx_status_t>(r); |
| } |
| return fuchsia_io_FileWrite_reply(txn, status, actual); |
| } |
| |
| static zx_status_t fidl_file_writeat(void* ctx, const uint8_t* data, size_t count, uint64_t offset, |
| fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| if (!CAN_WRITE(conn)) { |
| return fuchsia_io_FileWriteAt_reply(txn, ZX_ERR_ACCESS_DENIED, 0); |
| } |
| |
| size_t actual = 0; |
| zx_status_t status = ZX_OK; |
| ssize_t r = do_sync_io(conn->dev, DO_WRITE, (uint8_t*)data, count, offset); |
| if (r >= 0) { |
| actual = r; |
| } else { |
| status = static_cast<zx_status_t>(r); |
| } |
| return fuchsia_io_FileWriteAt_reply(txn, status, actual); |
| } |
| |
| static zx_status_t fidl_file_seek(void* ctx, int64_t offset, fuchsia_io_SeekOrigin start, |
| fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| auto bad_args = [&]() { return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, 0); }; |
| size_t end = conn->dev->GetSizeOp(); |
| size_t n; |
| switch (start) { |
| case fuchsia_io_SeekOrigin_START: |
| if ((offset < 0) || ((size_t)offset > end)) { |
| return bad_args(); |
| } |
| n = offset; |
| break; |
| case fuchsia_io_SeekOrigin_CURRENT: |
| // TODO: track seekability with flag, don't update off |
| // at all on read/write if not seekable |
| n = conn->io_off + offset; |
| if (offset < 0) { |
| // if negative seek |
| if (n > conn->io_off) { |
| // wrapped around |
| return bad_args(); |
| } |
| } else { |
| // positive seek |
| if (n < conn->io_off) { |
| // wrapped around |
| return bad_args(); |
| } |
| } |
| break; |
| case fuchsia_io_SeekOrigin_END: |
| n = end + offset; |
| if (offset <= 0) { |
| // if negative or exact-end seek |
| if (n > end) { |
| // wrapped around |
| return bad_args(); |
| } |
| } else { |
| if (n < end) { |
| // wrapped around |
| return bad_args(); |
| } |
| } |
| break; |
| default: |
| return bad_args(); |
| } |
| if (n > end) { |
| // devices may not seek past the end |
| return bad_args(); |
| } |
| conn->io_off = n; |
| return fuchsia_io_FileSeek_reply(txn, ZX_OK, conn->io_off); |
| } |
| |
| static zx_status_t fidl_file_truncate(void* ctx, uint64_t length, fidl_txn_t* txn) { |
| return fuchsia_io_FileTruncate_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_file_getflags(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_FileGetFlags_reply(txn, ZX_ERR_NOT_SUPPORTED, 0); |
| } |
| |
| static zx_status_t fidl_file_setflags(void* ctx, uint32_t flags, fidl_txn_t* txn) { |
| return fuchsia_io_FileSetFlags_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_file_getbuffer(void* ctx, uint32_t flags, fidl_txn_t* txn) { |
| return fuchsia_io_FileGetBuffer_reply(txn, ZX_ERR_NOT_SUPPORTED, nullptr); |
| } |
| |
| static const fuchsia_io_File_ops_t kFileOps = []() { |
| fuchsia_io_File_ops_t ops; |
| ops.Read = fidl_file_read; |
| ops.ReadAt = fidl_file_readat; |
| ops.Write = fidl_file_write; |
| ops.WriteAt = fidl_file_writeat; |
| ops.Seek = fidl_file_seek; |
| ops.Truncate = fidl_file_truncate; |
| ops.GetFlags = fidl_file_getflags; |
| ops.SetFlags = fidl_file_setflags; |
| ops.GetBuffer = fidl_file_getbuffer; |
| return ops; |
| }(); |
| |
| static zx_status_t fidl_node_sync(void* ctx, fidl_txn_t* txn) { |
| // TODO(ZX-3294): We may want to support sync through the block |
| // protocol, but in the interim, it is unsupported. |
| return fuchsia_io_NodeSync_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_node_getattr(void* ctx, fidl_txn_t* txn) { |
| auto conn = static_cast<DevfsConnection*>(ctx); |
| fuchsia_io_NodeAttributes attributes; |
| memset(&attributes, 0, sizeof(attributes)); |
| attributes.mode = V_TYPE_CDEV | V_IRUSR | V_IWUSR; |
| attributes.content_size = conn->dev->GetSizeOp(); |
| attributes.link_count = 1; |
| return fuchsia_io_NodeGetAttr_reply(txn, ZX_OK, &attributes); |
| } |
| |
| static zx_status_t fidl_node_setattr(void* ctx, uint32_t flags, |
| const fuchsia_io_NodeAttributes* attributes, fidl_txn_t* txn) { |
| return fuchsia_io_NodeSetAttr_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_node_getflags(void* ctx, fidl_txn_t* txn) { |
| return fuchsia_io_NodeSetAttr_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static zx_status_t fidl_node_setflags(void* ctx, uint32_t flags, fidl_txn_t* txn) { |
| return fuchsia_io_NodeSetAttr_reply(txn, ZX_ERR_NOT_SUPPORTED); |
| } |
| |
| static const fuchsia_io_Node_ops_t kNodeOps = { |
| .Clone = fidl_node_clone, |
| .Close = fidl_node_close, |
| .Describe = fidl_node_describe, |
| .Sync = fidl_node_sync, |
| .GetAttr = fidl_node_getattr, |
| .SetAttr = fidl_node_setattr, |
| .NodeGetFlags = fidl_node_getflags, |
| .NodeSetFlags = fidl_node_setflags, |
| }; |
| |
| zx_status_t devhost_fidl_handler(fidl_msg_t* msg, fidl_txn_t* txn, void* cookie) { |
| zx_status_t status = fuchsia_io_Node_try_dispatch(cookie, txn, msg, &kNodeOps); |
| if (status != ZX_ERR_NOT_SUPPORTED) { |
| return status; |
| } |
| status = fuchsia_io_File_try_dispatch(cookie, txn, msg, &kFileOps); |
| if (status != ZX_ERR_NOT_SUPPORTED) { |
| return status; |
| } |
| status = fuchsia_io_Directory_try_dispatch(cookie, txn, msg, &kDirectoryOps); |
| if (status != ZX_ERR_NOT_SUPPORTED) { |
| return status; |
| } |
| status = fuchsia_io_DirectoryAdmin_try_dispatch(cookie, txn, msg, &kDirectoryAdminOps); |
| if (status != ZX_ERR_NOT_SUPPORTED) { |
| return status; |
| } |
| auto* conn = static_cast<DevfsConnection*>(cookie); |
| devmgr::Transaction transaction(txn); |
| bool dispatched = llcpp::fuchsia::device::Controller::TryDispatch(conn, msg, &transaction); |
| status = transaction.Status(); |
| if (dispatched) { |
| if (status != ZX_ERR_NOT_SUPPORTED) { |
| return status; |
| } |
| } |
| |
| auto ddk_connection = Connection::FromTxn(txn)->ToDdkConnection(); |
| return conn->dev->MessageOp(msg, ddk_connection.Txn()); |
| } |
| |
| } // namespace devmgr |