summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDirk Engling <erdgeist@erdgeist.org>2024-04-12 18:10:31 +0200
committerDirk Engling <erdgeist@erdgeist.org>2024-04-12 18:10:31 +0200
commit301faeb10c5994a6fd31adc5f0b4f8f2b5c23502 (patch)
tree126b9981239b9419c63ad4fdbf267160c51934a1
parent52d9829f81264de99055fb5c85e7e05915997aa6 (diff)
Start an extra thread to update timer cache. Using signals was unnecessary
-rw-r--r--opentracker.c22
1 files changed, 12 insertions, 10 deletions
diff --git a/opentracker.c b/opentracker.c
index 2108a98..7c67f26 100644
--- a/opentracker.c
+++ b/opentracker.c
@@ -70,10 +70,6 @@ static void signal_handler( int s ) {
70#endif 70#endif
71 71
72 exit( 0 ); 72 exit( 0 );
73 } else if( s == SIGALRM ) {
74 /* Maintain our copy of the clock. time() on BSDs is very expensive. */
75 g_now_seconds = time(NULL);
76 alarm(5);
77 } 73 }
78} 74}
79 75
@@ -83,7 +79,6 @@ static void defaul_signal_handlers( void ) {
83 sigaddset (&signal_mask, SIGPIPE); 79 sigaddset (&signal_mask, SIGPIPE);
84 sigaddset (&signal_mask, SIGHUP); 80 sigaddset (&signal_mask, SIGHUP);
85 sigaddset (&signal_mask, SIGINT); 81 sigaddset (&signal_mask, SIGINT);
86 sigaddset (&signal_mask, SIGALRM);
87 pthread_sigmask (SIG_BLOCK, &signal_mask, NULL); 82 pthread_sigmask (SIG_BLOCK, &signal_mask, NULL);
88} 83}
89 84
@@ -95,11 +90,10 @@ static void install_signal_handlers( void ) {
95 sa.sa_handler = signal_handler; 90 sa.sa_handler = signal_handler;
96 sigemptyset(&sa.sa_mask); 91 sigemptyset(&sa.sa_mask);
97 sa.sa_flags = SA_RESTART; 92 sa.sa_flags = SA_RESTART;
98 if ((sigaction(SIGINT, &sa, NULL) == -1) || (sigaction(SIGALRM, &sa, NULL) == -1) ) 93 if ((sigaction(SIGINT, &sa, NULL) == -1))
99 panic( "install_signal_handlers" ); 94 panic( "install_signal_handlers" );
100 95
101 sigaddset (&signal_mask, SIGINT); 96 sigaddset (&signal_mask, SIGINT);
102 sigaddset (&signal_mask, SIGALRM);
103 pthread_sigmask (SIG_UNBLOCK, &signal_mask, NULL); 97 pthread_sigmask (SIG_UNBLOCK, &signal_mask, NULL);
104} 98}
105 99
@@ -608,12 +602,22 @@ int drop_privileges ( const char * const serveruser, const char * const serverdi
608 return 0; 602 return 0;
609} 603}
610 604
605/* Maintain our copy of the clock. time() on BSDs is very expensive. */
606static void *time_caching_worker(void*args) {
607 (void)args;
608 while (1) {
609 g_now_seconds = time(NULL);
610 sleep(5);
611 }
612}
613
611int main( int argc, char **argv ) { 614int main( int argc, char **argv ) {
612 ot_ip6 serverip; 615 ot_ip6 serverip;
613 ot_net tmpnet; 616 ot_net tmpnet;
614 int bound = 0, scanon = 1; 617 int bound = 0, scanon = 1;
615 uint16_t tmpport; 618 uint16_t tmpport;
616 char * statefile = 0; 619 char * statefile = 0;
620 pthread_t thread_id; /* time cacher */
617 621
618 memset( serverip, 0, sizeof(ot_ip6) ); 622 memset( serverip, 0, sizeof(ot_ip6) );
619#ifdef WANT_V4_ONLY 623#ifdef WANT_V4_ONLY
@@ -690,6 +694,7 @@ int main( int argc, char **argv ) {
690 panic( "drop_privileges failed, exiting. Last error"); 694 panic( "drop_privileges failed, exiting. Last error");
691 695
692 g_now_seconds = time( NULL ); 696 g_now_seconds = time( NULL );
697 pthread_create( &thread_id, NULL, time_caching_worker, NULL);
693 698
694 /* Create our self pipe which allows us to interrupt mainloops 699 /* Create our self pipe which allows us to interrupt mainloops
695 io_wait in case some data is available to send out */ 700 io_wait in case some data is available to send out */
@@ -714,9 +719,6 @@ int main( int argc, char **argv ) {
714 if( !g_udp_workers ) 719 if( !g_udp_workers )
715 udp_init( -1, 0 ); 720 udp_init( -1, 0 );
716 721
717 /* Kick off our initial clock setting alarm */
718 alarm(5);
719
720 server_mainloop( 0 ); 722 server_mainloop( 0 );
721 723
722 return 0; 724 return 0;