主要是添加了处理merge的ProcessMergeThread,还未实现真正的逻辑.只是简单的接收请求后,清空localchangeset.
- 在和RequesThread类似,在初始化MOT引擎时,启动ProcessMerge的线程,线程绑定的函数为ProcessMergeThread,在这接收其他节点传来的需要merge的数据,并在本地执行merge过程.
- 通过一个模拟的节点向其发送请求,主要是一个清空set的消息.接收到后清空本地的changeset.
- 基于实现的两个merge线程,简单模拟了数据的merge通信过程,基本实现了利用zeroMQ实现主机之间merge通信.
网友评论