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
|
/*
* Copyright (C) Igor Sysoev
* Copyright (C) NGINX, Inc.
*/
#include <nxt_router.h>
#include <nxt_http.h>
static void nxt_http_request_send_error_body(nxt_task_t *task, void *r,
void *data);
static const nxt_http_request_state_t nxt_http_request_send_state;
static const char error[] =
"<html><head><title>Error</title><head>"
"<body>Error.</body></html>\r\n";
void
nxt_http_request_error(nxt_task_t *task, nxt_http_request_t *r,
nxt_http_status_t status)
{
nxt_http_field_t *content_type;
nxt_debug(task, "http request error: %d", status);
if (r->header_sent) {
goto fail;
}
r->status = status;
r->resp.fields = nxt_list_create(r->mem_pool, 8, sizeof(nxt_http_field_t));
if (nxt_slow_path(r == NULL)) {
goto fail;
}
content_type = nxt_list_zero_add(r->resp.fields);
if (nxt_slow_path(content_type == NULL)) {
goto fail;
}
nxt_http_field_set(content_type, "Content-Type", "text/html");
r->resp.content_length = NULL;
r->resp.content_length_n = sizeof(error) - 1;
r->state = &nxt_http_request_send_state;
nxt_http_request_header_send(task, r);
return;
fail:
nxt_http_request_release(task, r);
}
static const nxt_http_request_state_t nxt_http_request_send_state
nxt_aligned(64) =
{
.ready_handler = nxt_http_request_send_error_body,
.error_handler = nxt_http_request_close_handler,
};
static void
nxt_http_request_send_error_body(nxt_task_t *task, void *obj, void *data)
{
nxt_buf_t *out, *last;
nxt_http_request_t *r;
r = obj;
nxt_debug(task, "http request send error body");
out = nxt_buf_mem_alloc(r->mem_pool, 0, 0);
if (nxt_slow_path(out == NULL)) {
goto fail;
}
out->mem.start = (u_char *) error;
out->mem.pos = out->mem.start;
out->mem.free = out->mem.start + sizeof(error) - 1;
out->mem.end = out->mem.free;
last = nxt_http_request_last_buffer(task, r);
if (nxt_slow_path(last == NULL)) {
goto fail;
}
out->next = last;
nxt_http_request_send(task, r, out);
return;
fail:
// TODO
nxt_http_request_release(task, r);
}
|
