RepoMirrors
/
simple-mtpfs
mirror of https://github.com/phatina/simple-mtpfs
1
0
Fork 0
Code Issues Releases Wiki Activity

Merge pull request #91 from Cyp/fix85 

On partial read/write, keep reading.
This commit is contained in:
Peter Hatina 2023-10-31 08:56:42 -05:00 committed by GitHub
parent 19e7bb9b60 2c44f913e8
commit 5dfd25c72c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 31 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/simple-mtpfs-fuse.cpp
View File

@ -85,13 +85,41 @@ int wrap_open(const char *path, struct fuse_file_info *file_info)
int wrap_read(const char *path, char *buf, size_t size, off_t offset,
struct fuse_file_info *file_info)
{
return SMTPFileSystem::instance()->read(path, buf, size, offset, file_info);
if (file_info->direct_io) {
return SMTPFileSystem::instance()->read(path, buf, size, offset, file_info);
} else {
int bytes_read = 0;
while (bytes_read < size) {
int rval = SMTPFileSystem::instance()->read(path, buf + bytes_read, size - bytes_read, offset + bytes_read, file_info);
if (rval < 0) {
return rval;
} else if (rval == 0) {
break;
}
bytes_read += rval;
}
return bytes_read;
}
}
int wrap_write(const char *path, const char *buf, size_t size, off_t offset,
struct fuse_file_info *file_info)
{
return SMTPFileSystem::instance()->write(path, buf, size, offset, file_info);
if (file_info->direct_io) {
return SMTPFileSystem::instance()->write(path, buf, size, offset, file_info);
} else {
int bytes_written = 0;
while (bytes_written < size) {
int rval = SMTPFileSystem::instance()->write(path, buf + bytes_written, size - bytes_written, offset + bytes_written, file_info);
if (rval < 0) {
return rval;
} else if (rval == 0) {
break;
}
bytes_written += rval;
}
return bytes_written;
}
}
int wrap_statfs(const char *path, struct statvfs *stat_info)

1
src/simple-mtpfs-mtp-device.cpp
View File

@ -720,6 +720,7 @@ bool MTPDevice::listDevices(bool verbose, const std::string &dev_file)
continue;
std::cout << i + 1 << ": "
<< (raw_devices[i].device_entry.vendor ? raw_devices[i].device_entry.vendor : "Unknown vendor ")
<< ", "
<< (raw_devices[i].device_entry.product ? raw_devices[i].device_entry.product : "Unknown product")
<< std::endl;
#ifdef HAVE_LIBMTP_CHECK_CAPABILITY