src/nxt_http_source.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
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_ */