types.h

/* Copyright (c) 2014-2017, Human Brain Project
 *                          Daniel Nachbaur <daniel.nachbaur@epfl.ch>
 *                          Juan Hernando <jhernando@fi.upm.es>
 */

#pragma once

#include <functional>
#include <memory>
#include <servus/serializable.h>
#include <servus/servus.h>
#include <servus/types.h>
#include <servus/uint128_t.h>
#include <zeroeq/defines.h>

#ifdef _WIN32
#define NOMINMAX
#include <winsock2.h> // SOCKET
#ifdef DELETE
#undef DELETE
#endif
#endif

namespace zeroeq
{
using servus::uint128_t;
class Monitor;
class Publisher;
class Sender;
class Subscriber;
class URI;

using URIs = std::vector<URI>; 

using EventFunc = std::function<void()>;

using EventPayloadFunc = std::function<void(const void*, size_t)>;

using ReplyFunc = std::function<void(const uint128_t&, const void*, size_t)>;

using ReplyData = std::pair<uint128_t, servus::Serializable::Data>;

using HandleFunc = std::function<ReplyData(const void*, size_t)>;

#ifdef WIN32
typedef SOCKET SocketDescriptor;
#else
typedef int SocketDescriptor;
#endif

// Attn: identical to Win32 INFINITE!
static const uint32_t TIMEOUT_INDEFINITE = 0xffffffffu;

using servus::make_uint128;

static const std::string DEFAULT_SESSION("__zeroeq");
static const std::string NULL_SESSION("__null_session");
static const std::string TEST_SESSION(servus::TEST_DRIVER);
static const std::string ENV_PUB_SESSION("ZEROEQ_PUB_SESSION");
static const std::string ENV_REP_SESSION("ZEROEQ_SERVER_SESSION");

namespace detail
{
struct Socket;
}
namespace zmq
{
using ContextPtr = std::shared_ptr<void>;
using SocketPtr = std::shared_ptr<void>;
}
}