mirrors/ngircd
1
0
Fork 0
mirror of https://github.com/osmarks/ngircd.git synced 2025-10-24 18:47:39 +00:00
Code Issues Releases Wiki Activity

Don't use a POSIX thread for the Howl "run loop".

Browse Source
This commit is contained in:
Alexander Barton
2004-12-26 16:48:53 +00:00
parent 292879aca4
commit 5049c5c694
1 changed files with 11 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/ngircd/rendezvous.c
View File

@@ -21,7 +21,7 @@
#ifdef RENDEZVOUS #ifdef RENDEZVOUS
static char UNUSED id[] = "$Id: rendezvous.c,v 1.3 2004/12/26 00:14:33 alex Exp $"; static char UNUSED id[] = "$Id: rendezvous.c,v 1.4 2004/12/26 16:48:53 alex Exp $";
#include "imp.h" #include "imp.h"
#include <assert.h> #include <assert.h>
@@ -93,16 +93,11 @@ LOCAL VOID Registration_Reply_Handler( DNSServiceRegistrationReplyErrorType ErrC
#ifdef HOWL #ifdef HOWL
#include <pthread.h>
LOCAL sw_discovery My_Discovery_Session = NULL; LOCAL sw_discovery My_Discovery_Session = NULL;
LOCAL pthread_t My_Howl_Thread; LOCAL sw_salt My_Salt;
LOCAL BOOLEAN My_Howl_Thread_Created = FALSE;
LOCAL sw_result HOWL_API Registration_Reply_Handler( sw_discovery Session, sw_discovery_publish_status Status, sw_discovery_oid Id, sw_opaque Extra ); LOCAL sw_result HOWL_API Registration_Reply_Handler( sw_discovery Session, sw_discovery_publish_status Status, sw_discovery_oid Id, sw_opaque Extra );
LOCAL VOID* Howl_Thread( VOID *x );
#endif /* Howl */ #endif /* Howl */
@@ -119,6 +114,13 @@ GLOBAL VOID Rendezvous_Init( VOID )
Log( LOG_ALERT, "%s exiting due to fatal errors!", PACKAGE_NAME ); Log( LOG_ALERT, "%s exiting due to fatal errors!", PACKAGE_NAME );
exit( 1 ); exit( 1 );
} }
if( sw_discovery_salt( My_Discovery_Session, &My_Salt ) != SW_OKAY )
{
Log( LOG_EMERG, "Can't initialize Rendezvous (Howl): sw_discovery_salt() failed!" );
Log( LOG_ALERT, "%s exiting due to fatal errors!", PACKAGE_NAME );
exit( 1 );
}
#endif #endif
for( i = 0; i < MAX_RENDEZVOUS; i++ ) My_Rendezvous[i].Desc[0] = '\0'; for( i = 0; i < MAX_RENDEZVOUS; i++ ) My_Rendezvous[i].Desc[0] = '\0';
@@ -137,12 +139,6 @@ GLOBAL VOID Rendezvous_Exit( VOID )
} }
#ifdef HOWL #ifdef HOWL
if( My_Howl_Thread_Created )
{
Log( LOG_DEBUG, "Rendezvous: Canceling management thread ..." );
pthread_cancel( My_Howl_Thread );
}
sw_discovery_fina( My_Discovery_Session ); sw_discovery_fina( My_Discovery_Session );
#endif #endif
} /* Rendezvous_Exit */ } /* Rendezvous_Exit */
@@ -261,13 +257,8 @@ GLOBAL VOID Rendezvous_Handler( VOID )
#endif /* Apple */ #endif /* Apple */
#ifdef HOWL #ifdef HOWL
if( My_Discovery_Session != NULL && My_Howl_Thread_Created == FALSE ) sw_ulong msecs = 10;
{ sw_salt_step( My_Salt, &msecs );
/* Create POSIX thread for sw_discovery_run() */
Log( LOG_DEBUG, "Rendezvous: Creating management thread ..." );
pthread_create( &My_Howl_Thread, NULL, Howl_Thread, NULL );
My_Howl_Thread_Created = TRUE;
}
#endif #endif
} /* Rendezvous_Handler */ } /* Rendezvous_Handler */
@@ -366,14 +357,6 @@ LOCAL sw_result HOWL_API Registration_Reply_Handler( sw_discovery Session, sw_di
} /* Registration_Reply_Handler */ } /* Registration_Reply_Handler */
LOCAL VOID *Howl_Thread( VOID *x )
{
assert( x == NULL );
sw_discovery_run( My_Discovery_Session );
pthread_exit( NULL );
} /* Howl_Thread */
#endif /* Howl */ #endif /* Howl */