用libssh复制文件

Question

我试图编写一个简单的程序(玩具示例)，将文件从远程主机复制到本地计算机。

当我试图复制txt文件时，它是有效的，但对于像mp4这样的文件则不起作用。

下面是我的代码，它基本上是从教程中拼接在一起的：https://pastebin.com/0FPrmeDx

这就是错误发生的地方：

int scp_receive(ssh_session session, ssh_scp scp)
{
  int rc;
  int size, mode;
  char *filename, *buffer;

  rc = ssh_scp_pull_request(scp);
  if (rc != SSH_SCP_REQUEST_NEWFILE)
  {
    fprintf(stderr, "Error receiving information about file: %s\n",
            ssh_get_error(session));
    return SSH_ERROR;
  }

  size = ssh_scp_request_get_size(scp);
  filename = strdup(ssh_scp_request_get_filename(scp));
  mode = ssh_scp_request_get_permissions(scp);
  printf("Receiving file %s, size %d, permisssions 0%o\n",
          filename, size, mode);
  free(filename);

  buffer = malloc(size);
  if (buffer == NULL)
  {
    fprintf(stderr, "Memory allocation error\n");
    return SSH_ERROR;
  }

  ssh_scp_accept_request(scp);
  rc = ssh_scp_read(scp, buffer, size);
  if (rc == SSH_ERROR)
  {
    fprintf(stderr, "Error receiving file data: %s\n",
            ssh_get_error(session));
    free(buffer);
    return rc;
  }
  printf("Done!!!!!!!!!!!!!!!!!!!!!!!!!!!!!\n");

  int filedesc = open("/home/user/video.mp4", O_WRONLY | O_CREAT);

  if (filedesc < 0) {
    return -1;
  }

  write(filedesc, buffer, size);
  free(buffer);

  close(filedesc);

  rc = ssh_scp_pull_request(scp);
  if (rc != SSH_SCP_REQUEST_EOF)
  {
    fprintf(stderr, "Unexpected request: %s\n",
            ssh_get_error(session));
    return SSH_ERROR;
  }

  return SSH_OK;
}

使用以下代码触发错误：

rc = ssh_scp_pull_request(scp);
if (rc != SSH_SCP_REQUEST_EOF)
{
   fprintf(stderr, "Unexpected request: %s\n",
           ssh_get_error(session));
   return SSH_ERROR;
}

这是我得到的错误：

Unexpected request: ssh_scp_pull_request called under invalid state

我试着想办法，但没能取得任何进展。

更新1：

复制文件的大小与txt和mp4文件的源文件大小完全相同。但是，复制的文件似乎大部分是空的.复制时，权限将从-rwxr-xr-x更改为--wxr-----。

更新2：

在这里，文件大小似乎起着重要作用。非常小的文件(10-15kb)被复制，没有问题。较大的文件不会复制并产生上述错误.

Answer 1

您不能期望ssh_scp_read()在对它的单个调用中读取整个数据。您必须迭代，直到没有更多的数据可阅读：

int r = 0;
while (r < size) {
    int st = ssh_scp_read(scp, buffer+r, size-r);
    r += st;
}

现在，对ssh_scp_pull_request(scp)的后续调用应该成功。