data segment serialization, reads data from raw stream. */

cleans up and frees the engine data. */

send command within lock, to ensure flag integrity */

* allocates memory using `mmap`, but enforces block size alignment. * requires page aligned `len`. * * `align_shift` is used to move the memory pag

Closes a websocket connection. */

Returns the opaque user data associated with the websocket. */

Message masking ***************************************************************************** */ used internally to mask and unmask client messages. *

* Schedules a protected connection task. The task will run within the * connection's lock. * * If an error ocuurs or the connection is closed befor

allocates directly from the system adding size header - no lock required. */

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

returns true if there's data to be skipped */

This will decode a Base64 encoded string of a specified length (len) and place the decoded data into the target byte buffer (target). The target buff

Increases a channel's reference count. */

* Performs a single task from the queue, returning -1 if the queue was empty. */

joins a thread pool */

* Returns a C string detailing the IO engine selected during compilation. * * Valid values are "kqueue", "epoll" and "poll". */

public API. */

some comon tasks extracted */

* Returns the number of bytes consumed. Stops as close as possible to the end * of the buffer or once an object parsing was completed. */

Adds a node to the list's tail. */

* Engines can ask facil.io to call the `subscribe` callback for all active * channels. * * This allows engines that lost their connection to their

* Replaces an existing read/write hook with another from within a read/write * hook callback. * * Does NOT call any cleanup callbacks. * * Return

Returns 1 if the String is UTF-8 valid and 0 if not. */

OVERRIDE THIS to replace the default pthread implementation. */

Called when the library specific data for the context should be built */

Called when the library specific data for the context should be built */

* Increase the reference count for the TLS object. * * Decrease with `fio_tls_destroy`. */

public API. */

* Parses the URI returning it's components and their lengths (no decoding * performed, doesn't accept decoded URIs). * * The returned string are NO

* `fio_write` copies `legnth` data from the buffer and schedules the data to * be sent over the socket. * * The data isn't necessarily written to t

Shifts an object from the beginning of the Array. */

* Calculates a String's SipHash value for use as a HashMap key. */

Creates an HTTP1 protocol object and handles any unread data in the buffer * (if any). */

called when a request path (excluding query) is parsed. */

Writes an HTTP date string to the `target` buffer. This requires ~32 bytes of space to be available at the target buffer (unless it's a super funky y

Called when partial data is available. */

* Sends the response headers and the specified file (the response's body). * * Returns -1 eton error and 0 on success. * * AFTER THIS FUNCTION IS

cleans up any resources used by the argument list processing */

Calls a C function within the GVL. */

free the mustache template */

* This helper function should be used to write text to the output * stream (often used within the `mustache_on_arg` callback). */

@deprecated use {Iodine.on_state}. Sets a block of code to run once a Worker process shuts down (both in single process mode and cluster mode).

attach a command to the queue */

releases any resources used by an internal engine*/

a local static callback, called when a String object had finished * streaming. */

* a local static callback, called when a String should be allocated. * * `str_len` is the expected number of bytes that will fill the final string

a local static callback, called as String objects are streamed. */

* This seems to be faster on some systems, especially for smaller distances. * * On newer systems, `memchr` should be faster. */

frees memory using `munmap`. requires exact, page aligned, `len` */

* Returns all known information regarding the upcoming message. * * @returns a struct websocket_packet_info_s. * * On protocol error, the `head_le

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

Writes data to the websocket. Returns -1 on failure (0 on success). */

Returns a pointer to the default (first) ALPN object in the TLS (if any). */

Returns a pointer to the ALPN data (callback, etc') IF exists in the TLS. */

Schedules the ALPN protocol callback. */

reads size header and frees memory back to the system */

handle's a bock's reference count - called without a lock */

A helper function that converts between String data to a signed double. */

consumes any digits in the string (base 2-10), returning their value */

returns true if there's data to be skipped */

managing the protocol pointer array and the `on_close` callback */

* The actual encoding logic. The map can be switched for encoding variations. */

common internal tasks */