-
Notifications
You must be signed in to change notification settings - Fork 0
/
access_log.c
77 lines (68 loc) · 2.7 KB
/
access_log.c
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
/*
* Copyright (c) 2014 DeNA Co., Ltd.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to
* deal in the Software without restriction, including without limitation the
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
* sell copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
* IN THE SOFTWARE.
*/
#include <fcntl.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include "h2o.h"
struct st_h2o_access_logger_t {
h2o_logger_t super;
int fd;
};
static void log_access(h2o_logger_t *_self, h2o_req_t *req)
{
struct st_h2o_access_logger_t *self = (struct st_h2o_access_logger_t*)_self;
char peername[sizeof("255.255.255.255")];
struct sockaddr sa;
socklen_t sa_len = sizeof(sa);
h2o_buf_t line;
if (req->conn->getpeername(req->conn, &sa, &sa_len) == 0 && sa.sa_family == AF_INET) {
uint32_t addr = htonl(((struct sockaddr_in*)&sa)->sin_addr.s_addr);
sprintf(peername, "%d.%d.%d.%d", addr >> 24, (addr >> 16) & 255, (addr >> 8) & 255, addr & 255);
} else {
strcpy(peername, "-");
}
line = h2o_sprintf(
&req->pool,
"%s - - [%.*s] \"%.*s %.*s HTTP/%d.%d\" %d %llu\n",
peername,
(int)H2O_TIMESTR_LOG_LEN, req->processed_at.str->log,
(int)req->method.len, req->method.base,
(int)req->path.len, req->path.base,
(int)(req->version >> 8),
(int)(req->version & 255),
req->res.status,
(unsigned long long)req->bytes_sent);
write(self->fd, line.base, line.len);
}
h2o_logger_t *h2o_register_access_logger(h2o_context_t *ctx, const char *path)
{
struct st_h2o_access_logger_t *self = h2o_malloc(sizeof(*self));
memset(self, 0, sizeof(*self));
self->super.destroy = (void*)free;
self->super.log = log_access;
self->fd = open(path, O_CREAT | O_WRONLY | O_APPEND, 0644);
if (self->fd == -1)
return NULL;
return &self->super;
}