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"
#include "Arp/System/Ve/ISocketService.hpp"
 
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);
 
    virtual ISocketService::PeerCredentials GetPeerCredentials(IpcSocketError& error);
 
private: // fields
 
    ISocketService *pSocketService;
 
};
 
}}}}