Method process_runable_rpcs

src/braft/node.cpp:2998–3023

}

void NodeImpl::AppendEntriesCache::process_runable_rpcs(int64_t local_last_index) {
    CHECK(!_rpc_map.empty());
    CHECK(!_rpc_queue.empty());
    HandleAppendEntriesFromCacheArg* arg = NULL;
    for (std::map<int64_t, AppendEntriesRpc*>::iterator it = _rpc_map.begin();
        it != _rpc_map.end();) {
        AppendEntriesRpc* rpc = it->second;
        if (rpc->request->prev_log_index() > local_last_index) {
            break;
        }
        local_last_index = rpc->request->prev_log_index() + rpc->request->entries_size();
        _rpc_map.erase(it++);
        rpc->RemoveFromList();
        if (arg == NULL) {
            arg = new HandleAppendEntriesFromCacheArg;
            arg->node = _node;
        }
        arg->rpcs.Append(rpc);
    }
    if (arg != NULL) {
        start_to_handle(arg);
    }
    if (_rpc_map.empty()) {
        stop_timer();
    }
}

void NodeImpl::AppendEntriesCache::clear() {
    BRAFT_VLOG << "node " << _node->_group_id << ":" << _node->_server_id