amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-29 14:45:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

完整主进程

Browse Source
This commit is contained in:
xiongziliang 2019-05-20 22:22:05 +08:00
parent bc0a39bc52
commit 056ce72182
2 changed files with 19 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
server/System.cpp
View File

@ -275,23 +275,16 @@ static void sig_crash(int sig) {
void System::startDaemon() { void System::startDaemon() {
signal(SIGTTOU,SIG_IGN); static pid_t pid;
signal(SIGTTIN,SIG_IGN);
signal(SIGHUP,SIG_IGN);
signal(SIGINT, [](int) {
InfoL << "SIGINT:exit";
signal(SIGINT,SIG_IGN);
throw ExitException();
});
do{ do{
auto pid = fork(); pid = fork();
if(pid == -1){ if(pid == -1){
WarnL << "fork失败:" << get_uv_errmsg(); WarnL << "fork失败:" << get_uv_errmsg();
//休眠1秒再试 //休眠1秒再试
sleep(1); sleep(1);
continue; continue;
} }
if(pid == 0){ if(pid == 0){
//子进程 //子进程
return; return;
@ -299,23 +292,21 @@ void System::startDaemon() {
//父进程,监视子进程是否退出 //父进程,监视子进程是否退出
DebugL << "启动子进程:" << pid; DebugL << "启动子进程:" << pid;
signal(SIGINT, [](int) {
WarnL << "收到主动退出信号,关闭父进程与子进程";
kill(pid,SIGINT);
exit(0);
});
do{ do{
try { int status = 0;
int status = 0; if(waitpid(pid, &status, 0) >= 0) {
if(waitpid(pid, &status, 0) >= 0) { WarnL << "子进程退出";
WarnL << "子进程退出"; //休眠1秒再启动子进程
//休眠1秒再启动子进程 sleep(1);
sleep(1); break;
break;
}
DebugL << "waitpid被中断:" << get_uv_errmsg();
}catch (ExitException &ex){
WarnL << "收到主动退出信号,关闭父进程与子进程";
//通知子进程主动退出
kill(pid,SIGINT);
//父进程主动退出
exit(0);
} }
DebugL << "waitpid被中断:" << get_uv_errmsg();
}while (true); }while (true);
}while (true); }while (true);
} }

3
server/main.cpp
View File

@ -160,6 +160,9 @@ extern void unInstallWebHook();
static void inline listen_shell_input(){ static void inline listen_shell_input(){
cout << "> 欢迎进入命令模式，你可以输入\"help\"命令获取帮助" << endl; cout << "> 欢迎进入命令模式，你可以输入\"help\"命令获取帮助" << endl;
cout << "> " << std::flush; cout << "> " << std::flush;
signal(SIGTTOU,SIG_IGN);
signal(SIGTTIN,SIG_IGN);
SockUtil::setNoBlocked(STDIN_FILENO); SockUtil::setNoBlocked(STDIN_FILENO);
auto oninput = [](int event) { auto oninput = [](int event) {
if (event & Event_Read) { if (event & Event_Read) {