Semaphore.cpp

Go to the documentation of this file.

/*
* Copyright Onix Solutions Limited [OnixS]. All rights reserved.
*
* This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law
* and international copyright treaties.
*
* Access to and use of the software is governed by the terms of the applicable OnixS Software
* Services Agreement (the Agreement) and Customer end user license agreements granting
* a non-assignable, non-transferable and non-exclusive license to use the software
* for it's own data processing purposes under the terms defined in the Agreement.
*
* Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part
* of this source code or associated reference material to any other location for further reproduction
* or redistribution, and any amendments to this copyright notice, are expressly prohibited.
*
* Any reproduction or redistribution for sale or hiring of the Software not in accordance with
* the terms of the Agreement is a violation of copyright law.
*/

#include <OnixS/Core/Concurrency/Semaphore.h>

#include <OnixS/SgxTitan/MarketData/Itch/Semaphore.h>

#include "NamespaceHelper.h"

ONIXS_HANDLER_NAMESPACE_BEGIN
    
class Semaphore::Impl
{
public:
    Impl(int initialCounter) :
        sem_(initialCounter)
    {
    }

    ~Impl()
    {
    }

    bool acquire(int timeoutInMs)
    {
        if (timeoutInMs == -1)
        {
            sem_.acquire();
            return true;
        }
        else
        {
            const OnixS::Time::TotalSeconds seconds = timeoutInMs / 1000;
            const OnixS::Time::Nanoseconds nanoseconds = (timeoutInMs % 1000) * 1000000;
            const OnixS::Time::TimeSpan timeout(seconds, OnixS::Time::NanosecondSubseconds(nanoseconds));
            return sem_.acquire(timeout);
        }
    }

    void release()
    {
        sem_.release();
    }

private:
    OnixS::Concurrency::Semaphore sem_;
};

Semaphore::Semaphore(int initialCounter) :
    impl_(new Impl(initialCounter))
{
}

Semaphore::~Semaphore()
{
    delete impl_;
}

bool Semaphore::acquire(int timeoutInMs)
{
    return impl_->acquire(timeoutInMs);
}

void Semaphore::release()
{
    impl_->release();
}

ONIXS_HANDLER_NAMESPACE_END