You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
125 lines
2.8 KiB
125 lines
2.8 KiB
|
|
#include "http11_response.h"
|
|
#include <stdio.h>
|
|
#include <assert.h>
|
|
#include <stdlib.h>
|
|
#include <ctype.h>
|
|
#include <string.h>
|
|
|
|
|
|
#define LEN(AT, FPC) (FPC - buffer - parser->AT)
|
|
#define MARK(M,FPC) (parser->M = (FPC) - buffer)
|
|
#define PTR_TO(F) (buffer + parser->F)
|
|
|
|
/** Machine **/
|
|
|
|
%%{
|
|
|
|
machine http_parser;
|
|
|
|
action mark {MARK(mark, fpc); }
|
|
|
|
action start_field { MARK(field_start, 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 http_version {
|
|
if(parser->http_version != NULL)
|
|
parser->http_version(parser->data, PTR_TO(mark), LEN(mark, fpc));
|
|
}
|
|
|
|
action status_code {
|
|
if(parser->status_code != NULL)
|
|
parser->status_code(parser->data, PTR_TO(mark), LEN(mark,fpc));
|
|
}
|
|
|
|
action reason_phrase {
|
|
if(parser->reason_phrase != NULL)
|
|
parser->reason_phrase(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);
|
|
fbreak;
|
|
}
|
|
|
|
include http_response_common "http11_response_common.rl";
|
|
|
|
}%%
|
|
|
|
/** Data **/
|
|
%% write data;
|
|
|
|
int http_parser_init(http_parser *parser) {
|
|
int cs = 0;
|
|
%% 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, size_t off) {
|
|
const char *p, *pe;
|
|
int cs = parser->cs;
|
|
|
|
assert(off <= len && "offset past end of buffer");
|
|
|
|
p = buffer+off;
|
|
pe = buffer+len;
|
|
|
|
assert(pe - p == len - off && "pointers aren't same distance");
|
|
|
|
%% write exec;
|
|
|
|
if (!http_parser_has_error(parser))
|
|
parser->cs = cs;
|
|
parser->nread += p - (buffer + off);
|
|
|
|
assert(p <= pe && "buffer overflow after parsing execute");
|
|
assert(parser->nread <= len && "nread longer than length");
|
|
assert(parser->body_start <= len && "body starts after buffer end");
|
|
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) {
|
|
return parser->cs == http_parser_error;
|
|
}
|
|
|
|
int http_parser_is_finished(http_parser *parser) {
|
|
return parser->cs >= http_parser_first_final;
|
|
}
|