Pipe.h

/*
** libutil++
** $Id: Pipe.h 1653 2016-02-28 19:54:59Z sella $
** Copyright (c) 2011-2016 Digital Genesis, LLC. All Rights Reserved.
** Released under the LGPL Version 2.1 License.
** http://www.digitalgenesis.com
*/

#ifndef __libutilxx__sella__net__Pipe_H__
#define __libutilxx__sella__net__Pipe_H__

#include "../../common.h"
#include "UnixSocket.h"

#include <sys/socket.h>

namespace sella {
        namespace net {
                class Pipe;
        }
}

class sella::net::Pipe {
        public:
                typedef std::shared_ptr<Pipe> shared;
                typedef Pipe *ptr;

                static const size_t ReadSizeDefault = 65536;

        public:
                Pipe(bool nonBlock = true) throw (SocketException);
                Pipe(const Pipe &sock) = delete;
                virtual ~Pipe();
                void operator=(const Pipe &sock) = delete;

                ssize_t write(const void *data, size_t len) throw (SocketException);
                ssize_t write(const std::string &data) throw (SocketException);
                ssize_t write(const std::vector<uint8_t> &data) throw (SocketException);
                ssize_t read(void *data, size_t len) throw (SocketException);
                ssize_t read(std::string &data, size_t len = ReadSizeDefault) throw (SocketException);
                ssize_t read(std::vector<uint8_t> &data, size_t len = ReadSizeDefault) throw (SocketException);

                int getWriteFD(void);
                int getReadFD(void);

                static const Pipe::shared shared_ptr(bool nonBlock = true) throw (SocketException);

        protected:
                int fd[2];
};

#endif

/*
** vim: noet ts=3 sw=3
*/