| 5595 | } |
| 5596 | |
| 5597 | void replicateSubkeyExpire(redisDb *db, robj_roptr key, robj_roptr subkey, long long expire) { |
| 5598 | if (!g_pserver->fActiveReplica || listLength(g_pserver->slaves) == 0) |
| 5599 | return; |
| 5600 | |
| 5601 | redisObjectStack objTtl; |
| 5602 | initStaticStringObject(objTtl, sdscatprintf(sdsempty(), "%lld", expire)); |
| 5603 | redisObject *argv[4] = {shared.pexpirememberat, key.unsafe_robjcast(), subkey.unsafe_robjcast(), &objTtl}; |
| 5604 | replicationFeedSlaves(g_pserver->slaves, db->id, argv, 4); |
| 5605 | |
| 5606 | sdsfree(szFromObj(&objTtl)); |
| 5607 | } |
| 5608 | |
| 5609 | void _clientAsyncReplyBufferReserve(client *c, size_t len); |
| 5610 |
no test coverage detected