Lines Matching refs:alr
114 asyncLineReader_init(AsyncLineReader* alr,
119 alr->buffer = buffer;
120 alr->buffsize = buffsize;
121 alr->pos = 0;
122 alr->io = io;
123 alr->eol = '\n';
129 asyncLineReader_read(AsyncLineReader* alr)
133 if (alr->pos >= alr->buffsize) {
140 ret = socket_recv(alr->io->fd, &ch, 1);
150 loopIo_wantRead(alr->io);
155 alr->buffer[alr->pos++] = (uint8_t)ch;
156 if (ch == alr->eol) {
157 loopIo_dontWantRead(alr->io);
160 } while (alr->pos < alr->buffsize);
163 loopIo_dontWantRead(alr->io);
169 asyncLineReader_getLineRaw(AsyncLineReader* alr, int *pLength)
171 if (alr->pos == 0 || alr->pos > alr->buffsize)
175 *pLength = alr->pos;
177 return (const char*) alr->buffer;
181 asyncLineReader_getLine(AsyncLineReader* alr)
184 size_t pos = alr->pos;
185 char* buffer = (char*) alr->buffer;
187 if (pos == 0 || pos > alr->buffsize)
193 if (alr->eol == '\n') {
