Method TimerCB

src/commands/cmd_replication.cc:443–449

  }

  void TimerCB(int, int16_t) {
    timer_.reset();
    // Wake up the connection upon timeout.
    // WakeupWaitConnection will hold the lock of the connection during the execution,
    // holding the lock is necessary to avoid race condition that timeout and replication ack happen at the same time.
    srv_->WakeupWaitConnection(conn_, target_seq_);
  }

  void OnEvent(bufferevent *bev, int16_t events) {
    if (events & (BEV_EVENT_EOF | BEV_EVENT_ERROR)) {