| 224 | } |
| 225 | |
| 226 | static char *readLine(redisReader *r, int *_len) { |
| 227 | char *p, *s; |
| 228 | int len; |
| 229 | |
| 230 | p = r->buf+r->pos; |
| 231 | s = seekNewline(p,(r->len-r->pos)); |
| 232 | if (s != NULL) { |
| 233 | len = s-(r->buf+r->pos); |
| 234 | r->pos += len+2; /* skip \r\n */ |
| 235 | if (_len) *_len = len; |
| 236 | return p; |
| 237 | } |
| 238 | return NULL; |
| 239 | } |
| 240 | |
| 241 | static void moveToNextTask(redisReader *r) { |
| 242 | redisReadTask *cur, *prv; |
no test coverage detected