unpv13e/threads/readline.lc

/* include readline1 */
#include    "unpthread.h"##  1 ##src/threads/readline.c##

static pthread_key_t rl_key;##  2 ##src/threads/readline.c##
static pthread_once_t rl_once = PTHREAD_ONCE_INIT;##  3 ##src/threads/readline.c##

static void##  4 ##src/threads/readline.c##
readline_destructor(void *ptr)##  5 ##src/threads/readline.c##
{##  6 ##src/threads/readline.c##
    free(ptr);##  7 ##src/threads/readline.c##
}##  8 ##src/threads/readline.c##

static void##  9 ##src/threads/readline.c##
readline_once(void)## 10 ##src/threads/readline.c##
{## 11 ##src/threads/readline.c##
    Pthread_key_create(&rl_key, readline_destructor);## 12 ##src/threads/readline.c##
}## 13 ##src/threads/readline.c##

typedef struct {## 14 ##src/threads/readline.c##
    int     rl_cnt;             /* initialize to 0 */## 15 ##src/threads/readline.c##
    char   *rl_bufptr;          /* initialize to rl_buf */## 16 ##src/threads/readline.c##
    char    rl_buf[MAXLINE];## 17 ##src/threads/readline.c##
} Rline;## 18 ##src/threads/readline.c##
/* end readline1 */

/* include readline2 */
static ssize_t## 19 ##src/threads/readline.c##
my_read(Rline *tsd, int fd, char *ptr)## 20 ##src/threads/readline.c##
{## 21 ##src/threads/readline.c##
    if (tsd->rl_cnt <= 0) {## 22 ##src/threads/readline.c##
      again:## 23 ##src/threads/readline.c##
        if ((tsd->rl_cnt = read(fd, tsd->rl_buf, MAXLINE)) < 0) {## 24 ##src/threads/readline.c##
            if (errno == EINTR)## 25 ##src/threads/readline.c##
                goto again;## 26 ##src/threads/readline.c##
            return (-1);## 27 ##src/threads/readline.c##
        } else if (tsd->rl_cnt == 0)## 28 ##src/threads/readline.c##
            return (0);## 29 ##src/threads/readline.c##
        tsd->rl_bufptr = tsd->rl_buf;## 30 ##src/threads/readline.c##
    }## 31 ##src/threads/readline.c##

    tsd->rl_cnt--;## 32 ##src/threads/readline.c##
    *ptr = *tsd->rl_bufptr++;## 33 ##src/threads/readline.c##
    return (1);## 34 ##src/threads/readline.c##
}## 35 ##src/threads/readline.c##

ssize_t## 36 ##src/threads/readline.c##
readline(int fd, void *vptr, size_t maxlen)## 37 ##src/threads/readline.c##
{## 38 ##src/threads/readline.c##
    int     n, rc;## 39 ##src/threads/readline.c##
    char    c, *ptr;## 40 ##src/threads/readline.c##
    Rline  *tsd;## 41 ##src/threads/readline.c##

    Pthread_once(&rl_once, readline_once);## 42 ##src/threads/readline.c##
    if ((tsd = pthread_getspecific(rl_key)) == NULL) {## 43 ##src/threads/readline.c##
        tsd = Calloc(1, sizeof(Rline)); /* init to 0 */## 44 ##src/threads/readline.c##
        Pthread_setspecific(rl_key, tsd);## 45 ##src/threads/readline.c##
    }## 46 ##src/threads/readline.c##

    ptr = vptr;## 47 ##src/threads/readline.c##
    for (n = 1; n < maxlen; n++) {## 48 ##src/threads/readline.c##
        if ((rc = my_read(tsd, fd, &c)) == 1) {## 49 ##src/threads/readline.c##
            *ptr++ = c;## 50 ##src/threads/readline.c##
            if (c == '\n')## 51 ##src/threads/readline.c##
                break;## 52 ##src/threads/readline.c##
        } else if (rc == 0) {## 53 ##src/threads/readline.c##
            if (n == 1)## 54 ##src/threads/readline.c##
                return (0);     /* EOF, no data read */## 55 ##src/threads/readline.c##
            else## 56 ##src/threads/readline.c##
                break;          /* EOF, some data was read */## 57 ##src/threads/readline.c##
        } else## 58 ##src/threads/readline.c##
            return (-1);        /* error, errno set by read() */## 59 ##src/threads/readline.c##
    }## 60 ##src/threads/readline.c##

    *ptr = 0;## 61 ##src/threads/readline.c##
    return (n);## 62 ##src/threads/readline.c##
}## 63 ##src/threads/readline.c##
/* end readline2 */

ssize_t## 64 ##src/threads/readline.c##
Readline(int fd, void *ptr, size_t maxlen)## 65 ##src/threads/readline.c##
{## 66 ##src/threads/readline.c##
    ssize_t n;## 67 ##src/threads/readline.c##

    if ((n = readline(fd, ptr, maxlen)) < 0)## 68 ##src/threads/readline.c##
        err_sys("readline error");## 69 ##src/threads/readline.c##
    return (n);## 70 ##src/threads/readline.c##
}## 71 ##src/threads/readline.c##