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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
|
/*
* Copyright (C) Max Romanov
* Copyright (C) Valentin V. Bartenev
* Copyright (C) NGINX, Inc.
*/
#ifndef _NXT_APPLICATION_H_INCLUDED_
#define _NXT_APPLICATION_H_INCLUDED_
#include <nxt_conf.h>
#include <nxt_unit_typedefs.h>
typedef enum {
NXT_APP_EXTERNAL,
NXT_APP_PYTHON,
NXT_APP_PHP,
NXT_APP_PERL,
NXT_APP_RUBY,
NXT_APP_JAVA,
NXT_APP_UNKNOWN,
} nxt_app_type_t;
typedef struct nxt_app_module_s nxt_app_module_t;
typedef struct {
nxt_app_type_t type;
u_char *version;
char *file;
nxt_app_module_t *module;
} nxt_app_lang_module_t;
typedef struct nxt_common_app_conf_s nxt_common_app_conf_t;
typedef struct {
char *executable;
nxt_conf_value_t *arguments;
} nxt_external_app_conf_t;
typedef struct {
char *home;
nxt_str_t path;
nxt_str_t module;
} nxt_python_app_conf_t;
typedef struct {
char *root;
nxt_str_t script;
nxt_str_t index;
nxt_conf_value_t *options;
} nxt_php_app_conf_t;
typedef struct {
char *script;
} nxt_perl_app_conf_t;
typedef struct {
nxt_str_t script;
} nxt_ruby_app_conf_t;
typedef struct {
nxt_conf_value_t *classpath;
char *webapp;
nxt_conf_value_t *options;
char *unit_jars;
} nxt_java_app_conf_t;
struct nxt_common_app_conf_s {
nxt_str_t name;
nxt_str_t type;
nxt_str_t user;
nxt_str_t group;
char *working_directory;
nxt_conf_value_t *environment;
union {
nxt_external_app_conf_t external;
nxt_python_app_conf_t python;
nxt_php_app_conf_t php;
nxt_perl_app_conf_t perl;
nxt_ruby_app_conf_t ruby;
nxt_java_app_conf_t java;
} u;
};
typedef struct {
nxt_str_t method;
nxt_str_t target;
nxt_str_t version;
nxt_str_t path;
nxt_str_t query;
nxt_str_t server_name;
nxt_list_t *fields;
nxt_str_t cookie;
nxt_str_t content_length;
nxt_str_t content_type;
off_t parsed_content_length;
nxt_bool_t done;
size_t bufs;
nxt_buf_t *buf;
} nxt_app_request_header_t;
typedef struct {
size_t preread_size;
nxt_bool_t done;
nxt_buf_t *buf;
} nxt_app_request_body_t;
typedef struct {
nxt_app_request_header_t header;
nxt_app_request_body_t body;
nxt_str_t remote;
nxt_str_t local;
} nxt_app_request_t;
typedef struct nxt_app_parse_ctx_s nxt_app_parse_ctx_t;
struct nxt_app_parse_ctx_s {
nxt_app_request_t r;
nxt_http_request_t *request;
nxt_timer_t timer;
void *timer_data;
nxt_http_request_parse_t parser;
nxt_http_request_parse_t resp_parser;
nxt_mp_t *mem_pool;
};
nxt_int_t nxt_app_http_req_done(nxt_task_t *task, nxt_app_parse_ctx_t *ctx);
struct nxt_app_module_s {
size_t compat_length;
uint32_t *compat;
nxt_str_t type;
const char *version;
nxt_int_t (*pre_init)(nxt_task_t *task,
nxt_common_app_conf_t *conf);
nxt_int_t (*init)(nxt_task_t *task,
nxt_common_app_conf_t *conf);
};
nxt_app_lang_module_t *nxt_app_lang_module(nxt_runtime_t *rt, nxt_str_t *name);
nxt_app_type_t nxt_app_parse_type(u_char *p, size_t length);
NXT_EXPORT extern nxt_str_t nxt_server;
extern nxt_app_module_t nxt_external_module;
NXT_EXPORT nxt_int_t nxt_unit_default_init(nxt_task_t *task,
nxt_unit_init_t *init);
#endif /* _NXT_APPLICATION_H_INCLIDED_ */
|
