dl::utils::basic_pipebuf< CharT, Traits, Allocator > Class Template Reference

Inheritance diagram for dl::utils::basic_pipebuf< CharT, Traits, Allocator >:

Collaboration diagram for dl::utils::basic_pipebuf< CharT, Traits, Allocator >:

Public Member Functions
	basic_pipebuf (const basic_pipebuf &other)=default
	basic_pipebuf (basic_pipebuf &&other)=delete
	basic_pipebuf (size_t bufsize=1024)
bool	is_open () const noexcept
basic_pipebuf< CharT, Traits, Allocator > *	close () noexcept
int_type	underflow () override
int_type	overflow (int_type c=Traits::eof()) override
Public Member Functions inherited from std::basic_streambuf
T	pptr (T... args)
T	epptr (T... args)
T	eback (T... args)
T	setp (T... args)
T	sputbackc (T... args)
T	getloc (T... args)
T	seekoff (T... args)
T	pubseekoff (T... args)
T	sungetc (T... args)
T	sync (T... args)
T	xsputn (T... args)
T	pbase (T... args)
T	sgetc (T... args)
T	pubimbue (T... args)
T	showmanyc (T... args)
T	egptr (T... args)
T	seekpos (T... args)
T	underflow (T... args)
T	setbuf (T... args)
T	gbump (T... args)
T	in_avail (T... args)
T	swap (T... args)
T	basic_streambuf (T... args)
T	pbackfail (T... args)
T	sputc (T... args)
T	xsgetn (T... args)
T	uflow (T... args)
T	overflow (T... args)
T	sputn (T... args)
T	sgetn (T... args)
T	sbumpc (T... args)
T	operator= (T... args)
T	pbump (T... args)
T	pubsetbuf (T... args)
T	pubsync (T... args)
T	imbue (T... args)
T	setg (T... args)
T	snextc (T... args)
T	gptr (T... args)
T	pubseekpos (T... args)
T	~basic_streambuf (T... args)

Detailed Description

template<class CharT, class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>
class dl::utils::basic_pipebuf< CharT, Traits, Allocator >

Definition at line 11 of file pipe.hpp.

Constructor & Destructor Documentation

basic_pipebuf()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

dl::utils::basic_pipebuf< CharT, Traits, Allocator >::basic_pipebuf ( size_t  bufsize = 1024 )

inline

Definition at line 25 of file pipe.hpp.

                                             : readbuf(bufsize), writebuf(bufsize) {
            // Read Pointers are all at the end of the buffer
            this->setg(readbuf.data(), readbuf.data() + readbuf.size(), readbuf.data() + readbuf.size());
            // Set write buffer to whole buffer
            this->setp(writebuf.data(), writebuf.data() + writebuf.size());
        }

~basic_pipebuf()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

dl::utils::basic_pipebuf< CharT, Traits, Allocator >::~basic_pipebuf ( )

inline

Definition at line 31 of file pipe.hpp.

                         {
            if (basic_pipebuf::is_open())
                basic_pipebuf::overflow(Traits::eof());
        }

Member Function Documentation

close()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

basic_pipebuf< CharT, Traits, Allocator > * dl::utils::basic_pipebuf< CharT, Traits, Allocator >::close ( )

inlinenoexcept

Definition at line 38 of file pipe.hpp.

                                                                  {
            if (!is_open())
                return nullptr;
            overflow(Traits::eof()); // Will close the writer
            return this;
        }

is_open()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

bool dl::utils::basic_pipebuf< CharT, Traits, Allocator >::is_open ( ) const

inlinenoexcept

Definition at line 36 of file pipe.hpp.

{ return !writerClosed; }

overflow()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

int_type dl::utils::basic_pipebuf< CharT, Traits, Allocator >::overflow ( int_type  c = Traits::eof() )

inlineoverride

Definition at line 62 of file pipe.hpp.

                                                             {
            if (c == Traits::eof())
                writerClosed = true;
            barrier.arrive_and_wait();
            // Reader will switch buffers and update *Closed flags
            barrier.arrive_and_wait();
            if (writerClosed)
                return (c == Traits::eof()) ? 1 : Traits::eof();
            // Reset Pointers
            this->setp(writebuf.data(), writebuf.data() + writebuf.size());
            *this->pptr() = c;
            this->pbump(1);
            return c;
        }

underflow()

template<class CharT , class Traits = std::char_traits<CharT>, typename Allocator = std::allocator<CharT>>

int_type dl::utils::basic_pipebuf< CharT, Traits, Allocator >::underflow ( )

inlineoverride

Definition at line 45 of file pipe.hpp.

                                      {
            if (readerClosed)
                return Traits::eof();
            barrier.arrive_and_wait();
            // Swap buffers
            std::swap(readbuf, writebuf);
            writerClosed = readerClosed = readerClosed || writerClosed;
            numLastWritten = this->pptr() - this->pbase();
            assert(numLastWritten <= readbuf.size());
            barrier.arrive_and_wait();
            if (readerClosed && numLastWritten == 0) // Reader was freshly closed and no new data was given
                return Traits::eof();
            // Reset Pointer
            this->setg(readbuf.data(), readbuf.data(), readbuf.data() + numLastWritten);
            return Traits::to_int_type(*this->gptr());
        }

---

The documentation for this class was generated from the following file:

• dl/utils/pipe.hpp