From 9fb0b2691d7298c67f404c0d5de256c4189889fc Mon Sep 17 00:00:00 2001 From: ehouse Date: Fri, 25 Mar 2005 02:59:10 +0000 Subject: [PATCH] first checked in --- relay/mlock.h | 64 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 64 insertions(+) create mode 100644 relay/mlock.h diff --git a/relay/mlock.h b/relay/mlock.h new file mode 100644 index 000000000..34e5a601c --- /dev/null +++ b/relay/mlock.h @@ -0,0 +1,64 @@ +/* -*-mode: C; fill-column: 78; c-basic-offset: 4; -*- */ + +/* + * Copyright 2005 by Eric House (fixin@peak.org). All rights reserved. + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + */ + +#ifndef _MLOCK_H_ +#define _MLOCK_H_ + +#include + +#include "xwrelay_priv.h" + +class MutexLock { + public: + MutexLock( pthread_mutex_t* mutex ) { + m_mutex = mutex; + logf( "locking mutex %x", mutex ); + pthread_mutex_lock( mutex ); + logf( "successfully locked mutex %x", mutex ); + } + ~MutexLock() { + logf( "UNlocking mutex %x", m_mutex ); + pthread_mutex_unlock( m_mutex ); + } + + private: + pthread_mutex_t* m_mutex; +}; + +class SocketWriteLock { + public: + SocketWriteLock( int socket ) { + m_socket = socket; + m_mutex = GetWriteMutexForSocket( socket ); + logf( "locking mutex %x for socket %d", m_mutex, socket ); + pthread_mutex_lock( m_mutex ); + logf( "successfully locked mutex %x for socket %d", m_mutex, socket ); + } + ~SocketWriteLock() { + logf( "UNlocking mutex %x for socket %d", m_mutex, m_socket ); + pthread_mutex_unlock( m_mutex ); + } + + private: + pthread_mutex_t* m_mutex; + int m_socket; +}; + +#endif