EntropyEngine::Networking::HTTP::StreamState

Streaming response state for incremental reads. More…

#include <HttpClient.h>

Public Attributes

	Name
size_t	totalReceived Total bytes received.
size_t	tail Write index.
int	statusCode HTTP status code.
size_t	size Bytes currently stored.
bool	resumeRequested consumer requested resume (handled on worker thread)
bool	paused true if write callback paused due to backpressure
std::mutex	mutex Protects ring buffer state.
size_t	maxBodyBytes Hard safety cap.
bool	headersReady true when HTTP headers parsed
HttpHeaderValuesMap	headersMulti All values per header key.
HttpHeaders	headers Response headers (lowercase, last-seen).
size_t	head Read index.
std::string	failureReason Error description.
bool	failed true on error
CURL *	easy cURL easy handle for this stream (set by worker thread)
bool	done true when response complete
std::condition_variable	cv Signals data available/consumed.
size_t	capacity Total capacity.
bool	cancelRequested Cancellation requested by consumer.
std::vector< uint8_t >	buffer Ring buffer storage.

Detailed Description

struct EntropyEngine::Networking::HTTP::StreamState;

Streaming response state for incremental reads.

Ring buffer with producer/consumer pattern. HTTP parser writes to tail, StreamHandle reads from head. Backpressure via CURL_WRITEFUNC_PAUSE.

Public Attributes Documentation

variable totalReceived

size_t totalReceived = 0;

Total bytes received.

variable tail

size_t tail = 0;

Write index.

variable statusCode

int statusCode = 0;

HTTP status code.

variable size

size_t size = 0;

Bytes currently stored.

variable resumeRequested

bool resumeRequested = false;

consumer requested resume (handled on worker thread)

variable paused

bool paused = false;

true if write callback paused due to backpressure

variable mutex

std::mutex mutex;

Protects ring buffer state.

variable maxBodyBytes

size_t maxBodyBytes = 0;

Hard safety cap.

variable headersReady

bool headersReady = false;

true when HTTP headers parsed

variable headersMulti

HttpHeaderValuesMap headersMulti;

All values per header key.

variable headers

HttpHeaders headers;

Response headers (lowercase, last-seen).

variable head

size_t head = 0;

Read index.

variable failureReason

std::string failureReason;

Error description.

variable failed

bool failed = false;

true on error

variable easy

CURL * easy = nullptr;

cURL easy handle for this stream (set by worker thread)

variable done

bool done = false;

true when response complete

variable cv

std::condition_variable cv;

Signals data available/consumed.

variable capacity

size_t capacity = 0;

Total capacity.

variable cancelRequested

bool cancelRequested = false;

Cancellation requested by consumer.

variable buffer

std::vector< uint8_t > buffer;

Ring buffer storage.

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