mirror/transmission
1
0
Fork 0
mirror of https://github.com/transmission/transmission synced 2025-02-22 06:00:41 +00:00
Code Issues Releases Wiki Activity

Use tr_cond* a bit more

Browse source
This commit is contained in:
Eric Petit 2007-01-14 12:11:06 +00:00
parent e5e6a8b5df
commit 4386cba273
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
libtransmission/net.c
View file

@ -44,6 +44,7 @@ int tr_netResolve( const char * address, struct in_addr * addr )
/* TODO: Make this code reentrant */
static tr_thread_t resolveThread;
static tr_lock_t resolveLock;
static tr_cond_t resolveCond;
static volatile int resolveDie;
static tr_resolve_t * resolveQueue;
@ -71,6 +72,7 @@ void tr_netResolveThreadInit()
resolveDie = 0;
resolveQueue = NULL;
tr_lockInit( &resolveLock );
tr_condInit( &resolveCond );
tr_threadCreate( &resolveThread, resolveFunc, NULL );
}
@ -86,6 +88,7 @@ void tr_netResolveThreadClose()
tr_lockLock( &resolveLock );
resolveDie = 1;
tr_lockUnlock( &resolveLock );
tr_condSignal( &resolveCond );
tr_wait( 200 );
}
@ -116,6 +119,7 @@ tr_resolve_t * tr_netResolveInit( const char * address )
iter->next = r;
}
tr_lockUnlock( &resolveLock );
tr_condSignal( &resolveCond );
return r;
}
@ -186,10 +190,7 @@ static void resolveFunc( void * arg UNUSED )
{
if( !( r = resolveQueue ) )
{
/* TODO: Use a condition wait */
tr_lockUnlock( &resolveLock );
tr_wait( 50 );
tr_lockLock( &resolveLock );
tr_condWait( &resolveCond, &resolveLock );
continue;
}