| // Copyright 2017 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 <fs/connection.h> |
| |
| #include <fcntl.h> |
| #include <limits.h> |
| #include <stdint.h> |
| #include <stdlib.h> |
| #include <string.h> |
| #include <sys/stat.h> |
| |
| #include <fs/trace.h> |
| #include <fs/vnode.h> |
| #include <fuchsia/io/c/fidl.h> |
| #include <lib/fdio/debug.h> |
| #include <lib/fdio/io.h> |
| #include <lib/fdio/remoteio.h> |
| #include <lib/fdio/vfs.h> |
| #include <lib/zx/handle.h> |
| #include <zircon/assert.h> |
| |
| #define ZXDEBUG 0 |
| |
| namespace fs { |
| namespace { |
| |
| void WriteDescribeError(zx::channel channel, zx_status_t status) { |
| zxrio_describe_t msg; |
| memset(&msg, 0, sizeof(msg)); |
| msg.hdr.ordinal = ZXFIDL_ON_OPEN; |
| msg.status = status; |
| channel.write(0, &msg, sizeof(zxrio_describe_t), nullptr, 0); |
| } |
| |
| zx_status_t GetNodeInfo(const fbl::RefPtr<Vnode>& vn, uint32_t flags, |
| zxrio_node_info_t* info) { |
| if (IsPathOnly(flags)) { |
| return vn->Vnode::GetHandles(flags, &info->handle, &info->tag, info); |
| } else { |
| return vn->GetHandles(flags, &info->handle, &info->tag, info); |
| } |
| } |
| |
| void Describe(const fbl::RefPtr<Vnode>& vn, uint32_t flags, |
| zxrio_describe_t* response, zx_handle_t* handle) { |
| response->hdr.ordinal = ZXFIDL_ON_OPEN; |
| response->extra.handle = ZX_HANDLE_INVALID; |
| zx_status_t r = GetNodeInfo(vn, flags, &response->extra); |
| *handle = response->extra.handle; |
| |
| // If a handle was returned, encode it. |
| if (*handle != ZX_HANDLE_INVALID) { |
| response->extra.handle = FIDL_HANDLE_PRESENT; |
| } else { |
| response->extra.handle = FIDL_HANDLE_ABSENT; |
| } |
| |
| // If a valid response was returned, encode it. |
| response->status = r; |
| response->extra_ptr = reinterpret_cast<zxrio_node_info_t*>(r == ZX_OK ? |
| FIDL_ALLOC_PRESENT : |
| FIDL_ALLOC_ABSENT); |
| } |
| |
| void FilterFlags(uint32_t flags, uint32_t* out_flags, bool* out_describe) { |
| // Filter out flags that are invalid when combined with REF_ONLY. |
| if (IsPathOnly(flags)) { |
| flags &= ZX_FS_FLAG_VNODE_REF_ONLY | ZX_FS_FLAG_DIRECTORY | ZX_FS_FLAG_DESCRIBE; |
| } |
| |
| *out_describe = flags & ZX_FS_FLAG_DESCRIBE; |
| *out_flags = flags & (~ZX_FS_FLAG_DESCRIBE); |
| } |
| |
| void VnodeServe(Vfs* vfs, fbl::RefPtr<Vnode> vnode, zx::channel channel, uint32_t open_flags) { |
| if (IsPathOnly(open_flags)) { |
| vnode->Vnode::Serve(vfs, fbl::move(channel), open_flags); |
| } else { |
| vnode->Serve(vfs, fbl::move(channel), open_flags); |
| } |
| } |
| |
| // Performs a path walk and opens a connection to another node. |
| void OpenAt(Vfs* vfs, fbl::RefPtr<Vnode> parent, zx::channel channel, |
| fbl::StringPiece path, uint32_t flags, uint32_t mode) { |
| bool describe; |
| uint32_t open_flags; |
| FilterFlags(flags, &open_flags, &describe); |
| |
| fbl::RefPtr<Vnode> vnode; |
| zx_status_t r = vfs->Open(fbl::move(parent), &vnode, path, &path, open_flags, mode); |
| |
| if (r != ZX_OK) { |
| xprintf("vfs: open: r=%d\n", r); |
| } else if (!(open_flags & ZX_FS_FLAG_NOREMOTE) && vnode->IsRemote()) { |
| // Remote handoff to a remote filesystem node. |
| vfs->ForwardOpenRemote(fbl::move(vnode), fbl::move(channel), fbl::move(path), |
| flags, mode); |
| return; |
| } |
| |
| if (describe) { |
| // Regardless of the error code, in the 'describe' case, we |
| // should respond to the client. |
| if (r != ZX_OK) { |
| WriteDescribeError(fbl::move(channel), r); |
| return; |
| } |
| |
| zxrio_describe_t response; |
| memset(&response, 0, sizeof(response)); |
| zx_handle_t extra = ZX_HANDLE_INVALID; |
| Describe(vnode, flags, &response, &extra); |
| uint32_t hcount = (extra != ZX_HANDLE_INVALID) ? 1 : 0; |
| channel.write(0, &response, sizeof(zxrio_describe_t), &extra, hcount); |
| } else if (r != ZX_OK) { |
| return; |
| } |
| |
| VnodeServe(vfs, fbl::move(vnode), fbl::move(channel), open_flags); |
| } |
| |
| // This template defines a mechanism to transform a member of Connection |
| // into a FIDL-dispatch operation compatible format, independent of |
| // FIDL arguments. |
| // |
| // For example: |
| // |
| // ZXFIDL_OPERATION(Foo) |
| // |
| // Defines the following method: |
| // |
| // zx_status_t FooOp(void* ctx, Args... args); |
| // |
| // That invokes: |
| // |
| // zx_status_t Connection::Foo(Args... args); |
| // |
| // Such that FooOp may be used in the fuchsia_io_* ops table. |
| #define ZXFIDL_OPERATION(Method) \ |
| template <typename... Args> \ |
| zx_status_t Method ## Op(void* ctx, Args... args) { \ |
| TRACE_DURATION("vfs", #Method); \ |
| auto connection = reinterpret_cast<Connection*>(ctx); \ |
| return (connection->Connection::Method)(fbl::forward<Args>(args)...); \ |
| } |
| |
| ZXFIDL_OPERATION(NodeClone) |
| ZXFIDL_OPERATION(NodeClose) |
| ZXFIDL_OPERATION(NodeDescribe) |
| ZXFIDL_OPERATION(NodeSync) |
| ZXFIDL_OPERATION(NodeGetAttr) |
| ZXFIDL_OPERATION(NodeSetAttr) |
| ZXFIDL_OPERATION(NodeIoctl) |
| |
| const fuchsia_io_Node_ops kNodeOps = { |
| .Clone = NodeCloneOp, |
| .Close = NodeCloseOp, |
| .Describe = NodeDescribeOp, |
| .Sync = NodeSyncOp, |
| .GetAttr = NodeGetAttrOp, |
| .SetAttr = NodeSetAttrOp, |
| .Ioctl = NodeIoctlOp, |
| }; |
| |
| ZXFIDL_OPERATION(FileRead) |
| ZXFIDL_OPERATION(FileReadAt) |
| ZXFIDL_OPERATION(FileWrite) |
| ZXFIDL_OPERATION(FileWriteAt) |
| ZXFIDL_OPERATION(FileSeek) |
| ZXFIDL_OPERATION(FileTruncate) |
| ZXFIDL_OPERATION(FileGetFlags) |
| ZXFIDL_OPERATION(FileSetFlags) |
| ZXFIDL_OPERATION(FileGetVmo) |
| |
| const fuchsia_io_File_ops kFileOps = { |
| .Clone = NodeCloneOp, |
| .Close = NodeCloseOp, |
| .Describe = NodeDescribeOp, |
| .Sync = NodeSyncOp, |
| .GetAttr = NodeGetAttrOp, |
| .SetAttr = NodeSetAttrOp, |
| .Ioctl = NodeIoctlOp, |
| .Read = FileReadOp, |
| .ReadAt = FileReadAtOp, |
| .Write = FileWriteOp, |
| .WriteAt = FileWriteAtOp, |
| .Seek = FileSeekOp, |
| .Truncate = FileTruncateOp, |
| .GetFlags = FileGetFlagsOp, |
| .SetFlags = FileSetFlagsOp, |
| .GetVmo = FileGetVmoOp, |
| }; |
| |
| ZXFIDL_OPERATION(DirectoryOpen) |
| ZXFIDL_OPERATION(DirectoryUnlink) |
| ZXFIDL_OPERATION(DirectoryReadDirents) |
| ZXFIDL_OPERATION(DirectoryRewind) |
| ZXFIDL_OPERATION(DirectoryGetToken) |
| ZXFIDL_OPERATION(DirectoryRename) |
| ZXFIDL_OPERATION(DirectoryLink) |
| |
| const fuchsia_io_Directory_ops kDirectoryOps { |
| .Clone = NodeCloneOp, |
| .Close = NodeCloseOp, |
| .Describe = NodeDescribeOp, |
| .Sync = NodeSyncOp, |
| .GetAttr = NodeGetAttrOp, |
| .SetAttr = NodeSetAttrOp, |
| .Ioctl = NodeIoctlOp, |
| .Open = DirectoryOpenOp, |
| .Unlink = DirectoryUnlinkOp, |
| .ReadDirents = DirectoryReadDirentsOp, |
| .Rewind = DirectoryRewindOp, |
| .GetToken = DirectoryGetTokenOp, |
| .Rename = DirectoryRenameOp, |
| .Link = DirectoryLinkOp, |
| }; |
| |
| } // namespace |
| |
| constexpr zx_signals_t kWakeSignals = ZX_CHANNEL_READABLE | |
| ZX_CHANNEL_PEER_CLOSED | kLocalTeardownSignal; |
| |
| Connection::Connection(Vfs* vfs, fbl::RefPtr<Vnode> vnode, |
| zx::channel channel, uint32_t flags) |
| : vfs_(vfs), vnode_(fbl::move(vnode)), channel_(fbl::move(channel)), |
| wait_(this, ZX_HANDLE_INVALID, kWakeSignals), flags_(flags) { |
| ZX_DEBUG_ASSERT(vfs); |
| ZX_DEBUG_ASSERT(vnode_); |
| ZX_DEBUG_ASSERT(channel_); |
| } |
| |
| Connection::~Connection() { |
| // Stop waiting and clean up if still connected. |
| if (wait_.is_pending()) { |
| zx_status_t status = wait_.Cancel(); |
| ZX_DEBUG_ASSERT_MSG(status == ZX_OK, "Could not cancel wait: status=%d", status); |
| } |
| |
| // Invoke a "close" call to the underlying object if we haven't already. |
| if (is_open()) { |
| CallClose(); |
| } |
| |
| // Release the token associated with this connection's vnode since the connection |
| // will be releasing the vnode's reference once this function returns. |
| if (token_) { |
| vfs_->TokenDiscard(fbl::move(token_)); |
| } |
| } |
| |
| void Connection::AsyncTeardown() { |
| if (channel_) { |
| ZX_ASSERT(channel_.signal(0, kLocalTeardownSignal) == ZX_OK); |
| } |
| } |
| |
| void Connection::SyncTeardown() { |
| if (wait_.Cancel() == ZX_OK) { |
| Terminate(/* call_close= */ true); |
| } |
| } |
| |
| zx_status_t Connection::Serve() { |
| wait_.set_object(channel_.get()); |
| return wait_.Begin(vfs_->dispatcher()); |
| } |
| |
| void Connection::HandleSignals(async_dispatcher_t* dispatcher, async::WaitBase* wait, zx_status_t status, |
| const zx_packet_signal_t* signal) { |
| ZX_DEBUG_ASSERT(is_open()); |
| |
| if (status == ZX_OK) { |
| if (vfs_->IsTerminating()) { |
| // Short-circuit locally destroyed connections, rather than servicing |
| // requests on their behalf. This prevents new requests from being |
| // opened while filesystems are torn down. |
| status = ZX_ERR_PEER_CLOSED; |
| } else if (signal->observed & ZX_CHANNEL_READABLE) { |
| // Handle the message. |
| status = CallHandler(); |
| switch (status) { |
| case ERR_DISPATCHER_ASYNC: |
| return; |
| case ZX_OK: |
| status = wait_.Begin(dispatcher); |
| if (status == ZX_OK) { |
| return; |
| } |
| break; |
| } |
| } |
| } |
| |
| bool call_close = (status != ERR_DISPATCHER_DONE); |
| Terminate(call_close); |
| } |
| |
| void Connection::Terminate(bool call_close) { |
| if (call_close) { |
| // Give the dispatcher a chance to clean up. |
| CallClose(); |
| } else { |
| // It's assumed that someone called the close handler |
| // prior to calling this function. |
| set_closed(); |
| } |
| |
| // Tell the VFS that the connection closed remotely. |
| // This might have the side-effect of destroying this object. |
| vfs_->OnConnectionClosedRemotely(this); |
| } |
| |
| zx_status_t Connection::CallHandler() { |
| return zxfidl_handler(channel_.get(), &Connection::HandleMessageThunk, this); |
| } |
| |
| void Connection::CallClose() { |
| channel_.reset(); |
| CallHandler(); |
| set_closed(); |
| } |
| |
| zx_status_t Connection::HandleMessageThunk(fidl_msg_t* msg, fidl_txn_t* txn, void* cookie) { |
| Connection* connection = static_cast<Connection*>(cookie); |
| return connection->HandleMessage(msg, txn); |
| } |
| |
| // Flags which can be modified by SetFlags. |
| constexpr uint32_t kSettableStatusFlags = ZX_FS_FLAG_APPEND; |
| |
| // All flags which indicate state of the |
| // connection (excluding rights). |
| constexpr uint32_t kStatusFlags = kSettableStatusFlags | ZX_FS_FLAG_VNODE_REF_ONLY; |
| |
| zx_status_t Connection::NodeClone(uint32_t flags, zx_handle_t object) { |
| zx::channel channel(object); |
| |
| bool describe; |
| uint32_t open_flags; |
| FilterFlags(flags, &open_flags, &describe); |
| // TODO(smklein): Avoid automatically inheriting rights |
| // from the cloned file descriptor; allow de-scoping. |
| // Currently, this is difficult, since the remote IO interface |
| // to clone does not specify a reduced set of rights. |
| open_flags |= (flags_ & (ZX_FS_RIGHTS | kStatusFlags)); |
| |
| fbl::RefPtr<Vnode> vn(vnode_); |
| zx_status_t status = ZX_OK; |
| if (!IsPathOnly(open_flags)) { |
| status = OpenVnode(open_flags, &vn); |
| } |
| if (describe) { |
| zxrio_describe_t response; |
| memset(&response, 0, sizeof(response)); |
| response.status = status; |
| zx_handle_t extra = ZX_HANDLE_INVALID; |
| if (status == ZX_OK) { |
| Describe(vnode_, open_flags, &response, &extra); |
| } |
| uint32_t hcount = (extra != ZX_HANDLE_INVALID) ? 1 : 0; |
| channel.write(0, &response, sizeof(zxrio_describe_t), &extra, hcount); |
| } |
| |
| if (status == ZX_OK) { |
| VnodeServe(vfs_, fbl::move(vn), fbl::move(channel), open_flags); |
| } |
| return ZX_OK; |
| } |
| |
| zx_status_t Connection::NodeClose(fidl_txn_t* txn) { |
| zx_status_t status; |
| if (IsPathOnly(flags_)) { |
| status = ZX_OK; |
| } else { |
| status = vnode_->Close(); |
| } |
| fuchsia_io_NodeClose_reply(txn, status); |
| |
| return ERR_DISPATCHER_DONE; |
| } |
| |
| zx_status_t Connection::NodeDescribe(fidl_txn_t* txn) { |
| zxrio_node_info_t info; |
| memset(&info, 0, sizeof(info)); |
| zx_status_t status = GetNodeInfo(vnode_, flags_, &info); |
| if (status != ZX_OK) { |
| return status; |
| } |
| // See static_asserts in zxrio_process_open_response which ensure that this |
| // cast makes sense. |
| auto fidl_info = reinterpret_cast<fuchsia_io_NodeInfo*>(&info); |
| return fuchsia_io_NodeDescribe_reply(txn, fidl_info); |
| } |
| |
| zx_status_t Connection::NodeSync(fidl_txn_t* txn) { |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_NodeSync_reply(txn, ZX_ERR_BAD_HANDLE); |
| } |
| Vnode::SyncCallback closure([this, ctxn = zxfidl_txn_copy(txn)] |
| (zx_status_t status) mutable { |
| fuchsia_io_NodeSync_reply(&ctxn.txn, status); |
| |
| // Try to reset the wait object |
| ZX_ASSERT_MSG(wait_.Begin(vfs_->dispatcher()) == ZX_OK, |
| "Dispatch loop unexpectedly ended"); |
| }); |
| |
| vnode_->Sync(fbl::move(closure)); |
| return ERR_DISPATCHER_ASYNC; |
| } |
| |
| zx_status_t Connection::NodeGetAttr(fidl_txn_t* txn) { |
| fuchsia_io_NodeAttributes attributes; |
| memset(&attributes, 0, sizeof(attributes)); |
| |
| // TODO(smklein): Consider using "NodeAttributes" within |
| // ulib/fs, rather than vnattr_t. |
| // Alternatively modify vnattr_t to match "NodeAttributes" |
| vnattr_t attr; |
| zx_status_t r; |
| if ((r = vnode_->Getattr(&attr)) != ZX_OK) { |
| return fuchsia_io_NodeGetAttr_reply(txn, r, &attributes); |
| } |
| |
| attributes.mode = attr.mode; |
| attributes.id = attr.inode; |
| attributes.content_size = attr.size; |
| attributes.storage_size = VNATTR_BLKSIZE * attr.blkcount; |
| attributes.link_count = attr.nlink; |
| attributes.creation_time = attr.create_time; |
| attributes.modification_time = attr.modify_time; |
| |
| return fuchsia_io_NodeGetAttr_reply(txn, ZX_OK, &attributes); |
| } |
| |
| zx_status_t Connection::NodeSetAttr(uint32_t flags, |
| const fuchsia_io_NodeAttributes* attributes, |
| fidl_txn_t* txn) { |
| // TODO(smklein): Prevent read-only files from setting attributes, |
| // but allow attribute-setting on mutable directories. |
| // For context: ZX-1262, ZX-1065 |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_NodeSetAttr_reply(txn, ZX_ERR_BAD_HANDLE); |
| } |
| |
| vnattr_t attr; |
| attr.valid = flags; |
| attr.create_time = attributes->creation_time; |
| attr.modify_time = attributes->modification_time; |
| zx_status_t status = vnode_->Setattr(&attr); |
| return fuchsia_io_NodeSetAttr_reply(txn, status); |
| } |
| |
| zx_status_t Connection::NodeIoctl(uint32_t opcode, uint64_t max_out, |
| const zx_handle_t* handles, size_t handles_count, |
| const uint8_t* in_data, size_t in_count, fidl_txn_t* txn) { |
| zx::handle handle; |
| if (handles_count == 1) { |
| handle.reset(handles[0]); |
| if (IOCTL_KIND(opcode) != IOCTL_KIND_SET_HANDLE) { |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0, nullptr, 0); |
| } |
| if (in_count < sizeof(zx_handle_t)) { |
| in_count = sizeof(zx_handle_t); |
| } |
| } else if (handles_count > 1) { |
| zx_handle_close_many(handles, handles_count); |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0, nullptr, 0); |
| } |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_BAD_HANDLE, nullptr, 0, nullptr, 0); |
| } |
| if ((in_count > FDIO_IOCTL_MAX_INPUT) || (max_out > FDIO_IOCTL_MAX_INPUT)) { |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0, nullptr, 0); |
| } |
| |
| uint8_t out[max_out]; |
| zx_handle_t* handles_out = reinterpret_cast<zx_handle_t*>(out); |
| uint8_t in_buf[FDIO_IOCTL_MAX_INPUT]; |
| // The sending side copied the handle into msg->handle[0] |
| // so that it would be sent via channel_write(). Here we |
| // copy the local version back into the space in the buffer |
| // that the original occupied. |
| size_t hsize = handles_count * sizeof(zx_handle_t); |
| zx_handle_t h = handle.release(); |
| memcpy(in_buf, &h, hsize); |
| memcpy(in_buf + hsize, (void*)((uintptr_t)in_data + hsize), in_count - hsize); |
| |
| // Some ioctls operate on the connection only, and don't |
| // require a call to Vfs::Ioctl |
| size_t actual = 0; |
| switch (opcode) { |
| case IOCTL_VFS_MOUNT_FS: |
| case IOCTL_VFS_MOUNT_MKDIR_FS: |
| // Mounting requires ADMIN privileges |
| if (!(flags_ & ZX_FS_RIGHT_ADMIN)) { |
| vfs_unmount_handle(h, 0); |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_ACCESS_DENIED, nullptr, 0, nullptr, 0); |
| } |
| // If our permissions validate, fall through to the VFS ioctl |
| break; |
| case IOCTL_VFS_UNMOUNT_FS: { |
| // Unmounting ioctls require Connection privileges |
| if (!(flags_ & ZX_FS_RIGHT_ADMIN)) { |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_ACCESS_DENIED, nullptr, 0, nullptr, 0); |
| } |
| // "IOCTL_VFS_UNMOUNT_FS" is fatal to the requesting connections. |
| Vfs::ShutdownCallback closure([ch = fbl::move(channel_), |
| ctxn = zxfidl_txn_copy(txn)] |
| (zx_status_t status) mutable { |
| fuchsia_io_NodeIoctl_reply(&ctxn.txn, status, nullptr, 0, nullptr, 0); |
| }); |
| Vfs* vfs = vfs_; |
| Terminate(/* call_close= */ true); |
| vfs->Shutdown(fbl::move(closure)); |
| return ERR_DISPATCHER_ASYNC; |
| } |
| case IOCTL_VFS_UNMOUNT_NODE: |
| case IOCTL_VFS_GET_DEVICE_PATH: |
| // Unmounting ioctls require Connection privileges |
| if (!(flags_ & ZX_FS_RIGHT_ADMIN)) { |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_ERR_ACCESS_DENIED, nullptr, 0, nullptr, 0); |
| } |
| // If our permissions validate, fall through to the VFS ioctl |
| break; |
| } |
| |
| zx_status_t status = vfs_->Ioctl(vnode_, opcode, in_buf, in_count, out, |
| max_out, &actual); |
| if (status == ZX_ERR_NOT_SUPPORTED && handles_count > 0) { |
| zx_handle_close(h); |
| } |
| |
| if (status != ZX_OK) { |
| return fuchsia_io_NodeIoctl_reply(txn, status, nullptr, 0, nullptr, 0); |
| } |
| |
| handles_count = 0; |
| switch (IOCTL_KIND(opcode)) { |
| case IOCTL_KIND_DEFAULT: |
| break; |
| case IOCTL_KIND_GET_HANDLE: |
| handles_count = 1; |
| break; |
| case IOCTL_KIND_GET_TWO_HANDLES: |
| handles_count = 2; |
| break; |
| case IOCTL_KIND_GET_THREE_HANDLES: |
| handles_count = 3; |
| break; |
| } |
| |
| ZX_DEBUG_ASSERT(actual <= static_cast<size_t>(max_out)); |
| |
| return fuchsia_io_NodeIoctl_reply(txn, ZX_OK, handles_out, handles_count, out, actual); |
| } |
| |
| zx_status_t Connection::FileRead(uint64_t count, fidl_txn_t* txn) { |
| if (!IsReadable(flags_)) { |
| return fuchsia_io_FileRead_reply(txn, ZX_ERR_BAD_HANDLE, 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 = vnode_->Read(data, count, offset_, &actual); |
| if (status == ZX_OK) { |
| ZX_DEBUG_ASSERT(actual <= count); |
| offset_ += actual; |
| } |
| return fuchsia_io_FileRead_reply(txn, status, data, actual); |
| } |
| |
| zx_status_t Connection::FileReadAt(uint64_t count, uint64_t offset, fidl_txn_t* txn) { |
| if (!IsReadable(flags_)) { |
| return fuchsia_io_FileReadAt_reply(txn, ZX_ERR_BAD_HANDLE, 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 = vnode_->Read(data, count, offset, &actual); |
| if (status == ZX_OK) { |
| ZX_DEBUG_ASSERT(actual <= count); |
| } |
| return fuchsia_io_FileReadAt_reply(txn, status, data, actual); |
| } |
| |
| zx_status_t Connection::FileWrite(const uint8_t* data_data, size_t data_count, fidl_txn_t* txn) { |
| if (!IsWritable(flags_)) { |
| return fuchsia_io_FileWrite_reply(txn, ZX_ERR_BAD_HANDLE, 0); |
| } |
| |
| size_t actual = 0; |
| zx_status_t status; |
| if (flags_ & ZX_FS_FLAG_APPEND) { |
| size_t end; |
| status = vnode_->Append(data_data, data_count, &end, &actual); |
| if (status == ZX_OK) { |
| offset_ = end; |
| } |
| } else { |
| status = vnode_->Write(data_data, data_count, offset_, &actual); |
| if (status == ZX_OK) { |
| offset_ += actual; |
| } |
| } |
| ZX_DEBUG_ASSERT(actual <= data_count); |
| return fuchsia_io_FileWrite_reply(txn, status, actual); |
| } |
| |
| zx_status_t Connection::FileWriteAt(const uint8_t* data_data, size_t data_count, |
| uint64_t offset, fidl_txn_t* txn) { |
| if (!IsWritable(flags_)) { |
| return fuchsia_io_FileWriteAt_reply(txn, ZX_ERR_BAD_HANDLE, 0); |
| } |
| size_t actual = 0; |
| zx_status_t status = vnode_->Write(data_data, data_count, offset, &actual); |
| ZX_DEBUG_ASSERT(actual <= data_count); |
| return fuchsia_io_FileWriteAt_reply(txn, status, actual); |
| } |
| |
| zx_status_t Connection::FileSeek(int64_t offset, fuchsia_io_SeekOrigin start, fidl_txn_t* txn) { |
| static_assert(SEEK_SET == fuchsia_io_SeekOrigin_START, ""); |
| static_assert(SEEK_CUR == fuchsia_io_SeekOrigin_CURRENT, ""); |
| static_assert(SEEK_END == fuchsia_io_SeekOrigin_END, ""); |
| |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_BAD_HANDLE, offset_); |
| } |
| vnattr_t attr; |
| zx_status_t r; |
| if ((r = vnode_->Getattr(&attr)) < 0) { |
| return r; |
| } |
| size_t n; |
| switch (start) { |
| case SEEK_SET: |
| if (offset < 0) { |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| n = offset; |
| break; |
| case SEEK_CUR: |
| n = offset_ + offset; |
| if (offset < 0) { |
| // if negative seek |
| if (n > offset_) { |
| // wrapped around. attempt to seek before start |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| } else { |
| // positive seek |
| if (n < offset_) { |
| // wrapped around. overflow |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| } |
| break; |
| case SEEK_END: |
| n = attr.size + offset; |
| if (offset < 0) { |
| // if negative seek |
| if (n > attr.size) { |
| // wrapped around. attempt to seek before start |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| } else { |
| // positive seek |
| if (n < attr.size) { |
| // wrapped around |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| } |
| break; |
| default: |
| return fuchsia_io_FileSeek_reply(txn, ZX_ERR_INVALID_ARGS, offset_); |
| } |
| offset_ = n; |
| return fuchsia_io_FileSeek_reply(txn, ZX_OK, offset_); |
| } |
| |
| zx_status_t Connection::FileTruncate(uint64_t length, fidl_txn_t* txn) { |
| if (!IsWritable(flags_)) { |
| return fuchsia_io_FileTruncate_reply(txn, ZX_ERR_BAD_HANDLE); |
| } |
| |
| zx_status_t status = vnode_->Truncate(length); |
| return fuchsia_io_FileTruncate_reply(txn, status); |
| } |
| |
| zx_status_t Connection::FileGetFlags(fidl_txn_t* txn) { |
| uint32_t flags = flags_ & (kStatusFlags | ZX_FS_RIGHTS); |
| return fuchsia_io_FileGetFlags_reply(txn, ZX_OK, flags); |
| } |
| |
| zx_status_t Connection::FileSetFlags(uint32_t flags, fidl_txn_t* txn) { |
| flags_ = (flags_ & ~kSettableStatusFlags) | (flags & kSettableStatusFlags); |
| return fuchsia_io_FileSetFlags_reply(txn, ZX_OK); |
| } |
| |
| zx_status_t Connection::FileGetVmo(uint32_t flags, fidl_txn_t* txn) { |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_FileGetVmo_reply(txn, ZX_ERR_BAD_HANDLE, ZX_HANDLE_INVALID); |
| } |
| |
| if ((flags & FDIO_MMAP_FLAG_PRIVATE) && (flags & FDIO_MMAP_FLAG_EXACT)) { |
| return fuchsia_io_FileGetVmo_reply(txn, ZX_ERR_INVALID_ARGS, ZX_HANDLE_INVALID); |
| } else if ((flags_ & ZX_FS_FLAG_APPEND) && flags & FDIO_MMAP_FLAG_WRITE) { |
| return fuchsia_io_FileGetVmo_reply(txn, ZX_ERR_ACCESS_DENIED, ZX_HANDLE_INVALID); |
| } else if (!IsWritable(flags_) && (flags & FDIO_MMAP_FLAG_WRITE)) { |
| return fuchsia_io_FileGetVmo_reply(txn, ZX_ERR_ACCESS_DENIED, ZX_HANDLE_INVALID); |
| } else if (!IsReadable(flags_)) { |
| return fuchsia_io_FileGetVmo_reply(txn, ZX_ERR_ACCESS_DENIED, ZX_HANDLE_INVALID); |
| } |
| |
| zx_handle_t handle = ZX_HANDLE_INVALID; |
| zx_status_t status = vnode_->GetVmo(flags, &handle); |
| return fuchsia_io_FileGetVmo_reply(txn, status, handle); |
| } |
| |
| zx_status_t Connection::DirectoryOpen(uint32_t flags, uint32_t mode, const char* path_data, |
| size_t path_size, zx_handle_t object) { |
| zx::channel channel(object); |
| bool describe = flags & ZX_FS_FLAG_DESCRIBE; |
| if ((path_size < 1) || (path_size > PATH_MAX)) { |
| if (describe) { |
| WriteDescribeError(fbl::move(channel), ZX_ERR_INVALID_ARGS); |
| } |
| } else if ((flags & ZX_FS_RIGHT_ADMIN) && !(flags_ & ZX_FS_RIGHT_ADMIN)) { |
| if (describe) { |
| WriteDescribeError(fbl::move(channel), ZX_ERR_ACCESS_DENIED); |
| } |
| } else { |
| OpenAt(vfs_, vnode_, fbl::move(channel), |
| fbl::StringPiece(path_data, path_size), flags, mode); |
| } |
| return ZX_OK; |
| } |
| |
| zx_status_t Connection::DirectoryUnlink(const char* path_data, size_t path_size, fidl_txn_t* txn) { |
| zx_status_t status = vfs_->Unlink(vnode_, fbl::StringPiece(path_data, path_size)); |
| return fuchsia_io_DirectoryUnlink_reply(txn, status); |
| } |
| |
| zx_status_t Connection::DirectoryReadDirents(uint64_t max_out, fidl_txn_t* txn) { |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_DirectoryReadDirents_reply(txn, ZX_ERR_BAD_HANDLE, nullptr, 0); |
| } |
| if (max_out > ZXFIDL_MAX_MSG_BYTES) { |
| return fuchsia_io_DirectoryReadDirents_reply(txn, ZX_ERR_INVALID_ARGS, nullptr, 0); |
| } |
| uint8_t data[max_out]; |
| size_t actual = 0; |
| zx_status_t status = vfs_->Readdir(vnode_.get(), &dircookie_, data, max_out, &actual); |
| return fuchsia_io_DirectoryReadDirents_reply(txn, status, data, actual); |
| } |
| |
| zx_status_t Connection::DirectoryRewind(fidl_txn_t* txn) { |
| if (IsPathOnly(flags_)) { |
| return fuchsia_io_DirectoryRewind_reply(txn, ZX_ERR_BAD_HANDLE); |
| } |
| dircookie_.Reset(); |
| return fuchsia_io_DirectoryRewind_reply(txn, ZX_OK); |
| } |
| |
| zx_status_t Connection::DirectoryGetToken(fidl_txn_t* txn) { |
| zx::event returned_token; |
| zx_status_t status = vfs_->VnodeToToken(vnode_, &token_, &returned_token); |
| return fuchsia_io_DirectoryGetToken_reply(txn, status, returned_token.release()); |
| } |
| |
| zx_status_t Connection::DirectoryRename(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::event token(dst_parent_token); |
| fbl::StringPiece oldStr(src_data, src_size); |
| fbl::StringPiece newStr(dst_data, dst_size); |
| |
| if (src_size < 1 || dst_size < 1) { |
| return fuchsia_io_DirectoryRename_reply(txn, ZX_ERR_INVALID_ARGS); |
| } |
| zx_status_t status = vfs_->Rename(fbl::move(token), vnode_, |
| fbl::move(oldStr), fbl::move(newStr)); |
| return fuchsia_io_DirectoryRename_reply(txn, status); |
| } |
| |
| zx_status_t Connection::DirectoryLink(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::event token(dst_parent_token); |
| fbl::StringPiece oldStr(src_data, src_size); |
| fbl::StringPiece newStr(dst_data, dst_size); |
| |
| if (src_size < 1 || dst_size < 1) { |
| return fuchsia_io_DirectoryLink_reply(txn, ZX_ERR_INVALID_ARGS); |
| } |
| zx_status_t status = vfs_->Link(fbl::move(token), vnode_, fbl::move(oldStr), |
| fbl::move(newStr)); |
| return fuchsia_io_DirectoryLink_reply(txn, status); |
| } |
| |
| zx_status_t Connection::HandleMessage(fidl_msg_t* msg, fidl_txn_t* txn) { |
| fidl_message_header_t* hdr = reinterpret_cast<fidl_message_header_t*>(msg->bytes); |
| if (hdr->ordinal >= fuchsia_io_NodeCloneOrdinal && |
| hdr->ordinal <= fuchsia_io_NodeIoctlOrdinal) { |
| return fuchsia_io_Node_dispatch(this, txn, msg, &kNodeOps); |
| } else if (hdr->ordinal >= fuchsia_io_FileReadOrdinal && |
| hdr->ordinal <= fuchsia_io_FileGetVmoOrdinal) { |
| return fuchsia_io_File_dispatch(this, txn, msg, &kFileOps); |
| } else if (hdr->ordinal >= fuchsia_io_DirectoryOpenOrdinal && |
| hdr->ordinal <= fuchsia_io_DirectoryLinkOrdinal) { |
| return fuchsia_io_Directory_dispatch(this, txn, msg, &kDirectoryOps); |
| } else { |
| fprintf(stderr, "connection.cpp: Unsupported FIDL operation: 0x%x\n", hdr->ordinal); |
| zx_handle_close_many(msg->handles, msg->num_handles); |
| return ZX_ERR_NOT_SUPPORTED; |
| } |
| } |
| |
| } // namespace fs |
