edge_fetch.h File Reference

CDN edge-cache tier - async origin-fetch engine (PROTOCORE_ENABLE_EDGE_CACHE). More...

#include "protocore_config.h"

Go to the source code of this file.

Classes
struct	EdgeFetchTransport
	The origin transport, bound to protocore_client on the device and a mock in host tests. More...
struct	EdgeFetch
	One in-flight origin fetch (fixed-size, zero-heap). More...
struct	EdgeFetchNs
	Dispatch table. Addressed by offset, so the layout is asserted below. More...

Typedefs
typedef struct EdgeFetchTransport	EdgeFetchTransport
	The origin transport, bound to protocore_client on the device and a mock in host tests.
typedef enum PROTO_ENUM_PACKED	EdgeFetchStatus
	Fetch progress.

Enumerations
enum	PROTO_ENUM_PACKED { EDGE_FETCH_STATUS_PENDING , EDGE_FETCH_STATUS_DONE , EDGE_FETCH_STATUS_OVERSIZE , EDGE_FETCH_STATUS_FAILED }
	Fetch progress. More...

Functions
	PROTOCORE_NS_LAYOUT (EdgeFetchNs, begin, pump, end, edge_resp_complete)
void	protocore_edge_fetcher_begin (uint8_t *work, EdgeFetch *f, const EdgeFetchTransport *t, const char *host, uint16_t port, const void *request, size_t req_len, uint32_t now_ms)
	Open the origin connection and park request; begin the fetch. Sets .
EdgeFetchStatus	protocore_edge_fetcher_pump (uint8_t *work, EdgeFetch *f, const EdgeFetchTransport *t, uint32_t now_ms)
	Drain available bytes and advance. On DONE the response is parsed .
void	protocore_edge_fetcher_end (uint8_t *work, EdgeFetch *f, const EdgeFetchTransport *t)
	Release the transport connection (idempotent).
proto_bool	protocore_edge_fetcher_edge_resp_complete (uint8_t *work, const uint8_t *buf, size_t len, proto_bool conn_closed, size_t *head_len)
	Is the accumulated response complete? (headers terminated + body .

Variables
PROTOCORE_NS EdgeFetchNs EdgeFetcher	PROTOCORE_UNUSED
	Module namespace.

Detailed Description

CDN edge-cache tier - async origin-fetch engine (PROTOCORE_ENABLE_EDGE_CACHE).

A non-blocking origin fetch: open + send a request over a transport seam, accumulate the response across poll loops into a bounded buffer, detect completion (Content-Length / chunked / connection close), then parse it with the proven http_client codec. Pumped from the server poll loop so a miss or revalidation never stalls the worker; the transport seam is protocore_client on the device and a mock in host tests. Zero heap; the buffer is fixed (PROTOCORE_EDGE_FETCH_BUF).

work is bytes the CALLER holds. This module reads none of them: it carries nothing between calls, so there is no state to keep and nothing to wipe. The parameter is there so a caller drives every namespace the same way.

Author

Douglas Quigg (dstroy0)

Date

2026

Definition in file edge_fetch.h.

Typedef Documentation

EdgeFetchTransport

typedef struct EdgeFetchTransport EdgeFetchTransport

The origin transport, bound to protocore_client on the device and a mock in host tests.

EdgeFetchStatus

typedef enum PROTO_ENUM_PACKED EdgeFetchStatus

Fetch progress.

Enumeration Type Documentation

PROTO_ENUM_PACKED

enum PROTO_ENUM_PACKED

Fetch progress.

Enumerator
EDGE_FETCH_STATUS_PENDING	still receiving
EDGE_FETCH_STATUS_DONE	a complete response is parsed (status / body_off / body_len valid)
EDGE_FETCH_STATUS_OVERSIZE	response exceeded the buffer - not cacheable (caller passes through / fails open)
EDGE_FETCH_STATUS_FAILED	connect / send / timeout / closed-before-complete

Definition at line 46 of file edge_fetch.h.

Function Documentation

PROTOCORE_NS_LAYOUT()

PROTOCORE_NS_LAYOUT	(	EdgeFetchNs	,
		begin	,
		pump	,
		end	,
		edge_resp_complete
	)

protocore_edge_fetcher_begin()

void protocore_edge_fetcher_begin	(	uint8_t *	work,
		EdgeFetch *	f,
		const EdgeFetchTransport *	t,
		const char *	host,
		uint16_t	port,
		const void *	request,
		size_t	req_len,
		uint32_t	now_ms
	)

Open the origin connection and park request; begin the fetch. Sets .

Parameters

work	PROTOCORE_EDGE_FETCHER_BORROW bytes the caller took. Not held past the call.
f	F
t	T
host	Host
port	Port
request	Request
req_len	Req len
now_ms	Now ms

protocore_edge_fetcher_pump()

EdgeFetchStatus protocore_edge_fetcher_pump	(	uint8_t *	work,
		EdgeFetch *	f,
		const EdgeFetchTransport *	t,
		uint32_t	now_ms
	)

Drain available bytes and advance. On DONE the response is parsed .

Parameters

work	PROTOCORE_EDGE_FETCHER_BORROW bytes the caller took. Not held past the call.
f	F
t	T
now_ms	Now ms

Returns

The EdgeFetchStatus.

protocore_edge_fetcher_end()

void protocore_edge_fetcher_end	(	uint8_t *	work,
		EdgeFetch *	f,
		const EdgeFetchTransport *	t
	)

Release the transport connection (idempotent).

Parameters

work	PROTOCORE_EDGE_FETCHER_BORROW bytes the caller took. Not held past the call.
f	F
t	T

protocore_edge_fetcher_edge_resp_complete()

proto_bool protocore_edge_fetcher_edge_resp_complete	(	uint8_t *	work,
		const uint8_t *	buf,
		size_t	len,
		proto_bool	conn_closed,
		size_t *	head_len
	)

Is the accumulated response complete? (headers terminated + body .

Parameters

work	PROTOCORE_EDGE_FETCHER_BORROW bytes the caller took. Not held past the call.
buf	Buf
len	Len
conn_closed	Conn closed
head_len	Head len

Returns

PROTO_TRUE on success.

Variable Documentation

PROTOCORE_UNUSED

PROTOCORE_NS EdgeFetchNs EdgeFetcher PROTOCORE_UNUSED

Initial value:

= {.begin = protocore_edge_fetcher_begin,
                                                         .pump = protocore_edge_fetcher_pump,
                                                         .end = protocore_edge_fetcher_end,
                                                         .edge_resp_complete =
                                                             protocore_edge_fetcher_edge_resp_complete}

Module namespace.

Definition at line 123 of file edge_fetch.h.