2 #include <netinet/in.h>
4 #include <sys/socket.h>
13 Client::Client(int sock)
16 connect_time(time(NULL)),
17 state(Client::READING_REQUEST),
19 header_or_error_bytes_sent(0),
22 request.reserve(1024);
24 // Find the remote address, and convert it to ASCII.
26 socklen_t addr_len = sizeof(addr);
28 if (getpeername(sock, reinterpret_cast<sockaddr *>(&addr), &addr_len) == -1) {
29 perror("getpeername");
32 char buf[INET6_ADDRSTRLEN];
33 if (inet_ntop(addr.sin6_family, &addr.sin6_addr, buf, sizeof(buf)) == NULL) {
42 Client::Client(const ClientProto &serialized, Stream *stream)
43 : sock(serialized.sock()),
44 remote_addr(serialized.remote_addr()),
45 connect_time(serialized.connect_time()),
46 state(State(serialized.state())),
47 request(serialized.request()),
48 stream_id(serialized.stream_id()),
50 header_or_error(serialized.header_or_error()),
51 header_or_error_bytes_sent(serialized.header_or_error_bytes_sent()),
52 bytes_sent(serialized.bytes_sent())
54 if (stream->mark_pool != NULL) {
55 fwmark = stream->mark_pool->get_mark();
57 fwmark = 0; // No mark.
59 if (setsockopt(sock, SOL_SOCKET, SO_MARK, &fwmark, sizeof(fwmark)) == -1) {
61 perror("setsockopt(SO_MARK)");
66 ClientProto Client::serialize() const
68 ClientProto serialized;
69 serialized.set_sock(sock);
70 serialized.set_remote_addr(remote_addr);
71 serialized.set_connect_time(connect_time);
72 serialized.set_state(state);
73 serialized.set_request(request);
74 serialized.set_stream_id(stream_id);
75 serialized.set_header_or_error(header_or_error);
76 serialized.set_header_or_error_bytes_sent(serialized.header_or_error_bytes_sent());
77 serialized.set_bytes_sent(bytes_sent);
81 ClientStats Client::get_stats() const
84 stats.stream_id = stream_id;
85 stats.remote_addr = remote_addr;
86 stats.connect_time = connect_time;
87 stats.bytes_sent = bytes_sent;