Method MatchLogOffset

src/replica/replicate_node.cc:106–115

}

void ReplicateNode::MatchLogOffset() {
    while (is_running_.load(std::memory_order_relaxed)) {
        int ok = MatchLogOffsetFromNode();
        if (ok != 0) {
            bthread_usleep(FLAGS_binlog_match_logoffset_interval * 1000);
        } else {
            return;
        }
    }
}

void ReplicateNode::SyncData() {
    uint32_t coffee_time = 0;