* Copyright 2007, Haiku, Inc.
* Distributed under the terms of the MIT License.
*
* Authors:
* Axel Dörfler, axeld@pinc-software.de
*/
#include <DirectMessageTarget.h>
namespace BPrivate {
BDirectMessageTarget::BDirectMessageTarget()
:
fReferenceCount(1),
fClosed(false)
{
}
BDirectMessageTarget::~BDirectMessageTarget()
{
}
bool
BDirectMessageTarget::AddMessage(BMessage* message)
{
if (fClosed) {
delete message;
return false;
}
fQueue.AddMessage(message);
return true;
}
void
BDirectMessageTarget::Close()
{
fClosed = true;
}
void
BDirectMessageTarget::Acquire()
{
atomic_add(&fReferenceCount, 1);
}
void
BDirectMessageTarget::Release()
{
if (atomic_add(&fReferenceCount, -1) == 1)
delete this;
}
}
