/*
 * 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;
}

}       // namespace BPrivate