EntropyEngine::Networking::WebDAV::WebDAVConnection::StreamState

Internal state for streaming GET operations. More…

#include <WebDAVConnection.h>

Public Attributes

	Name
size_t	tail Write index.
int	statusCode HTTP status code (e.g., 200, 404).
size_t	size Bytes currently stored.
size_t	receivedTotal Byte counter for cap enforcement.
bool	parserPaused true if llhttp parser is paused due to backpressure
size_t	maxBodyBytes Hard safety cap across whole message.
std::mutex	m Protects ring buffer state.
bool	headersReady true when HTTP headers parsed
std::unordered_map< std::string, std::string >	headers Response headers (lowercase keys).
size_t	head Read index.
std::string	failureReason Error description if failed.
bool	failed true on parse or network error
bool	done true when response complete
std::condition_variable	cv Signals data available/consumed.
std::string	curHeaderValue Temp accumulator for header value.
std::string	curHeaderField Temp accumulator for header field.
size_t	capacity Total capacity (buf.size()).
std::vector< uint8_t >	buf Ring buffer storage.

struct EntropyEngine::Networking::WebDAV::WebDAVConnection::StreamState;

Internal state for streaming GET operations.

Ring buffer state shared between HTTP parser (producer) and WebDAVReadStream (consumer). Protected by mutex with condition variable.

size_t tail = 0;

Write index.

int statusCode = 0;

HTTP status code (e.g., 200, 404).

size_t size = 0;

Bytes currently stored.

size_t receivedTotal = 0;

Byte counter for cap enforcement.

bool parserPaused = false;

true if llhttp parser is paused due to backpressure

size_t maxBodyBytes = 0;

Hard safety cap across whole message.

std::mutex m;

Protects ring buffer state.

bool headersReady = false;

true when HTTP headers parsed

std::unordered_map< std::string, std::string > headers;

Response headers (lowercase keys).

size_t head = 0;

Read index.

std::string failureReason;

Error description if failed.

bool failed = false;

true on parse or network error

bool done = false;

true when response complete

std::condition_variable cv;

Signals data available/consumed.

std::string curHeaderValue;

Temp accumulator for header value.

std::string curHeaderField;

Temp accumulator for header field.

size_t capacity = 0;

Total capacity (buf.size()).

std::vector< uint8_t > buf;

Ring buffer storage.

Updated on 2026-01-26 at 17:14:35 -0500