core::pipe::Source Class Reference

#include <Source.h>

Inheritance diagram for core::pipe::Source:

Collaboration diagram for core::pipe::Source:

Public Member Functions
	Source ()=default
	Source (Source &)=delete
	Source (Source &&) noexcept=default
Source &	operator= (Source &)=delete
Source &	operator= (Source &&) noexcept=default
virtual	~Source ()
virtual bool	isOpen ()=0
bool	pipe (Sink *sink)
bool	pipe (const std::shared_ptr< Sink > &sink)
virtual void	start ()=0
virtual void	suspend ()=0
virtual void	resume ()=0
virtual void	stop ()=0

Protected Member Functions
ssize_t	send (const char *chunk, std::size_t chunkLen)
void	eof ()
void	error (int errnum)

Private Member Functions
void	disconnect (const Sink *sink)

Private Attributes
Sink *	sink = nullptr

Friends
class	Sink

Detailed Description

Definition at line 59 of file Source.h.

Constructor & Destructor Documentation

Source() [1/3]

core::pipe::Source::Source ( )

default

Source() [2/3]

core::pipe::Source::Source ( Source &  )

delete

Source() [3/3]

core::pipe::Source::Source ( Source &&  )

defaultnoexcept

~Source()

core::pipe::Source::~Source ( )

virtual

Definition at line 54 of file Source.cpp.

                    {
        if (sink != nullptr) {
            sink->disconnect(this);
        }
    }

References core::pipe::Sink::disconnect(), and sink.

Here is the call graph for this function:

Member Function Documentation

disconnect()

void core::pipe::Source::disconnect ( const Sink *  sink )

private

Definition at line 75 of file Source.cpp.

                                            {
        if (sink == this->sink) {
            this->sink->disconnect(this);
            this->sink = nullptr;
 
            stop();
        }
    }

References core::pipe::Sink::disconnect(), sink, and stop().

Referenced by core::pipe::Sink::stop(), and core::pipe::Sink::~Sink().

Here is the call graph for this function:

Here is the caller graph for this function:

eof()

void core::pipe::Source::eof ( )

protected

Definition at line 97 of file Source.cpp.

                     {
        if (sink != nullptr) {
            sink->streamEof();
        }
    }

References sink, and core::pipe::Sink::streamEof().

Referenced by core::file::FileReader::onEvent(), and core::file::FileReader::stop().

Here is the call graph for this function:

Here is the caller graph for this function:

error()

void core::pipe::Source::error ( int  errnum )

protected

Definition at line 103 of file Source.cpp.

                                 {
        if (sink != nullptr) {
            sink->streamError(errnum);
        }
    }

References sink, and core::pipe::Sink::streamError().

Referenced by core::file::FileReader::onEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

isOpen()

virtual bool core::pipe::Source::isOpen ( )

pure virtual

Implemented in core::file::FileReader.

Referenced by pipe(), and core::pipe::Sink::pipe().

Here is the caller graph for this function:

operator=() [1/2]

Source & core::pipe::Source::operator= ( Source &&  )

defaultnoexcept

operator=() [2/2]

Source & core::pipe::Source::operator= ( Source &  )

delete

pipe() [1/2]

bool core::pipe::Source::pipe

(

const std::shared_ptr< Sink > &

sink

)

Definition at line 71 of file Source.cpp.

                                                     {
        return pipe(sink.get());
    }

References pipe().

Here is the call graph for this function:

pipe() [2/2]

bool core::pipe::Source::pipe

(

Sink *

sink

)

Definition at line 60 of file Source.cpp.

                                {
        const bool success = sink != nullptr && isOpen();
 
        if (success) {
            this->sink = sink;
            sink->pipe(this);
        }
 
        return success;
    }

References isOpen(), core::pipe::Sink::pipe(), and sink.

Referenced by web::http::client::MasterRequest::executeSendFile(), pipe(), and web::http::server::Response::sendFile().

Here is the call graph for this function:

Here is the caller graph for this function:

resume()

virtual void core::pipe::Source::resume ( )

pure virtual

Implemented in core::file::FileReader.

Referenced by core::socket::stream::SocketWriter::doWrite().

Here is the caller graph for this function:

send()

ssize_t core::pipe::Source::send ( const char *  chunk, std::size_t  chunkLen  )

protected

Definition at line 84 of file Source.cpp.

                                                              {
        ssize_t ret = static_cast<ssize_t>(chunkLen);
 
        if (sink != nullptr) {
            sink->streamData(chunk, chunkLen);
        } else {
            ret = -1;
            errno = EPIPE;
        }
 
        return ret;
    }

References sink, and core::pipe::Sink::streamData().

Referenced by core::file::FileReader::onEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

start()

virtual void core::pipe::Source::start ( )

pure virtual

Implemented in core::file::FileReader.

Referenced by web::http::client::MasterRequest::onSourceConnect(), and web::http::server::Response::onSourceConnect().

Here is the caller graph for this function:

stop()

virtual void core::pipe::Source::stop ( )

pure virtual

Implemented in core::file::FileReader.

Referenced by disconnect(), web::http::client::MasterRequest::onSourceConnect(), and web::http::server::Response::onSourceConnect().

Here is the caller graph for this function:

suspend()

virtual void core::pipe::Source::suspend ( )

pure virtual

Implemented in core::file::FileReader.

Referenced by core::socket::stream::SocketWriter::sendToPeer().

Here is the caller graph for this function:

Friends And Related Symbol Documentation

Sink

friend class Sink

friend

Definition at line 91 of file Source.h.

Member Data Documentation

sink

Sink* core::pipe::Source::sink = nullptr

private

Definition at line 89 of file Source.h.

Referenced by disconnect(), eof(), error(), pipe(), send(), and ~Source().

---

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

• core/pipe/Source.h
• core/pipe/Source.cpp