dtm_control_workflow
2016-08-05 15:28:37 0 举报
dtm_control_workflow是一种用于控制和管理数据转换工作流的系统。它允许用户定义、执行和监控数据转换过程,以确保数据的质量和一致性。该系统具有高度的灵活性和可扩展性,可以适应各种复杂的数据转换需求。通过使用dtm_control_workflow,用户可以有效地管理数据转换过程中的各个阶段,包括数据清洗、转换、验证和加载等。此外,该系统还提供了丰富的可视化工具,使用户能够直观地了解数据转换的状态和进度。总之,dtm_control_workflow是一个强大的数据转换工作流管理系统,能够帮助用户高效地完成数据转换任务。
作者其他创作
大纲/内容
本地信号通信
内部小循环
N
读取共享内存,遍历当前注册的子进程
网络通信
重新初始化日志关闭继承于Master的dtm.log的fd打开control_process.log
阻塞地抢ctrl锁
Control
将控制Socket放入epoll,监听IN事件
如果需要控制Master/Worker行为通过它们对应的Pipe进行
end of 遍历
如果是服务Socket,是新连接
是常规Client Socket与Client通信,接受并处理控制命令
主循环while 没有收到shutdown信号
执行配置中心逻辑
Y
向该子进程的Pipe发送控制指令
end of 主循环
有新生子进程需要发送控制指令?
主循环
本地管道通信
阻塞epoll_wait,超时为timeout
从服务Socket中accept出新的Client Socket并放入epoll,监听OUT事件
更新Control自己维护的当前alive子进程列表
Color Legend
共享内存操作
从Master继承过来的所有Pipe关掉所有Worker/Master侧Pipe
已收到shutdown信号?
遍历本次epoll返回的ready fd
创建本进程epoll
0 条评论
下一页