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
|
#include <string.h>
#include "mongoose/mongoose.h"
#include "rgw_mongoose.h"
#define dout_subsys ceph_subsys_rgw
int RGWMongoose::write_data(const char *buf, int len)
{
if (!sent_header) {
header_data.append(buf, len);
return 0;
}
dout(0) << buf << dendl;
return mg_write(conn, buf, len);
}
RGWMongoose::RGWMongoose(mg_connection *_conn) : conn(_conn), sent_header(false) {
}
int RGWMongoose::read_data(char *buf, int len)
{
return mg_read(conn, buf, len);
}
void RGWMongoose::flush()
{
}
void RGWMongoose::init_env(CephContext *cct)
{
env.init(cct);
struct mg_request_info *info = mg_get_request_info(conn);
if (!info)
return;
for (int i = 0; i < info->num_headers; i++) {
struct mg_request_info::mg_header *header = &info->http_headers[i];
if (strcasecmp(header->name, "content-length") == 0) {
env.set("CONTENT_LENGTH", header->value);
continue;
}
int len = strlen(header->name) + 5; /* HTTP_ prepended */
char buf[len + 1];
memcpy(buf, "HTTP_", 5);
const char *src = header->name;
char *dest = &buf[5];
for (; *src; src++, dest++) {
char c = *src;
switch (c) {
case '-':
c = '_';
break;
default:
c = toupper(c);
break;
}
*dest = c;
}
*dest = '\0';
env.set(buf, header->value);
}
env.set("REQUEST_METHOD", info->request_method);
env.set("REQUEST_URI", info->uri);
env.set("QUERY_STRING", info->query_string);
env.set("REMOTE_USER", info->remote_user);
env.set("SCRIPT_URI", info->uri); /* FIXME */
}
int RGWMongoose::send_status(const char *status, const char *status_name)
{
char buf[128];
if (!status_name)
status_name = "";
snprintf(buf, sizeof(buf), "HTTP/1.1 %s %s\n", status, status_name);
bufferlist bl;
bl.append(buf);
bl.append(header_data);
header_data = bl;
return 0;
}
int RGWMongoose::send_100_continue()
{
char buf[] = "HTTP/1.1 100 CONTINUE\r\n\r\n";
return mg_write(conn, buf, sizeof(buf));
}
int RGWMongoose::complete_header()
{
header_data.append("\r\n");
sent_header = true;
return write_data(header_data.c_str(), header_data.length());
}
|
