mirrors/neutrino
1
0
Fork 0
mirror of https://github.com/tuxbox-neutrino/neutrino.git synced 2025-08-29 16:31:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

neutrino: avoid crash when signals are caught during start

Browse Source 
this needs more work to avoid crashes when interrupted early
This commit is contained in:
Stefan Seyfried
2013-03-03 21:57:59 +01:00
parent 0cfdd6d9bb
commit 6c4b9741ec
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/neutrino.cpp
View File

@@ -134,9 +134,11 @@ t_channel_id standby_channel_id;
//NEW //NEW
static pthread_t timer_thread; static pthread_t timer_thread;
void * timerd_main_thread(void *data); void * timerd_main_thread(void *data);
static bool timerd_thread_started = false;
void * nhttpd_main_thread(void *data); void * nhttpd_main_thread(void *data);
static pthread_t nhttpd_thread ; static pthread_t nhttpd_thread ;
static bool nhttpd_thread_started = false;
//#define DISABLE_SECTIONSD //#define DISABLE_SECTIONSD
@@ -1886,6 +1888,7 @@ fprintf(stderr, "[neutrino start] %d -> %5ld ms\n", __LINE__, time_monotonic_ms
} }
g_settings.shutdown_timer_record_type = false; g_settings.shutdown_timer_record_type = false;
pthread_create (&timer_thread, NULL, timerd_main_thread, (void *)&timer_wakeup); pthread_create (&timer_thread, NULL, timerd_main_thread, (void *)&timer_wakeup);
timerd_thread_started = true;
// timer_wakeup = false; // timer_wakeup = false;
powerManager = new cPowerManager; powerManager = new cPowerManager;
@@ -1917,6 +1920,7 @@ fprintf(stderr, "[neutrino start] %d -> %5ld ms\n", __LINE__, time_monotonic_ms
dvbsub_init(); dvbsub_init();
pthread_create (&nhttpd_thread, NULL, nhttpd_main_thread, (void *) NULL); pthread_create (&nhttpd_thread, NULL, nhttpd_main_thread, (void *) NULL);
nhttpd_thread_started = true;
CStreamManager::getInstance()->Start(); CStreamManager::getInstance()->Start();
@@ -3630,14 +3634,18 @@ void stop_daemons(bool stopall)
g_Radiotext = NULL; g_Radiotext = NULL;
} }
printf("httpd shutdown\n"); printf("httpd shutdown\n");
pthread_cancel(nhttpd_thread); if (nhttpd_thread_started) {
pthread_join(nhttpd_thread, NULL); pthread_cancel(nhttpd_thread);
pthread_join(nhttpd_thread, NULL);
}
printf("httpd shutdown done\n"); printf("httpd shutdown done\n");
CStreamManager::getInstance()->Stop(); CStreamManager::getInstance()->Stop();
if(stopall) { if(stopall) {
printf("timerd shutdown\n"); printf("timerd shutdown\n");
g_Timerd->shutdown(); if (g_Timerd)
pthread_join(timer_thread, NULL); g_Timerd->shutdown();
if (timerd_thread_started)
pthread_join(timer_thread, NULL);
printf("timerd shutdown done\n"); printf("timerd shutdown done\n");
} }
#ifndef DISABLE_SECTIONSD #ifndef DISABLE_SECTIONSD
@@ -3703,6 +3711,9 @@ void sighandler (int signum)
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
g_Timerd = NULL;
g_Radiotext = NULL;
g_Zapit = NULL;
setDebugLevel(DEBUG_NORMAL); setDebugLevel(DEBUG_NORMAL);
signal(SIGTERM, sighandler); // TODO: consider the following signal(SIGTERM, sighandler); // TODO: consider the following
signal(SIGINT, sighandler); // NOTES: The effects of signal() in a multithreaded signal(SIGINT, sighandler); // NOTES: The effects of signal() in a multithreaded