Searched refs:receiver (Results 1 – 2 of 2) sorted by relevance
| /redis-3.2.3/deps/jemalloc/test/unit/ |
| H A D | mq.c | 67 thd_t receiver; in TEST_BEGIN() local
73 thd_create(&receiver, thd_receiver_start, (void *)&mq); in TEST_BEGIN()
77 thd_join(receiver, NULL); in TEST_BEGIN()
|
| /redis-3.2.3/src/ |
| H A D | t_list.c | 743 addReplyMultiBulkLen(receiver,2); in serveClientBlockedOnList()
744 addReplyBulk(receiver,key); in serveClientBlockedOnList()
745 addReplyBulk(receiver,value); in serveClientBlockedOnList()
749 lookupKeyWrite(receiver->db,dstkey); in serveClientBlockedOnList()
751 checkType(receiver,dstobj,OBJ_LIST))) in serveClientBlockedOnList()
760 rpoplpushHandlePush(receiver,dstkey,dstobj, in serveClientBlockedOnList()
823 client *receiver = clientnode->value; in handleClientsBlockedOnLists() local
824 robj *dstkey = receiver->bpop.target; in handleClientsBlockedOnLists()
825 int where = (receiver->lastcmd && in handleClientsBlockedOnLists()
835 unblockClient(receiver); in handleClientsBlockedOnLists()
[all …]
|