acl/lib_acl_cpp/include/acl_cpp/master/master_udp.hpp
2017-07-05 10:27:33 +08:00

82 lines
2.0 KiB
C++
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

#pragma once
#include "master_base.hpp"
#include "../stdlib/locker.hpp"
namespace acl {
class ACL_CPP_API master_udp : public master_base
{
public:
/**
* 开始运行,调用该函数是指该服务进程是在 acl_master 服务框架
* 控制之下运行,一般用于生产机状态
* @param argc {int} 从 main 中传递的第一个参数,表示参数个数
* @param argv {char**} 从 main 中传递的第二个参数
*/
void run_daemon(int argc, char** argv);
/**
* 在单独运行时的处理函数,用户可以调用此函数进行一些必要的调试工作
* @param addrs {const char*} 服务监听地址列表格式IP:PORT, IP:PORT...
* @param path {const char*} 配置文件全路径
* @param count {unsigned int} 循环服务的次数,达到此值后函数自动返回;
* 若该值为 0 则表示程序一直循环处理外来请求而不返回
* @return {bool} 监听是否成功
*/
bool run_alone(const char* addrs, const char* path = NULL,
unsigned int count = 1);
protected:
// 该类不能直接被实例化
master_udp();
virtual ~master_udp();
/**
* 纯虚函数:当 UDP 流有数据可读时回调子类此函数
* @param stream {socket_stream*}
*/
virtual void on_read(socket_stream* stream) = 0;
/**
* 获得本地监听的套接口流对象集合
* @return {const std::vector<socket_stream*>&}
*/
const std::vector<socket_stream*>& get_sstreams() const
{
return sstreams_;
}
/**
* 当线程初始化时该虚方法将被调用
*/
virtual void thread_on_init(void) {}
private:
std::vector<socket_stream*> sstreams_;
locker locker_;
void close_sstreams(void);
void run(int argc, char** argv);
private:
// 当接收到一个客户端连接时回调此函数
static void service_main(void*, ACL_VSTREAM*);
// 当进程切换用户身份后调用的回调函数
static void service_pre_jail(void*);
// 当进程切换用户身份后调用的回调函数
static void service_init(void*);
// 当进程退出时调用的回调函数
static void service_exit(void*);
// 当线程启动时调用的回调函数
static void thread_init(void*);
// 当进程收到 SIGHUP 信号后会回调本函数
static void service_on_sighup(void*);
};
} // namespace acl