File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -64,12 +64,16 @@ int websocket_frame_header(websocket_parser * parser) {
6464int ion_websocket_frame_body(websocket_parser * parser, const char * at, size_t size) {
6565 if(parser->flags & WS_HAS_MASK) {
6666 // if frame has mask, we have to copy and decode data via websocket_parser_copy_masked function
67- websocket_parser_copy_masked(&parser->data[ parser->offset] , at, size, parser);
67+ websocket_parser_copy_masked(&parser->data->body [ parser->offset] , at, size, parser);
6868 } else {
69- memcpy(&parser->data[ parser->offset] , at, size);
69+ memcpy(&parser->data->body [ parser->offset] , at, size);
7070 }
7171 return 0;
7272}
73+
74+ int websocket_frame_end(websocket_parser * parser) {
75+ my_app_push_frame(parser->data); // use parsed frame
76+ }
7377```
7478
7579When data is received execute the parser and check for errors.
@@ -81,4 +85,4 @@ if(parser->error) {
8185}
8286// ...
8387free(parser);
84- ```
88+ ```
You can’t perform that action at this time.
0 commit comments