web::http::decoder::Chunked::Chunk Class Reference

Collaboration diagram for web::http::decoder::Chunked::Chunk:

Public Member Functions
	Chunk ()=default
	Chunk (const Chunk &)=delete
	Chunk (Chunk &&) noexcept=default
Chunk &	operator= (const Chunk &)=delete
Chunk &	operator= (Chunk &&) noexcept=default
	~Chunk ()
std::size_t	read (const core::socket::stream::SocketContext *socketContext)
bool	isError () const
bool	isComplete () const
std::vector< char >::iterator	begin ()
std::vector< char >::iterator	end ()
std::size_t	size ()

Private Attributes
std::vector< char >	chunk
std::string	chunkLenTotalS
std::size_t	chunkLenTotal = 0
std::size_t	chunkLenRead = 0
int	state = 0
bool	CR = false
bool	LF = false
bool	error = false
bool	completed = false

Detailed Description

Definition at line 41 of file Chunked.h.

Constructor & Destructor Documentation

Chunk() [1/3]

web::http::decoder::Chunked::Chunk::Chunk ( )

default

Chunk() [2/3]

web::http::decoder::Chunked::Chunk::Chunk ( const Chunk & )

delete

Chunk() [3/3]

web::http::decoder::Chunked::Chunk::Chunk ( Chunk && )

defaultnoexcept

~Chunk()

web::http::decoder::Chunked::Chunk::~Chunk

(

)

Definition at line 71 of file Chunked.cpp.

                         {
    }

Member Function Documentation

begin()

std::vector< char >::iterator web::http::decoder::Chunked::Chunk::begin

(

)

Definition at line 193 of file Chunked.cpp.

                                                {
        return chunk.begin();
    }

end()

std::vector< char >::iterator web::http::decoder::Chunked::Chunk::end

(

)

Definition at line 197 of file Chunked.cpp.

                                              {
        return chunk.end();
    }

isComplete()

bool web::http::decoder::Chunked::Chunk::isComplete ( ) const

inline

Definition at line 189 of file Chunked.cpp.

                                               {
        return completed;
    }

References completed.

isError()

bool web::http::decoder::Chunked::Chunk::isError ( ) const

inline

Definition at line 185 of file Chunked.cpp.

                                            {
        return error;
    }

References error.

operator=() [1/2]

Chunk & web::http::decoder::Chunked::Chunk::operator= ( Chunk && )

defaultnoexcept

operator=() [2/2]

Chunk & web::http::decoder::Chunked::Chunk::operator= ( const Chunk & )

delete

read()

std::size_t web::http::decoder::Chunked::Chunk::read ( const core::socket::stream::SocketContext * socketContext )

inline

Definition at line 74 of file Chunked.cpp.

                                                                                          {
        std::size_t consumed = 0;
        std::size_t ret = 0;
        std::size_t pos = 0;
 
        const static int maxChunkLenTotalS = sizeof(std::size_t) * 2;
 
        switch (state) {
            case -1: // Re-init
                CR = false;
                LF = false;
                chunkLenTotalS.clear();
                chunkLenTotal = 0;
                chunkLenRead = 0;
 
                completed = false;
                error = false;
 
                state = 0;
 
                [[fallthrough]];
            case 0: // ChunklLenS
                do {
                    char ch = '\0';
 
                    ret = socketContext->readFromPeer(&ch, 1);
                    if (ret > 0) {
                        consumed++;
 
                        if (CR) {
                            if (ch == '\n') {
                                LF = true;
                            } else {
                                error = true;
                            }
                        } else if (ch == '\r') {
                            CR = true;
                        } else {
                            chunkLenTotalS += ch;
                        }
                    }
                } while (!error && ret > 0 && !(CR && LF) && chunkLenTotalS.size() <= maxChunkLenTotalS);
 
                if (!(CR && LF)) {
                    error = !error ? chunkLenTotalS.size() > maxChunkLenTotalS : error;
 
                    if (error) {
                        state = -1;
                    }
 
                    break;
                }
 
                CR = false;
                LF = false;
 
                try {
                    chunkLenTotal = std::stoul(chunkLenTotalS, &pos, 16);
                    chunk.resize(chunkLenTotal);
 
                    state = 1;
                } catch (std::invalid_argument&) {
                    error = true;
                    break;
                }
 
                [[fallthrough]];
            case 1: // ChunkData
                do {
                    ret = socketContext->readFromPeer(chunk.data() + chunkLenRead, chunkLenTotal - chunkLenRead);
                    chunkLenRead += ret;
                    consumed += ret;
                } while (ret > 0 && (chunkLenTotal != chunkLenRead));
 
                if (chunkLenTotal != chunkLenRead) {
                    break;
                }
 
                state = 2;
 
                [[fallthrough]];
            case 2: // Closing "\r\n"
                char ch = '\0';
 
                ret = socketContext->readFromPeer(&ch, 1);
                consumed += ret;
 
                if (ret > 0) {
                    if (CR || ch == '\r') {
                        if (CR && ch == '\n') {
                            LF = true;
                            completed = true;
                            state = -1;
                        } else if (CR) {
                            error = true;
                            state = -1;
                        } else {
                            CR = true;
                        }
                    } else {
                        error = true;
                        state = -1;
                    }
                }
 
                break;
        }
 
        return consumed;
    }

References chunkLenRead, chunkLenTotal, chunkLenTotalS, completed, CR, error, LF, core::socket::stream::SocketContext::readFromPeer(), and state.

Here is the call graph for this function:

size()

std::size_t web::http::decoder::Chunked::Chunk::size

(

)

Definition at line 201 of file Chunked.cpp.

                                 {
        return chunk.size();
    }

Member Data Documentation

chunk

std::vector<char> web::http::decoder::Chunked::Chunk::chunk

private

Definition at line 64 of file Chunked.h.

chunkLenRead

std::size_t web::http::decoder::Chunked::Chunk::chunkLenRead = 0

private

Definition at line 68 of file Chunked.h.

Referenced by read().

chunkLenTotal

std::size_t web::http::decoder::Chunked::Chunk::chunkLenTotal = 0

private

Definition at line 67 of file Chunked.h.

Referenced by read().

chunkLenTotalS

std::string web::http::decoder::Chunked::Chunk::chunkLenTotalS

private

Definition at line 66 of file Chunked.h.

Referenced by read().

completed

bool web::http::decoder::Chunked::Chunk::completed = false

private

Definition at line 76 of file Chunked.h.

Referenced by isComplete(), and read().

CR

bool web::http::decoder::Chunked::Chunk::CR = false

private

Definition at line 72 of file Chunked.h.

Referenced by read().

error

bool web::http::decoder::Chunked::Chunk::error = false

private

Definition at line 75 of file Chunked.h.

Referenced by isError(), and read().

LF

bool web::http::decoder::Chunked::Chunk::LF = false

private

Definition at line 73 of file Chunked.h.

Referenced by read().

state

int web::http::decoder::Chunked::Chunk::state = 0

private

Definition at line 70 of file Chunked.h.

Referenced by read().

---

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

• web/http/decoder/Chunked.h
• web/http/decoder/Chunked.cpp