1 files changed, 49 insertions, 0 deletions
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_ */