mirror of
https://github.com/faye/websocket-driver-ruby.git
synced 2025-11-01 13:59:38 +00:00
James Coglan
39 lines
1.4 KiB
C
39 lines
1.4 KiB
C
#ifndef _wsd_parser_h
|
|
#define _wsd_parser_h
|
|
|
|
#include <inttypes.h>
|
|
#include <stdio.h>
|
|
#include "constants.h"
|
|
#include "extensions.h"
|
|
#include "message.h"
|
|
#include "observer.h"
|
|
#include "stream_reader.h"
|
|
#include "util.h"
|
|
|
|
typedef struct wsd_Parser wsd_Parser;
|
|
|
|
wsd_Parser * wsd_Parser_create(wsd_Extensions *extensions, wsd_Observer *observer, int require_masking);
|
|
void wsd_Parser_destroy(wsd_Parser *parser);
|
|
int wsd_Parser_parse(wsd_Parser *parser, size_t length, uint8_t *data);
|
|
void wsd_Parser_parse_head(wsd_Parser *parser, wsd_Chunk *chunk);
|
|
int wsd_Parser_valid_opcode(int opcode);
|
|
int wsd_Parser_control_opcode(int opcode);
|
|
int wsd_Parser_message_opcode(int opcode);
|
|
int wsd_Parser_opening_opcode(int opcode);
|
|
void wsd_Parser_parse_extended_length(wsd_Parser *parser, wsd_Chunk *chunk);
|
|
int wsd_Parser_check_frame_length(wsd_Parser *parser);
|
|
size_t wsd_Parser_parse_payload(wsd_Parser *parser);
|
|
void wsd_Parser_emit_frame(wsd_Parser *parser);
|
|
int wsd_Parser_valid_close_code(int code);
|
|
void wsd_Parser_emit_message(wsd_Parser *parser);
|
|
|
|
#define WSD_PARSER_ERROR(P, C, M, ...) \
|
|
if (P->error_code == 0) { \
|
|
P->stage = 0; \
|
|
P->error_code = C; \
|
|
asprintf(&P->error_reason, M, ##__VA_ARGS__); \
|
|
wsd_Observer_on_error(P->observer, P->error_code, P->error_reason); \
|
|
}
|
|
|
|
#endif
|