IpcSocket.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#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"
#include "Arp/System/Commons/Ipc/PeerCredentials.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);
    PeerCredentials GetPeerCredentials(IpcSocketError& error);
 
private: // fields
    ISocketService *pSocketService;
};
 
}}}}