X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=client.h;h=9a189c0a9af709365944d11e6db37f75868161f0;hp=87fa71862995d90c0f2833631d12eff97bef81a9;hb=1e15bf9054e65adfce268578f4e474c980ef6443;hpb=195dc469133d0daed6ac69cdef373dc8dade9637 diff --git a/client.h b/client.h index 87fa718..9a189c0 100644 --- a/client.h +++ b/client.h @@ -3,22 +3,26 @@ // A Client represents a single connection from a client (watching a single stream). +#include #include #include class ClientProto; -class Stream; +struct Stream; // Digested statistics for writing to logs etc. struct ClientStats { std::string stream_id; + int sock; + int fwmark; std::string remote_addr; time_t connect_time; size_t bytes_sent; + size_t bytes_lost; + size_t num_loss_events; }; struct Client { - Client() {} Client(int sock); // Serialization/deserialization. @@ -58,8 +62,16 @@ struct Client { // or SENDING_ERROR. size_t header_or_error_bytes_sent; + // Number of bytes we are into the stream (ie., the end of last send). + // Only relevant for SENDING_DATA. + size_t stream_pos; + // Number of bytes we've sent of data. Only relevant for SENDING_DATA. size_t bytes_sent; + + // Number of times we've skipped forward due to the backlog being too big, + // and how many bytes we've skipped over in all. Only relevant for SENDING_DATA. + size_t bytes_lost, num_loss_events; }; #endif // !defined(_CLIENT_H)