Send a REPLCONF ACK command to the master to inform it about the current * processed offset. If we are not connected with a master, the command has * no effects. */
| 4285 | * processed offset. If we are not connected with a master, the command has |
| 4286 | * no effects. */ |
| 4287 | void replicationSendAck(redisMaster *mi) |
| 4288 | { |
| 4289 | client *c = mi->master; |
| 4290 | |
| 4291 | if (c != NULL) { |
| 4292 | std::unique_lock<fastlock> ul(c->lock); |
| 4293 | c->flags |= CLIENT_MASTER_FORCE_REPLY; |
| 4294 | addReplyArrayLen(c,3); |
| 4295 | addReplyBulkCString(c,"REPLCONF"); |
| 4296 | addReplyBulkCString(c,"ACK"); |
| 4297 | addReplyBulkLongLong(c,c->reploff); |
| 4298 | c->flags &= ~CLIENT_MASTER_FORCE_REPLY; |
| 4299 | } |
| 4300 | } |
| 4301 | |
| 4302 | /* ---------------------- MASTER CACHING FOR PSYNC -------------------------- */ |
| 4303 |
no test coverage detected