首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >从fd读取数据,而fd接收到的fd数据失败

从fd读取数据,而fd接收到的fd数据失败
EN

Stack Overflow用户
提问于 2020-02-05 07:21:03
回答 1查看 142关注 0票数 2

我想测试fuse,并从lib引信复制如下代码:

代码语言:javascript
复制
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/mount.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <unistd.h>

#define xlog(_fmt_, ...)                                                \
  printf("\033[0;33m[%s:%s:%d]\033[0m " _fmt_ "\n", __FILE__, __func__, \
         __LINE__, ##__VA_ARGS__)

static int receive_fd(int fd) {
  struct msghdr msg;
  struct iovec iov;
  char buf[1];
  int rv;
  size_t ccmsg[CMSG_SPACE(sizeof(int)) / sizeof(size_t)];
  struct cmsghdr *cmsg;

  iov.iov_base = buf;
  iov.iov_len = 1;

  memset(&msg, 0, sizeof(msg));
  msg.msg_name = 0;
  msg.msg_namelen = 0;
  msg.msg_iov = &iov;
  msg.msg_iovlen = 1;
  msg.msg_control = ccmsg;
  msg.msg_controllen = sizeof(ccmsg);

  while (((rv = recvmsg(fd, &msg, 0)) == -1) && errno == EINTR) {
  }
  if (rv == -1) {
    xlog("recvmsg: %s", strerror(errno));
    return -1;
  }
  if (!rv) {
    return -1;
  }

  cmsg = CMSG_FIRSTHDR(&msg);
  if (cmsg->cmsg_type != SCM_RIGHTS) {
    xlog("got control message of unknown type %d", cmsg->cmsg_type);
    return -1;
  }
  return *(int *)CMSG_DATA(cmsg);
}

static int fuse_mount(const char *mountpoint) {
  int fds[2];
  int res = socketpair(PF_UNIX, SOCK_STREAM, 0, fds);
  if (res != 0) {
    xlog("socketpair: %s", strerror(errno));
    return -1;
  }

  pid_t pid = fork();
  if (pid == -1) {
    close(fds[0]);
    close(fds[1]);
    return -1;
  }

  if (pid == 0) {
    const char *argv[32];
    unsigned argc = 0;
    argv[argc++] = "--";
    argv[argc++] = mountpoint;
    argv[argc++] = NULL;

    char env[16];
    snprintf(env, sizeof(env), "%i", fds[0]);
    setenv("_FUSE_COMMFD", env, 1);
    execvp("fusermount", (char **)argv);

    xlog("exec: %s", strerror(errno));
    exit(1);
  }

  int rv = receive_fd(fds[1]);
  if (rv >= 0) {
    fcntl(rv, F_SETFD, FD_CLOEXEC);
  }
  waitpid(pid, NULL, 0);

  close(fds[0]);
  close(fds[1]);
  return rv;
}

#define MOUNT_POINT "/tmp/xx"
#define BUFFER_SIZE 1024

int main(int argc, char **argv) {
  int fd = fuse_mount(MOUNT_POINT);
  if (fd < 0) {
    xlog("fuse mount fail");
    return -1;
  }

  char buf[BUFFER_SIZE];
  ssize_t n = read(fd, buf, sizeof(buf));
  if (n < 0) {
    xlog("read: %s", strerror(errno));
  } else {
    xlog("ok");
  }

  return 0;
}

它接收来自fusermountfusermount文件句柄,并从中读取数据。

代码在大多数平台上运行正常,但是当我在virtualbox上运行它时,我在第107行得到了错误read: Invalid argument

代码语言:javascript
复制
ssize_t n = read(fd, buf, sizeof(buf));

然后我检查lib引信的代码,它设置缓冲区大小如下所示:

代码语言:javascript
复制
se->bufsize = FUSE_MAX_MAX_PAGES * getpagesize() + FUSE_BUFFER_HEADER_SIZE;

因此,我在代码中设置了一个更大的BUFFER_SIZE,如10240,它运行正常。我感到困惑,因为我认为1024足够大,我从fd中读取的数据大小仅为56

我的问题是系统呼叫:

代码语言:javascript
复制
ssize_t read(int fd, void *buf, size_t count);

  1. 为什么计数的大小会导致Invalid argument错误?为什么在正常平台上将计数设置为1024,但在virtualbox上失败?

,为什么没有问题?

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2020-02-05 12:35:53

谢谢@this 253751提示,我阅读了代码fs/fuse/dev.c并发现如下:

代码语言:javascript
复制
static ssize_t fuse_dev_do_read(struct fuse_dev *fud, struct file *file,
                                struct fuse_copy_state *cs, size_t nbytes) {
  // ...
  if (nbytes < max_t(size_t, FUSE_MIN_READ_BUFFER,
                     sizeof(struct fuse_in_header) +
                         sizeof(struct fuse_write_in) + fc->max_write))
    return -EINVAL;
  // ...
}

从LinuxV5.4开始就添加了字节检查,所以如果内核版本比v5.3.18更新,那么较小的字节将导致EINVAL错误。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/60070754

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档