* used internally by some of the helpers to find convert a section pointer to * the full builder stack data. */

pushes text and padding instruction to the instruction array */

* used internally to write escaped text rather than clear text. */

* Called when an argument name was detected in the current section. * * A conforming implementation will search for the named argument both in the

* Returns the section's parent for nested sections, or NULL (for root section). * * This allows the `udata` values in the parent to be accessed and

a local static callback, called when the RESP message is complete. */

a local static callback, called when NULL is received. */

a local static callback, called when a parser / protocol error occurs. */

a helper that seeks the EOL, converts it to NUL and returns it's length */

Prints debugging information to the console. */

Rounds up any size to the nearest page alignment (assumes 4096 bytes per * page) */

* Wraps a WebSocket client message and writes it to the target buffer. * * The `first` and `last` flags can be used to support message fragmentation

* Consumes the data in the buffer, calling any callbacks required. * * Returns the remaining data in the existing buffer (can be 0). */

Writes a JSON friendly version of the src String */

@deprecated use {Iodine.on_state}. Sets a block of code to run after a new worker process is forked (cluster mode only). Code runs in both the paren

Adds an ALPN data object to the ALPN "list" (set) */

Adds an ALPN data object to the ALPN "list" (set) */

returned a locked arena. Attempts the preffered arena first. */

reallocates memory using the system, resetting the size header */

intializes the block header for an available block of memory. */

allocates memory from within a block - called within an arena's lock */

* We include this in case the parser is used outside of facil.io. */

* We include this in case the parser is used outside of facil.io. */

consumes any hex data in the string, returning their value */

Creates / finds a pubsub channel, adds a reference count and locks it. */

Finds a pubsub channel, increasing it's reference count if it exists. */

Creates / finds a pattern channel, adds a reference count and locks it. */

Returns the unrecognized argument using a 0 based `index`. */

Returns the number of unrecognized argument. */

Called when a ne client is available */

Returns `a` if `cond` isn't zero (uses fio_ct_true), returns b otherwise. */

* A thread entering this function should wait for new events. */

Creates / finds a filter channel, adds a reference count and locks it. */

Finds a filter channel, increasing it's reference count if it exists. */

`fio_flush_all` attempts flush all the open connections. */

* Returns 1 if the current process is a worker process or a single process. * * Otherwise returns 0. * * NOTE: When cluster mode is off, the root

an array closure was detected */

a dictionary object closure detected */

the JSON parsing is complete */

a FALSE object was detected */

a Float was detected (double). */

the JSON parsing is complete */

a Numberl was detected (long long). */

an array object was detected */

a dictionary object was detected */

a TRUE object was detected */

Tests if the list is empty. */

Removes an object from the list's tail. */

Adds an object to the list's tail. */

frees the internal message data */