eventsource.cxx

rtp在linux下的实现

// EventSource.cpp: implementation of the EventSource class.
//
//////////////////////////////////////////////////////////////////////

#include "EventSource.h"
#include <algorithm>

#ifndef WIN32
#define EnterCriticalSection(x) (x)->lock()
#define LeaveCriticalSection(x) (x)->lock()
#endif

using namespace std;

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

EventSource::EventSource()
{
#ifdef WIN32
	InitializeCriticalSection(&listenersMutex);
#endif
}

EventSource::~EventSource()
{
	EnterCriticalSection(&listenersMutex);
	listeners.clear();
	LeaveCriticalSection(&listenersMutex);
#ifdef WIN32
	DeleteCriticalSection(&listenersMutex);
#endif
}

int
EventSource::AddListener(void *listener)
{
	EnterCriticalSection(&listenersMutex);
	if (find(listeners.begin(), listeners.end(), listener) == listeners.end())
	{
		listeners.push_back(listener);
	}
	LeaveCriticalSection(&listenersMutex);
	return 0;
}

int
EventSource::RemoveListener(void *listener)
{
	EnterCriticalSection(&listenersMutex);
	vector<void *>::iterator position = NULL;
	position = find(listeners.begin(), listeners.end(), listener);
	if (position != listeners.end())
	{
		listeners.erase(position);
	}
	LeaveCriticalSection(&listenersMutex);
	return 0;
}