context.hpp

Go to the documentation of this file.

/*
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * This file is part of zmqpp.
 * Copyright (c) 2011-2015 Contributors as noted in the AUTHORS file.
 */

#ifndef ZMQPP_CONTEXT_HPP_
#define ZMQPP_CONTEXT_HPP_

#include <cassert>

#include <zmq.h>

#include "compatibility.hpp"
#include "exception.hpp"
#if (ZMQ_VERSION_MAJOR > 3) || ((ZMQ_VERSION_MAJOR == 3) && (ZMQ_VERSION_MINOR >= 2))
#include "context_options.hpp"
#endif

namespace zmqpp
{

class context
{
public:

#if (ZMQ_VERSION_MAJOR < 3) || ((ZMQ_VERSION_MAJOR == 3) && (ZMQ_VERSION_MINOR < 2))

    context(int const& threads = 1)
#else

    context()
#endif
        : _context(nullptr)
    {
#if (ZMQ_VERSION_MAJOR < 3) || ((ZMQ_VERSION_MAJOR == 3) && (ZMQ_VERSION_MINOR < 2))
        _context = zmq_init(threads);
#else
        _context = zmq_ctx_new();
#endif

        if (nullptr == _context)
        {
            throw zmq_internal_exception();
        }
    }

    ~context() NOEXCEPT
    {
        if (nullptr != _context)
        {
            terminate();
        }
    }

    context(context&& source) NOEXCEPT
        : _context(source._context)
    {
        source._context = nullptr;
    }

    context& operator=(context&& source) NOEXCEPT
    {
        std::swap( _context, source._context );
        return *this;
    }

    void terminate();

#if (ZMQ_VERSION_MAJOR > 3) || ((ZMQ_VERSION_MAJOR == 3) && (ZMQ_VERSION_MINOR >= 2))

    void set(context_option const option, int const value);

    int get(context_option const option);
#endif

    operator bool() const NOEXCEPT
    {
        return nullptr != _context;
    }

    operator void*() const NOEXCEPT
    {
        return _context;
    }

private:
    void* _context;

    // No copy - private and not implemented
    context(context const&) ZMQPP_EXPLICITLY_DELETED;
    context& operator=(context const&) NOEXCEPT ZMQPP_EXPLICITLY_DELETED;
};

}

#endif /* ZMQPP_CONTEXT_HPP_ */