Archives/falk-werner_webfuse
1
0
Fork 0
mirror of https://github.com/falk-werner/webfuse synced 2025-06-13 12:54:15 +00:00
Code Issues Releases Wiki Activity

adds implementation of filesystem_read

Browse Source
This commit is contained in:
Falk Werner 2019-04-22 18:24:52 +02:00
parent 20fbf8cf96
commit 2a300a63b0
1 changed files with 38 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
lib/webfuse/provider/impl/static_filesystem.c
View File

@ -4,6 +4,11 @@
#include "webfuse/provider/operation/error.h" #include "webfuse/provider/operation/error.h"
#include "webfuse/core/path.h" #include "webfuse/core/path.h"
#include "webfuse/core/util.h"
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
@ -12,6 +17,7 @@
#define WFP_STATIC_FILESYSTEM_DEFAULT_CAPACITY (16) #define WFP_STATIC_FILESYSTEM_DEFAULT_CAPACITY (16)
#define WFP_STATIC_FILSYSTEM_INDOE_ROOT (1) #define WFP_STATIC_FILSYSTEM_INDOE_ROOT (1)
#define WFP_STATIC_FILESYSTEM_MAX_READ_SIZE (4 * 1024)
struct wfp_static_filesystem_entry struct wfp_static_filesystem_entry
{ {
@ -315,29 +321,50 @@ static void wfp_static_filesystem_open(
int flags, int flags,
void * user_data) void * user_data)
{ {
(void) inode; struct wfp_static_filesystem * filesystem = user_data;
(void) flags; struct wfp_static_filesystem_entry * entry = wfp_static_filesystem_get_entry(filesystem, inode);
(void) user_data;
if ((NULL != entry) && (entry->is_file))
{
if (O_RDONLY == (flags & O_ACCMODE))
{
wfp_respond_open(request, 0U);
}
else
{
wfp_respond_error(request, WF_BAD_ACCESS_DENIED);
}
}
else
{
wfp_respond_error(request, WF_BAD_NOENTRY); wfp_respond_error(request, WF_BAD_NOENTRY);
} }
}
static void wfp_static_filesystem_read( static void wfp_static_filesystem_read(
struct wfp_request * request, struct wfp_request * request,
ino_t inode, ino_t inode,
uint32_t handle, uint32_t WF_UNUSED_PARAM(handle),
size_t offset, size_t offset,
size_t length, size_t length,
void * user_data) void * user_data)
{ {
(void) inode; struct wfp_static_filesystem * filesystem = user_data;
(void) handle; struct wfp_static_filesystem_entry * entry = wfp_static_filesystem_get_entry(filesystem, inode);
(void) offset;
(void) length;
(void) user_data;
if ((NULL != entry) && (entry->is_file))
{
char buffer[WFP_STATIC_FILESYSTEM_MAX_READ_SIZE];
size_t max_size = (length < WFP_STATIC_FILESYSTEM_MAX_READ_SIZE) ? length : WFP_STATIC_FILESYSTEM_MAX_READ_SIZE;
size_t count = entry->read(offset, buffer, max_size, entry->user_data);
wfp_respond_read(request, buffer, count);
}
else
{
wfp_respond_error(request, WF_BAD_NOENTRY); wfp_respond_error(request, WF_BAD_NOENTRY);
} }
}
struct wfp_static_filesystem * struct wfp_static_filesystem *