Zookeeper源码分析(8)- CommitProcessor
2014-03-26 17:34
447 查看
这个processor主要负责将已经完成本机submit的request和已经在集群中达成commit的request匹配,并将匹配后的request交给nextProcessor(即ToBeAppliedRequestProcessor)处理
这是个异步处理的processor,它有两个入口:
一个是前面的processor调用的processRequest,它把request放到队列queuedRequests中
另一个是leader在收到follower的ack包后,调用的processAck函数,如果leader收到了足够的ack包,他会调用这个processord的commit函数,这个函数把请求放入到队列committedRequests中
这个processor还会启动一个线程,他的主要是逻辑就是匹配queuedRequests和committedRequests中的request,匹配是基于两个队列的对首比较的,然后比较两个队列对首的以下元素:
request的txnHeader
request的record
request的zxid
如果都匹配上了就把这个request发给ToBeAppliedRequestProcessor处理
这是个异步处理的processor,它有两个入口:
一个是前面的processor调用的processRequest,它把request放到队列queuedRequests中
另一个是leader在收到follower的ack包后,调用的processAck函数,如果leader收到了足够的ack包,他会调用这个processord的commit函数,这个函数把请求放入到队列committedRequests中
这个processor还会启动一个线程,他的主要是逻辑就是匹配queuedRequests和committedRequests中的request,匹配是基于两个队列的对首比较的,然后比较两个队列对首的以下元素:
request的txnHeader
request的record
request的zxid
如果都匹配上了就把这个request发给ToBeAppliedRequestProcessor处理
相关文章推荐
- php 读取excel 时间列
- php 打印所有定义的变量
- php正则表达式攻略
- PHP中汉字截取
- smarty获取php中的变量
- NFS实现LAMP分离多服务器同步更新服务 推荐
- php面向对象之接口
- PHP5 的五种常用模式
- PHP初学笔记
- php面向对象之抽象类
- js+php级联
- PHPMailer邮件发送
- PHP 5.0对象模型深度探索之定义一个类
- thinkphp整合dwz 和xhEditor遇到的问题总结
- PHP中使用XML-RPC构造Web Service简单入门
- php多进程实现
- PHP MySQL多个平行表联合查询,比如按照月份或者按照日期的数据表
- php--错误日志
- php float转为int 失真问题解决办法
- 关于thinkphp钩子在onethink中的简单运用