74 lines
955 B
C++
74 lines
955 B
C++
/*
|
|
* 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;
|
|
// managed by MediaRosterUndertaker.
|
|
|
|
|
|
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);
|
|
}
|
|
}
|
|
|
|
|
|
} // namespace media
|
|
} // namespace BPrivate
|