HelloWorld

MonitorHandler

- createSocket(port : int) : int- createEpoll() : int- epollStart() : int- release() : void- addEpoll(fd : int) : int- deleteEpoll(fd : int) : int+ init() : int+ start(port : int) : int+ Send(TaskUnit*) : int

TypeHandler

- m_Instance : TypeHandler*- callback : CallBack- m_sem : sem_t- m_thread : pthread_t- m_mutex : pthread_mutex_t- m_shutdown : bool- taskqueue : queue<TaskUnit*>

+ init() : int+ destory() : int+ instance() : TypeHandler*+ type_handle_thread(void*) : void*+ process(TaskUnit*) : void+ push(TaskUnit*) : void+ pop() : TaskUnit*+ to_upper(TaskUnit*) : void+ to_lower(TaskUnit*) : void+ stress(TaskUnit*) : void+ setCallBack(CallBack &) : void

TaskUnit

- sockfd : int- address : sockaddr_in- buffer : char*- type : TaskType- user_count : int

PacketHandler

- m_Instance : PacketHandler*- HEAD_SIZE : int- PACKET_SIZE : int- BODY_SIZE : int- callback ：CallBack- m_sem : sem_t- m_thread : pthread_t- m_mutex : pthread_mutex_t- m_shutdown : bool- taskqueue : queue<TaskUnit*>

+ init() : int+ destory() : int+ instance() : PacketHandler*+ packet_handle_thread(void*) : void*+ process() : void+ submit() : void+ push() : void+ pop() : TaskUnit*+ pack(TaskUnit*) : int+ unpack(TaskUnit*) : int+ setCallBack(CallBack&) : void

1

*