- 重构 Channel记录索引值，便于事件收集
- Processor的Pop和Push接口中收集一些信息，可以统计每个Processor等待在io上的时间。后续收集的信息会更加细化，例如thread_id，每个port上每次io的字节数等等。
- 后续也会支持收集用户自定义事件。
- 重构 Processor的事件收集机制，收集的事件的统计结果作为Pipeline.Run函数的返回值返回给用户
- new concept RecordTransferredBytes, 对于数据类型T，用户可以通过在tunnel命名空间添加
GetBytes的T的特化版本，或者添加一个size_t tunnel_get_bytes() const成员函数来使统计信息中包含每个节点读取与写出的字节数。 - 关于中止信息如何跨pipeline传递的方案 [todo]
- add new interface Pipeline.BindExecutorForProcessor
- 支持多个pipeline绑定同一个abort_channel
- 重构channel_sink和channel_source的托管模式，应该向用户设置的channel传递退出信息。
- add new awaiter SocketAcceptAwaiter
- replace SimpleExecutor in some test with TunnelExecutor (fix occasionally core)
- add new concept HasTunnelSerializeSpecialization and HasTunnelDeserializeSpecialization
- add socket_source and socket_sink
- add new tool pipeline_draw.py
- add switcher new api : check_topic_exist and close_topic