db/dec/ws__async__internal_8h_source.html

#ifndef __CWIST_WS_ASYNC_INTERNAL_H__

#define __CWIST_WS_ASYNC_INTERNAL_H__


#include <cwist/net/websocket/websocket_async.h>

#include <cwist/sys/io/reactor.h>

#include <stdbool.h>

#include <stddef.h>

#include <stdint.h>


bool cwist_websocket_async_attach(int fd, cwist_reactor_t *reactor,

                                  cwist_ws_on_message_t on_message, void *user_data,

                                  const uint8_t *initial, size_t initial_len);


cwist_websocket_async *cwist_websocket_async_attach_ex(int fd, cwist_reactor_t *reactor,

                                                       cwist_ws_on_message_t on_message,

                                                       cwist_ws_on_close_t on_close,

                                                       void *user_data, const uint8_t *initial,

                                                       size_t initial_len);


void cwist_websocket_async_close_code(cwist_websocket_async *ws, uint16_t code);


#endif

cap
size_t cap
Definition otel.c:56

reactor.h

cwist_reactor_t
struct cwist_reactor cwist_reactor_t
Definition reactor.h:14

websocket_async.h
Reactor-driven, callback-shaped non-blocking WebSocket API (C1M mode).

cwist_websocket_async
struct cwist_websocket_async cwist_websocket_async
Definition websocket_async.h:22

cwist_ws_on_message_t
void(* cwist_ws_on_message_t)(cwist_websocket_async *ws, cwist_ws_frame *frame, void *user_data)
Callback invoked for each complete WebSocket message on the C1M path.
Definition websocket_async.h:32

cwist_ws_on_close_t
void(* cwist_ws_on_close_t)(cwist_websocket_async *ws, void *user_data)
Optional teardown hook for the callback-shaped WS path (see cwist_websocket_async_attach_ex in ws_asy...
Definition websocket_async.h:41

cwist_websocket_async_close_code
void cwist_websocket_async_close_code(cwist_websocket_async *ws, uint16_t code)
Initiate the WebSocket close handshake with a CLOSE frame carrying a status code.
Definition websocket_async.c:754

cwist_websocket_async_attach_ex
cwist_websocket_async * cwist_websocket_async_attach_ex(int fd, cwist_reactor_t *reactor, cwist_ws_on_message_t on_message, cwist_ws_on_close_t on_close, void *user_data, const uint8_t *initial, size_t initial_len)
Attach variant that reports the connection handle and teardown.
Definition websocket_async.c:1116

cwist_websocket_async_attach
bool cwist_websocket_async_attach(int fd, cwist_reactor_t *reactor, cwist_ws_on_message_t on_message, void *user_data, const uint8_t *initial, size_t initial_len)
Take ownership of a connected, upgraded fd and drive it reactively.
Definition websocket_async.c:1211