| 625 | } |
| 626 | |
| 627 | void redisAsyncRead(redisAsyncContext *ac) { |
| 628 | redisContext *c = &(ac->c); |
| 629 | |
| 630 | if (redisBufferRead(c) == REDIS_ERR) { |
| 631 | __redisAsyncDisconnect(ac); |
| 632 | } else { |
| 633 | /* Always re-schedule reads */ |
| 634 | _EL_ADD_READ(ac); |
| 635 | redisProcessCallbacks(ac); |
| 636 | } |
| 637 | } |
| 638 | |
| 639 | /* This function should be called when the socket is readable. |
| 640 | * It processes all replies that can be read and executes their callbacks. |
nothing calls this directly
no test coverage detected