core::file::FileReader Class Reference

#include <FileReader.h>

Inheritance diagram for core::file::FileReader:

Collaboration diagram for core::file::FileReader:

Public Member Functions
bool	isOpen () override
void	start () final
void	suspend () final
void	resume () final
void	stop () final
Public Member Functions inherited from core::pipe::Source
	Source ()=default
	Source (Source &)=delete
	Source (Source &&) noexcept=default
Source &	operator= (Source &)=delete
Source &	operator= (Source &&) noexcept=default
virtual	~Source ()
bool	pipe (Sink *sink)
bool	pipe (const std::shared_ptr< Sink > &sink)
Public Member Functions inherited from core::file::File
	File ()
	~File () override
Public Member Functions inherited from core::Descriptor
	Descriptor ()=delete
	Descriptor (const Descriptor &d)=delete
Descriptor &	operator= (int fd)
Descriptor &	operator= (const Descriptor &descriptor)=delete
Descriptor &	operator= (Descriptor &&descriptor) noexcept
int	getFd () const

Static Public Member Functions
static FileReader *	open (const std::string &path, const std::function< void(int)> &callback)

Protected Attributes
int	openErrno = 0
bool	running = false

Private Member Functions
	FileReader (int fd, const std::string &name, std::size_t pufferSize, int openErrno)
void	onEvent (const utils::Timeval &currentTime) override
Private Member Functions inherited from core::EventReceiver
	EventReceiver (const std::string &name)
	EventReceiver (EventReceiver &)=delete
	EventReceiver (EventReceiver &&)=delete
EventReceiver &	operator= (EventReceiver &)=delete
EventReceiver &	operator= (EventReceiver &&)=delete
virtual void	destruct ()
void	span ()
void	relax ()
const std::string &	getName () const
virtual	~EventReceiver ()=default

Private Attributes
std::size_t	pufferSize = 0
bool	suspended = false

Additional Inherited Members
Protected Member Functions inherited from core::pipe::Source
ssize_t	send (const char *chunk, std::size_t chunkLen)
void	eof ()
void	error (int errnum)
Protected Member Functions inherited from core::Descriptor
	Descriptor (int fd)
	Descriptor (Descriptor &&descriptor) noexcept
virtual	~Descriptor ()
Static Private Member Functions inherited from core::EventReceiver
static void	atNextTick (const std::function< void(void)> &callBack)

Detailed Description

Definition at line 59 of file FileReader.h.

Constructor & Destructor Documentation

FileReader()

core::file::FileReader::FileReader ( int fd, const std::string & name, std::size_t pufferSize, int openErrno )

private

Definition at line 59 of file FileReader.cpp.

        : core::Descriptor(fd)
        , EventReceiver(name)
        , pufferSize(pufferSize)
        , openErrno(openErrno) {
    }

References core::Descriptor::Descriptor(), core::EventReceiver::EventReceiver(), openErrno, and pufferSize.

Referenced by open().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

isOpen()

bool core::file::FileReader::isOpen ( )

overridevirtual

Implements core::pipe::Source.

Definition at line 76 of file FileReader.cpp.

                            {
        return getFd() >= 0;
    }

References core::Descriptor::getFd().

Referenced by resume(), start(), stop(), and suspend().

Here is the call graph for this function:

Here is the caller graph for this function:

onEvent()

void core::file::FileReader::onEvent ( const utils::Timeval & currentTime )

overrideprivatevirtual

Implements core::EventReceiver.

Definition at line 80 of file FileReader.cpp.

                                                                             {
        if (running && core::eventLoopState() != core::State::STOPPING) {
            if (!suspended) {
                std::vector<char> puffer(pufferSize);
 
                const ssize_t ret = core::system::read(getFd(), puffer.data(), puffer.capacity());
                if (ret > 0) {
                    if (this->send(puffer.data(), static_cast<std::size_t>(ret)) < 0) {
                        running = false;
 
                        this->error(errno);
                    }
                } else {
                    running = false;
 
                    if (ret == 0) {
                        this->eof();
                    } else {
                        this->error(errno);
                    }
                }
 
                span();
            }
        } else {
            delete this;
        }
    }

References core::pipe::Source::eof(), core::pipe::Source::error(), core::eventLoopState(), core::Descriptor::getFd(), pufferSize, core::system::read(), running, core::pipe::Source::send(), core::EventReceiver::span(), core::STOPPING, and suspended.

Here is the call graph for this function:

open()

FileReader * core::file::FileReader::open ( const std::string & path, const std::function< void(int)> & callback )

static

Definition at line 66 of file FileReader.cpp.

                                                                                              {
        errno = 0;
 
        const int fd = core::system::open(path.c_str(), O_RDONLY);
 
        callback(fd);
 
        return new FileReader(fd, "FileReader: " + path, MF_READSIZE, fd < 0 ? errno : 0);
    }

References FileReader(), MF_READSIZE, and core::system::open().

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

Here is the call graph for this function:

Here is the caller graph for this function:

resume()

void core::file::FileReader::resume ( )

finalvirtual

Implements core::pipe::Source.

Definition at line 122 of file FileReader.cpp.

                            {
        if (running && isOpen()) {
            suspended = false;
            span();
        }
    }

References isOpen(), running, core::EventReceiver::span(), and suspended.

Here is the call graph for this function:

start()

void core::file::FileReader::start ( )

finalvirtual

Implements core::pipe::Source.

Definition at line 109 of file FileReader.cpp.

                           {
        if (!running && isOpen()) {
            running = true;
            span();
        }
    }

References isOpen(), running, and core::EventReceiver::span().

Here is the call graph for this function:

stop()

void core::file::FileReader::stop ( )

finalvirtual

Implements core::pipe::Source.

Definition at line 129 of file FileReader.cpp.

                          {
        if (running && isOpen()) {
            this->eof();
 
            running = false;
            span();
        }
    }

References core::pipe::Source::eof(), isOpen(), running, and core::EventReceiver::span().

Here is the call graph for this function:

suspend()

void core::file::FileReader::suspend ( )

finalvirtual

Implements core::pipe::Source.

Definition at line 116 of file FileReader.cpp.

                             {
        if (running && isOpen()) {
            suspended = true;
        }
    }

References isOpen(), running, and suspended.

Here is the call graph for this function:

Member Data Documentation

openErrno

int core::file::FileReader::openErrno = 0

protected

Definition at line 84 of file FileReader.h.

Referenced by FileReader().

pufferSize

std::size_t core::file::FileReader::pufferSize = 0

private

Definition at line 79 of file FileReader.h.

Referenced by FileReader(), and onEvent().

running

bool core::file::FileReader::running = false

protected

Definition at line 85 of file FileReader.h.

Referenced by onEvent(), resume(), start(), stop(), and suspend().

suspended

bool core::file::FileReader::suspended = false

private

Definition at line 81 of file FileReader.h.

Referenced by onEvent(), resume(), and suspend().

---

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

• core/file/FileReader.h
• core/file/FileReader.cpp