if (fwmark != 0) {
log_perror("setsockopt(SO_MARK)");
}
+ fwmark = 0;
}
}
{
ClientStats stats;
stats.stream_id = stream_id;
+ stats.sock = sock;
+ stats.fwmark = fwmark;
stats.remote_addr = remote_addr;
stats.connect_time = connect_time;
stats.bytes_sent = bytes_sent;
switch (status) {
case RP_OUT_OF_SPACE:
- log(WARNING, "fd %d sent overlong request!", client->sock);
+ log(WARNING, "[%s] Client sent overlong request!", client->remote_addr.c_str());
close_client(client);
return;
case RP_NOT_FINISHED_YET:
// See if there's more data for us.
goto read_request_again;
case RP_EXTRA_DATA:
- log(WARNING, "fd %d had junk data after request!", client->sock);
+ log(WARNING, "[%s] Junk data after request!", client->remote_addr.c_str());
close_client(client);
return;
case RP_FINISHED:
return;
}
if (bytes_to_send > stream->backlog_size) {
- log(WARNING, "fd %d lost %lld bytes, maybe too slow connection",
- client->sock,
+ log(WARNING, "[%s] Client lost %lld bytes, maybe too slow connection",
+ client->remote_addr.c_str(),
(long long int)(bytes_to_send - stream->backlog_size));
client->stream_pos = stream->bytes_received - stream->backlog_size;
client->bytes_lost += bytes_to_send - stream->backlog_size;
now = time(NULL);
client_stats = servers->get_client_stats();
for (size_t i = 0; i < client_stats.size(); ++i) {
- fprintf(fp, "%s %s %d %llu %llu %llu\n",
+ fprintf(fp, "%s %d %d %s %d %llu %llu %llu\n",
client_stats[i].remote_addr.c_str(),
+ client_stats[i].sock,
+ client_stats[i].fwmark,
client_stats[i].stream_id.c_str(),
int(now - client_stats[i].connect_time),
(long long unsigned)(client_stats[i].bytes_sent),