- bufinit(buf);
- nl = 0;
- while(1) {
- sizebuf(buf, buf.d + 1);
- ret = recv(fd, buf.b + buf.d, 1, MSG_DONTWAIT);
- if(ret <= 0) {
- if((ret < 0) && (errno == EAGAIN)) {
- block(fd, EV_READ);
- continue;
+ int get1(void)
+ {
+ int ret;
+
+ while(!(off < buf->d)) {
+ sizebuf(*buf, buf->d + 1024);
+ ret = recv(fd, buf->b + buf->d, buf->s - buf->d, MSG_DONTWAIT);
+ if(ret <= 0) {
+ if((ret < 0) && (errno == EAGAIN)) {
+ block(fd, EV_READ);
+ continue;
+ }
+ return(-1);