IpcSocket.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Commons/Net/PollMode.hpp"
#include "Arp/System/Commons/Net/SelectMode.hpp"
#include "Arp/System/Commons/Net/ShutdownMode.hpp"
#include "Arp/System/Commons/Ipc/IpcSocketError.hpp"

// forwards
namespace Arp { namespace System { namespace Ve
{
class ISocketService;
}}}

namespace Arp { namespace System { namespace Commons { namespace Ipc
{

class IpcSocket
{

public: // typedefs/usings

    typedef std::shared_ptr<IpcSocket> Ptr;

    using SelectMode = Arp::System::Commons::Net::SelectMode;

    using PollMode = Arp::System::Commons::Net::PollMode;

    using ShutdownMode = Arp::System::Commons::Net::ShutdownMode;

private: // typedefs/usings
    using ISocketService = Arp::System::Ve::ISocketService;

public: // construction/destruction
    IpcSocket(bool blocking = true);
    IpcSocket(const IpcSocket& arg) = delete;
    IpcSocket(IpcSocket&& arg) = default;
    IpcSocket& operator=(const IpcSocket& arg) = delete;
    ~IpcSocket(void);

private: // construction/destruction
    IpcSocket(ISocketService *pSocket);

public: // operations

    IpcSocketError Bind(const Arp::String& path);

    IpcSocketError Listen(size_t backlog);

    IpcSocketError Connect(const Arp::String& path);

    bool Select(SelectMode mode, Microseconds timeout, IpcSocketError& error);

    int Poll(PollMode mode, Milliseconds timeout, IpcSocketError& error);

    Ptr Accept(IpcSocketError& error);

    IpcSocketError  Shutdown(void);

    IpcSocketError  Shutdown(ShutdownMode mode);

    IpcSocketError Close(void);

    int Send(const void *pBuffer, size_t length, IpcSocketError& error);

    int Receive(void *pBuffer, size_t length, IpcSocketError& error);

private: // fields

    ISocketService *pSocketService;

};

}}}}