diff options
Diffstat (limited to 'ext/unicorn/http11/http11_parser.rl')
-rw-r--r-- | ext/unicorn/http11/http11_parser.rl | 134 |
1 files changed, 69 insertions, 65 deletions
diff --git a/ext/unicorn/http11/http11_parser.rl b/ext/unicorn/http11/http11_parser.rl index 1fad2ca..9894276 100644 --- a/ext/unicorn/http11/http11_parser.rl +++ b/ext/unicorn/http11/http11_parser.rl @@ -2,12 +2,37 @@ * Copyright (c) 2005 Zed A. Shaw * You can redistribute it and/or modify it under the same terms as Ruby. */ -#include "http11_parser.h" -#include <stdio.h> -#include <assert.h> -#include <stdlib.h> -#include <ctype.h> -#include <string.h> +#ifndef http11_parser_h +#define http11_parser_h + +#include <sys/types.h> + +static void http_field(void *data, const char *field, + size_t flen, const char *value, size_t vlen); +static void request_method(void *data, const char *at, size_t length); +static void scheme(void *data, const char *at, size_t length); +static void host(void *data, const char *at, size_t length); +static void request_uri(void *data, const char *at, size_t length); +static void fragment(void *data, const char *at, size_t length); +static void request_path(void *data, const char *at, size_t length); +static void query_string(void *data, const char *at, size_t length); +static void http_version(void *data, const char *at, size_t length); +static void header_done(void *data, const char *at, size_t length); + +typedef struct http_parser { + int cs; + size_t body_start; + size_t nread; + size_t mark; + size_t field_start; + size_t field_len; + size_t query_start; + + void *data; +} http_parser; + +static int http_parser_has_error(http_parser *parser); +static int http_parser_is_finished(http_parser *parser); /* * capitalizes all lower-case ASCII characters, @@ -15,10 +40,16 @@ */ static void snake_upcase_char(char *c) { - if (*c >= 'a' && *c <= 'z') - *c &= ~0x20; - else if (*c == '-') - *c = '_'; + if (*c >= 'a' && *c <= 'z') + *c &= ~0x20; + else if (*c == '-') + *c = '_'; +} + +static void downcase_char(char *c) +{ + if (*c >= 'A' && *c <= 'Z') + *c |= 0x20; } #define LEN(AT, FPC) (FPC - buffer - parser->AT) @@ -28,84 +59,69 @@ static void snake_upcase_char(char *c) /** Machine **/ %%{ - machine http_parser; action mark {MARK(mark, fpc); } - action start_field { MARK(field_start, fpc); } action snake_upcase_field { snake_upcase_char((char *)fpc); } - action write_field { + action downcase_char { downcase_char((char *)fpc); } + action write_field { parser->field_len = LEN(field_start, fpc); } action start_value { MARK(mark, fpc); } - action write_value { - if(parser->http_field != NULL) { - parser->http_field(parser->data, PTR_TO(field_start), parser->field_len, PTR_TO(mark), LEN(mark, fpc)); - } + action write_value { + http_field(parser->data, PTR_TO(field_start), parser->field_len, PTR_TO(mark), LEN(mark, fpc)); } - action request_method { - if(parser->request_method != NULL) - parser->request_method(parser->data, PTR_TO(mark), LEN(mark, fpc)); + action request_method { + request_method(parser->data, PTR_TO(mark), LEN(mark, fpc)); } - action request_uri { - if(parser->request_uri != NULL) - parser->request_uri(parser->data, PTR_TO(mark), LEN(mark, fpc)); + action scheme { scheme(parser->data, PTR_TO(mark), LEN(mark, fpc)); } + action host { host(parser->data, PTR_TO(mark), LEN(mark, fpc)); } + action request_uri { + request_uri(parser->data, PTR_TO(mark), LEN(mark, fpc)); } - action fragment { - if(parser->fragment != NULL) - parser->fragment(parser->data, PTR_TO(mark), LEN(mark, fpc)); + action fragment { + fragment(parser->data, PTR_TO(mark), LEN(mark, fpc)); } action start_query {MARK(query_start, fpc); } - action query_string { - if(parser->query_string != NULL) - parser->query_string(parser->data, PTR_TO(query_start), LEN(query_start, fpc)); + action query_string { + query_string(parser->data, PTR_TO(query_start), LEN(query_start, fpc)); } - action http_version { - if(parser->http_version != NULL) - parser->http_version(parser->data, PTR_TO(mark), LEN(mark, fpc)); + action http_version { + http_version(parser->data, PTR_TO(mark), LEN(mark, fpc)); } action request_path { - if(parser->request_path != NULL) - parser->request_path(parser->data, PTR_TO(mark), LEN(mark,fpc)); + request_path(parser->data, PTR_TO(mark), LEN(mark,fpc)); } - action done { - parser->body_start = fpc - buffer + 1; - if(parser->header_done != NULL) - parser->header_done(parser->data, fpc + 1, pe - fpc - 1); + action done { + parser->body_start = fpc - buffer + 1; + header_done(parser->data, fpc + 1, pe - fpc - 1); fbreak; } include http_parser_common "http11_parser_common.rl"; - }%% /** Data **/ %% write data; -int http_parser_init(http_parser *parser) { +static void http_parser_init(http_parser *parser) { int cs = 0; + memset(parser, 0, sizeof(*parser)); %% write init; parser->cs = cs; - parser->body_start = 0; - parser->content_len = 0; - parser->mark = 0; - parser->nread = 0; - parser->field_len = 0; - parser->field_start = 0; - - return(1); } - /** exec **/ -size_t http_parser_execute(http_parser *parser, const char *buffer, size_t len) { +static void http_parser_execute( + http_parser *parser, const char *buffer, size_t len) +{ const char *p, *pe; int cs = parser->cs; size_t off = parser->nread; @@ -130,25 +146,13 @@ size_t http_parser_execute(http_parser *parser, const char *buffer, size_t len) assert(parser->mark < len && "mark is after buffer end"); assert(parser->field_len <= len && "field has length longer than whole buffer"); assert(parser->field_start < len && "field starts after buffer end"); - - return(parser->nread); -} - -int http_parser_finish(http_parser *parser) -{ - if (http_parser_has_error(parser) ) { - return -1; - } else if (http_parser_is_finished(parser) ) { - return 1; - } else { - return 0; - } } -int http_parser_has_error(http_parser *parser) { +static int http_parser_has_error(http_parser *parser) { return parser->cs == http_parser_error; } -int http_parser_is_finished(http_parser *parser) { +static int http_parser_is_finished(http_parser *parser) { return parser->cs == http_parser_first_final; } +#endif /* http11_parser_h */ |