diff options
| author | DanielGavin <danielgavin5@hotmail.com> | 2021-05-11 21:52:51 +0200 |
|---|---|---|
| committer | DanielGavin <danielgavin5@hotmail.com> | 2021-05-11 21:52:51 +0200 |
| commit | 98609fccd73cb464dd4659702319dab2fe1c61c1 (patch) | |
| tree | 787f9da10a2332eb8ad8fc345b6ba6ddbb23a4b9 /src/server/reader.odin | |
| parent | f468b8089cc4ab1e76fac7ed8defb7dc6a65d6c7 (diff) | |
fix read on large files
Diffstat (limited to 'src/server/reader.odin')
| -rw-r--r-- | src/server/reader.odin | 22 |
1 files changed, 17 insertions, 5 deletions
diff --git a/src/server/reader.odin b/src/server/reader.odin index b8843de..a05e147 100644 --- a/src/server/reader.odin +++ b/src/server/reader.odin @@ -48,13 +48,25 @@ read_until_delimiter :: proc(reader: ^Reader, delimiter: u8, builder: ^strings.B return true; } -read_sized :: proc(reader: ^Reader, data: []u8) -> bool { +read_sized :: proc(reader: ^Reader, data: []u8) -> (ok: bool) { + ok = true; + size := len(data); + n := 0; - read, err := reader.reader_fn(reader.reader_context, data); + for n < size && ok { + read: int; + err_code: int; - if (err != 0 || read != len(data)) { - return false; + read, err_code = reader.reader_fn(reader.reader_context, data[n:]); + + ok = err_code == 0; + + n += read; } - return true; + if n >= size { + ok = true; + } + + return; } |