| 673 | } |
| 674 | |
| 675 | void redisAsyncHandleWrite(redisAsyncContext *ac) { |
| 676 | redisContext *c = &(ac->c); |
| 677 | |
| 678 | if (!(c->flags & REDIS_CONNECTED)) { |
| 679 | /* Abort connect was not successful. */ |
| 680 | if (__redisAsyncHandleConnect(ac) != REDIS_OK) |
| 681 | return; |
| 682 | /* Try again later when the context is still not connected. */ |
| 683 | if (!(c->flags & REDIS_CONNECTED)) |
| 684 | return; |
| 685 | } |
| 686 | |
| 687 | c->funcs->async_write(ac); |
| 688 | } |
| 689 | |
| 690 | void redisAsyncHandleTimeout(redisAsyncContext *ac) { |
| 691 | redisContext *c = &(ac->c); |
no test coverage detected