git: 2afc73005cb2 - stable/13 - sort: unify the code to read from FILE *
- Go to: [ bottom of page ] [ top of archives ] [ this month ]
Date: Wed, 19 Oct 2022 08:01:32 UTC
The branch stable/13 has been updated by bapt:
URL: https://cgit.FreeBSD.org/src/commit/?id=2afc73005cb2c288a2445af6be10484e14ea7409
commit 2afc73005cb2c288a2445af6be10484e14ea7409
Author: Baptiste Daroussin <bapt@FreeBSD.org>
AuthorDate: 2022-10-13 07:36:48 +0000
Commit: Baptiste Daroussin <bapt@FreeBSD.org>
CommitDate: 2022-10-19 07:59:29 +0000
sort: unify the code to read from FILE *
Previously the code to read from a local file or stdin was sperarated
After the change to remove the home made line reader used for stdin
(replaced by getdelim) it apprears that the rest of the code which is
used to read from any FILE * but stdin can benefit from the exact same
change.
(cherry picked from commit 8b9071360a312f2bb2104864af0b9905acac87bc)
---
usr.bin/sort/file.c | 94 -----------------------------------------------------
1 file changed, 94 deletions(-)
diff --git a/usr.bin/sort/file.c b/usr.bin/sort/file.c
index b48948e1edee..437be09819b5 100644
--- a/usr.bin/sort/file.c
+++ b/usr.bin/sort/file.c
@@ -62,26 +62,18 @@ const char *compress_program;
size_t max_open_files = 16;
-/*
- * How much space we read from file at once
- */
-#define READ_CHUNK (4096)
-
/*
* File reader structure
*/
struct file_reader
{
- struct reader_buffer rb;
FILE *file;
char *fname;
char *buffer;
unsigned char *mmapaddr;
unsigned char *mmapptr;
size_t bsz;
- size_t cbsz;
size_t mmapsize;
- size_t strbeg;
int fd;
char elsymb;
};
@@ -663,19 +655,6 @@ file_reader_init(const char *fsrc)
ret->file = openfile(fsrc, "r");
if (ret->file == NULL)
err(2, NULL);
-
- if (strcmp(fsrc, "-")) {
- ret->cbsz = READ_CHUNK;
- ret->buffer = sort_malloc(ret->cbsz);
- ret->bsz = 0;
- ret->strbeg = 0;
-
- ret->bsz = fread(ret->buffer, 1, ret->cbsz, ret->file);
- if (ret->bsz == 0) {
- if (ferror(ret->file))
- err(2, NULL);
- }
- }
}
return (ret);
@@ -708,79 +687,6 @@ file_reader_readline(struct file_reader *fr)
fr->mmapptr = strend + 1;
}
}
-
- } else if (fr->file != stdin) {
- char *strend;
- size_t bsz1, remsz, search_start;
-
- search_start = 0;
- remsz = 0;
- strend = NULL;
-
- if (fr->bsz > fr->strbeg)
- remsz = fr->bsz - fr->strbeg;
-
- /* line read cycle */
- for (;;) {
- if (remsz > search_start)
- strend = memchr(fr->buffer + fr->strbeg +
- search_start, fr->elsymb, remsz -
- search_start);
- else
- strend = NULL;
-
- if (strend)
- break;
- if (feof(fr->file))
- break;
-
- if (fr->bsz != fr->cbsz)
- /* NOTREACHED */
- err(2, "File read software error 1");
-
- if (remsz > (READ_CHUNK >> 1)) {
- search_start = fr->cbsz - fr->strbeg;
- fr->cbsz += READ_CHUNK;
- fr->buffer = sort_realloc(fr->buffer,
- fr->cbsz);
- bsz1 = fread(fr->buffer + fr->bsz, 1,
- READ_CHUNK, fr->file);
- if (bsz1 == 0) {
- if (ferror(fr->file))
- err(2, NULL);
- break;
- }
- fr->bsz += bsz1;
- remsz += bsz1;
- } else {
- if (remsz > 0 && fr->strbeg>0)
- bcopy(fr->buffer + fr->strbeg,
- fr->buffer, remsz);
-
- fr->strbeg = 0;
- search_start = remsz;
- bsz1 = fread(fr->buffer + remsz, 1,
- fr->cbsz - remsz, fr->file);
- if (bsz1 == 0) {
- if (ferror(fr->file))
- err(2, NULL);
- break;
- }
- fr->bsz = remsz + bsz1;
- remsz = fr->bsz;
- }
- }
-
- if (strend == NULL)
- strend = fr->buffer + fr->bsz;
-
- if ((fr->buffer + fr->strbeg <= strend) &&
- (fr->strbeg < fr->bsz) && (remsz>0))
- ret = bwscsbdup(fr->buffer + fr->strbeg, strend -
- fr->buffer - fr->strbeg);
-
- fr->strbeg = (strend - fr->buffer) + 1;
-
} else {
ssize_t len;