zookeeper源码解析--请求处理--Leader.ToBeAppliedRequestProcessor

zookeeper源码解析--请求处理--Leader.ToBeAppliedRequestProcessor Leader.ToBeAppliedRequestProcessor

// 交给下一级处理
next.processRequest(request);
// 请求存在事务头，表示是写请求
if (request.getHdr() != null) 
{
	// zxid
    long zxid = request.getHdr().getZxid();
    // 对toBeApplied进行迭代
    Iterator iter = leader.toBeApplied.iterator();
    // 获取当前迭代元素
    if (iter.hasNext()) 
    {
    	// 获取当前迭代元素
        Proposal p = iter.next();
        // 如果迭代提议包含请求
        // 且 请求zxid==zxid
        if (p.request != null && p.request.zxid == zxid) 
        {
        	// 从toBeApplied中将其删除
            iter.remove();
            return;
        }
    }

    LOG.error("Committed request not found on toBeApplied: {}", request);
}