dtm_control_workflow
2016-08-05 15:28:37 0 举报
dtm_control_workflow是一种用于管理和控制数据转换工作流的工具。它可以帮助用户在复杂的数据处理过程中,实现数据的精确转换和有效管理。通过使用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 条评论
下一页