* Copyright 2009, Axel Dörfler, axeld@pinc-software.de.
* Distributed under the terms of the MIT License.
*/
#include <set>
#include <Autolock.h>
#include <Locker.h>
#include <MediaDebug.h>
#include "PortPool.h"
namespace BPrivate {
namespace media {
PortPool* gPortPool;
PortPool::PortPool()
:
BLocker("port pool")
{
}
PortPool::~PortPool()
{
PortSet::iterator iterator = fPool.begin();
for (; iterator != fPool.end(); iterator++)
delete_port(*iterator);
}
port_id
PortPool::GetPort()
{
BAutolock _(this);
if (fPool.empty())
return create_port(1, "media reply port");
port_id port = *fPool.begin();
fPool.erase(port);
ASSERT(port >= 0);
return port;
}
void
PortPool::PutPort(port_id port)
{
ASSERT(port >= 0);
BAutolock _(this);
try {
fPool.insert(port);
} catch (std::bad_alloc& exception) {
delete_port(port);
}
}
}
}
