From 16cbf3c076a0aca6d47adaf3f719493674cf2363 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Tue, 17 Jan 2017 20:00:00 +0300 Subject: Initial version. --- src/nxt_http_source.h | 49 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 49 insertions(+) create mode 100644 src/nxt_http_source.h (limited to 'src/nxt_http_source.h') diff --git a/src/nxt_http_source.h b/src/nxt_http_source.h new file mode 100644 index 00000000..53924a4f --- /dev/null +++ b/src/nxt_http_source.h @@ -0,0 +1,49 @@ + +/* + * Copyright (C) Igor Sysoev + * Copyright (C) NGINX, Inc. + */ + +#ifndef _NXT_HTTP_SOURCE_H_INCLUDED_ +#define _NXT_HTTP_SOURCE_H_INCLUDED_ + + +typedef struct { + nxt_str_t copy; + uintptr_t data[3]; +} nxt_http_source_request_t; + + +typedef struct nxt_http_source_s nxt_http_source_t; +typedef nxt_int_t (*nxt_http_source_request_create_t)(nxt_http_source_t *hs); + + +struct nxt_http_source_s { + nxt_source_hook_t query; + nxt_source_hook_t *next; + + nxt_upstream_source_t *upstream; + + nxt_http_source_request_create_t request_create; + + nxt_upstream_header_in_t header_in; + + nxt_buf_t *rest; + + uint32_t chunked; /* 1 bit */ + + union { + nxt_http_source_request_t request; + nxt_http_status_parse_t status_parse; + nxt_http_split_header_parse_t header; + } u; +}; + + +NXT_EXPORT void nxt_http_source_handler(nxt_upstream_source_t *us, + nxt_http_source_request_create_t request_create); +NXT_EXPORT nxt_int_t nxt_http_source_hash_create(nxt_mem_pool_t *mp, + nxt_lvlhsh_t *lh); + + +#endif /* _NXT_HTTP_SOURCE_H_INCLUDED_ */ -- cgit