diff options
| author | Stef Walter <stef@memberwebs.com> | 2005-09-19 16:59:09 +0000 |
|---|---|---|
| committer | Stef Walter <stef@memberwebs.com> | 2005-09-19 16:59:09 +0000 |
| commit | a0d3264cbac70fbeb29db4441d9da7f38428adbf (patch) | |
| tree | d3ba104512826b665b649fa61e3ca2d29cf7721a | |
| parent | 077097673daf66e5cc52242c7b6c158f722f2cb4 (diff) | |
Solaris multi threading fixes.
| -rw-r--r-- | common/compat.c | 27 |
1 files changed, 23 insertions, 4 deletions
diff --git a/common/compat.c b/common/compat.c index 9828a41..40e4c73 100644 --- a/common/compat.c +++ b/common/compat.c @@ -270,6 +270,7 @@ ssize_t getdelim(char** lineptr, size_t* n, int delim, FILE* stream) { size_t written = 0; int allocated, ch; + ssize_t ret = -1; char* p; if(!n || !lineptr || !stream) @@ -281,6 +282,11 @@ ssize_t getdelim(char** lineptr, size_t* n, int delim, FILE* stream) /* Track whether we allocated this or not */ allocated = !(*lineptr); +#ifdef HAVE_FLOCKFILE + /* Affects performance on Solaris. */ + flockfile(stream); +#endif + for(;;) { if(!*lineptr) @@ -289,26 +295,32 @@ ssize_t getdelim(char** lineptr, size_t* n, int delim, FILE* stream) /* Reallocate if we need more space */ if(written == *n - 1) { - *n = *n ? 256 : *n * 2; + *n = *n ? *n * 2 : 256; if(!(p = (char*)realloc(*lineptr, *n))) { if(allocated && *lineptr) free(*lineptr); errno = ENOMEM; - return -1; + ret = -1; + goto finally; } *lineptr = p; } while(written < *n - 1) { +#ifdef HAVE_FLOCKFILE + ch = getc_unlocked(stream); +#else ch = fgetc(stream); +#endif if(ferror(stream)) { if(allocated && *lineptr) free(*lineptr); - return -1; + ret = -1; + goto finally; } if(ch != EOF) @@ -318,10 +330,17 @@ ssize_t getdelim(char** lineptr, size_t* n, int delim, FILE* stream) if(ch == EOF || ch == delim) { (*lineptr)[written] = 0; - return written ? written : -1; + ret = written ? written : -1; + goto finally; } } } +finally: + +#ifdef HAVE_FLOCKFILE + funlockfile(stream); +#endif + return ret; } #endif |