wash/fx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fx: stream: only return an error from read/write if no bytes were moved

Browse Source
This commit is contained in:
max 🍓
2026-06-10 19:08:09 +01:00
parent 20dc844c9d
commit 15784c3404
1 changed files with 18 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fx/stream.c
+18 -25
View File
@@ -642,9 +642,8 @@ static fx_stream *init_stdio_stream(FILE *fp, fx_stream_mode mode)
return NULL;
}
struct fx_stdio_stream_p *p = fx_object_get_private(
stream,
FX_TYPE_STDIO_STREAM);
struct fx_stdio_stream_p *p
= fx_object_get_private(stream, FX_TYPE_STDIO_STREAM);
fx_stream_cfg *cfg = fx_object_get_protected(stream, FX_TYPE_STREAM);
p->s_fp = fp;
cfg->s_mode = mode;
@@ -681,8 +680,8 @@ static enum fx_status stream_push_indent(struct stream_data *stream, int indent)
stream->s_private->s_istack_size += 4;
}
int cur_indent = stream->s_private
->s_istack[stream->s_private->s_istack_ptr];
int cur_indent
= stream->s_private->s_istack[stream->s_private->s_istack_ptr];
stream->s_private->s_istack[++stream->s_private->s_istack_ptr]
= cur_indent + indent;
@@ -750,9 +749,8 @@ fx_stream_buffer *fx_stream_buffer_create_dynamic(size_t buffer_size)
return NULL;
}
struct fx_stream_buffer_p *p = fx_object_get_private(
buffer,
FX_TYPE_STREAM_BUFFER);
struct fx_stream_buffer_p *p
= fx_object_get_private(buffer, FX_TYPE_STREAM_BUFFER);
p->p_buf = malloc(buffer_size);
if (!p->p_buf) {
@@ -773,9 +771,8 @@ fx_stream_buffer *fx_stream_buffer_create(void *buf, size_t len)
return NULL;
}
struct fx_stream_buffer_p *p = fx_object_get_private(
buffer,
FX_TYPE_STREAM_BUFFER);
struct fx_stream_buffer_p *p
= fx_object_get_private(buffer, FX_TYPE_STREAM_BUFFER);
p->p_buf = buf;
p->p_buf_len = len;
@@ -1130,15 +1127,14 @@ static enum fx_status stdio_read(
size_t max,
size_t *nr_read)
{
struct fx_stdio_stream_p *p = fx_object_get_private(
stream,
FX_TYPE_STDIO_STREAM);
struct fx_stdio_stream_p *p
= fx_object_get_private(stream, FX_TYPE_STDIO_STREAM);
enum fx_status status = FX_SUCCESS;
size_t count = fread(out, 1, max, p->s_fp);
if (ferror(p->s_fp)) {
if (count == 0 && ferror(p->s_fp)) {
status = FX_ERR_IO_FAILURE;
}
@@ -1152,14 +1148,13 @@ static enum fx_status stdio_write(
size_t count,
size_t *nr_written)
{
struct fx_stdio_stream_p *p = fx_object_get_private(
stream,
FX_TYPE_STDIO_STREAM);
struct fx_stdio_stream_p *p
= fx_object_get_private(stream, FX_TYPE_STDIO_STREAM);
enum fx_status status = FX_SUCCESS;
size_t w = fwrite(data, 1, count, p->s_fp);
if (ferror(p->s_fp)) {
if (count == 0 && ferror(p->s_fp)) {
status = FX_ERR_IO_FAILURE;
}
@@ -1172,9 +1167,8 @@ static enum fx_status stdio_seek(
long long offset,
fx_stream_seek_origin origin)
{
struct fx_stdio_stream_p *p = fx_object_get_private(
stream,
FX_TYPE_STDIO_STREAM);
struct fx_stdio_stream_p *p
= fx_object_get_private(stream, FX_TYPE_STDIO_STREAM);
int whence = 0;
switch (origin) {
@@ -1201,9 +1195,8 @@ static enum fx_status stdio_seek(
static enum fx_status stdio_tell(const fx_stream *stream, size_t *cursor)
{
struct fx_stdio_stream_p *p = fx_object_get_private(
stream,
FX_TYPE_STDIO_STREAM);
struct fx_stdio_stream_p *p
= fx_object_get_private(stream, FX_TYPE_STDIO_STREAM);
long pos = ftell(p->s_fp);
if (pos == -1L) {