Miroirs/xwords
1
0
Fork 0
mirror of git://xwords.git.sourceforge.net/gitroot/xwords/xwords synced 2025-02-05 20:45:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

use rwlock instead of mutex

Browse source
This commit is contained in:
ehouse 2005-04-20 12:06:25 +00:00
parent 176e2bf68d
commit 7723fa5e19
1 changed files with 32 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
relay/tpool.cpp
View file

@ -46,7 +46,7 @@ XWThreadPool::GetTPool()
XWThreadPool::XWThreadPool()
{
pthread_mutex_init ( &m_activeSocketsMutex, NULL );
pthread_rwlock_init( &m_activeSocketsRWLock, NULL );
pthread_mutex_init ( &m_queueMutex, NULL );
pthread_cond_init( &m_queueCondVar, NULL );
@ -84,27 +84,53 @@ XWThreadPool::AddSocket( int socket )
{
logf( "AddSocket(%d)", socket );
{
MutexLock ml( &m_activeSocketsMutex );
RWWriteLock ml( &m_activeSocketsRWLock );
m_activeSockets.push_back( socket );
}
interrupt_poll();
}
void
int
XWThreadPool::RemoveSocket( int socket )
{
int found = 0;
{
MutexLock ml( &m_activeSocketsMutex );
RWWriteLock ml( &m_activeSocketsRWLock );
vector<int>::iterator iter = m_activeSockets.begin();
while ( iter != m_activeSockets.end() ) {
if ( *iter == socket ) {
m_activeSockets.erase( iter );
found = 1;
break;
}
++iter;
}
}
return found;
}
void
XWThreadPool::CloseSocket( int socket )
{
int do_interrupt = 0;
if ( !RemoveSocket( socket ) ) {
RWWriteLock rwl( &m_activeSocketsRWLock );
deque<int>::iterator iter = m_queue.begin();
while ( iter != m_queue.end() ) {
if ( *iter == socket ) {
m_queue.erase( iter );
do_interrupt = 1;
break;
}
++iter;
}
}
close( socket );
if ( do_interrupt ) {
interrupt_poll();
}
}
int
@ -189,7 +215,7 @@ XWThreadPool::real_listener()
for ( ; ; ) {
pthread_mutex_lock( &m_activeSocketsMutex );
pthread_rwlock_rdlock( &m_activeSocketsRWLock );
int nSockets = m_activeSockets.size() + 1; /* for pipe */
pollfd* fds = (pollfd*)malloc( sizeof(fds[0]) * nSockets );
pollfd* curfd = fds;
@ -209,7 +235,7 @@ XWThreadPool::real_listener()
len += sprintf( log+len, "%d,", curfd->fd );
++curfd;
}
pthread_mutex_unlock( &m_activeSocketsMutex );
pthread_rwlock_unlock( &m_activeSocketsRWLock );
logf( "calling poll on %s", log );
int nEvents = poll( fds, nSockets, -1 ); /* -1: infinite timeout */