CLDPC_Encoder_df
Publisher
+ GetAvailableEventBase()+ OnListen()+ Initialize()+ UnInitialize()
- UdpSocket udp_socket_- vector thread_group_- vector event_base_pool_
Connection
+ OnPeerRead()+ OnPeerEvent()+ Initialize()+ Start()
- struct bufferevent* peer_event_- struct event_base* base_- int fd_- string peer_ip_- uint16_t local_port_-uint16_t peer_port_char buffer_[]int buffer_len_
PubWorker
- OnFileDataReceive()- OnMetaDataReceive()- OnFileDataSend()- GetData()- PutFileDataToBuffer()- PutFileDataToFile()- GenerateCellWithoutEncoding()-GenerateCellWithEncoding()
- struct event* send_event_- struct event_base* send_event_base_- FileConfig file_config_- FILE* write_fp_- FILE* read_fp_- FileEncoder* encoder_
FileEncoder
+ Setup()+ EncodeData()+ SetPAcketLength()
- uint16_t seed_- uint8_t encode_type_- uint32_t block_num_- uint32_t last_block_length_- CLDPC_Encoder_df real_encoder_
TcpServer
+ OnListen()+ ListenCallback()
