openGauss修改记录# 2020-12-06

2020-12-06  本文已影响0人  upup果

主要是添加了处理merge的ProcessMergeThread,还未实现真正的逻辑.只是简单的接收请求后,清空localchangeset.

  1. 在和RequesThread类似,在初始化MOT引擎时,启动ProcessMerge的线程,线程绑定的函数为ProcessMergeThread,在这接收其他节点传来的需要merge的数据,并在本地执行merge过程.
  2. 通过一个模拟的节点向其发送请求,主要是一个清空set的消息.接收到后清空本地的changeset.
  3. 基于实现的两个merge线程,简单模拟了数据的merge通信过程,基本实现了利用zeroMQ实现主机之间merge通信.
上一篇下一篇

猜你喜欢

热点阅读