X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=httpinput.h;h=ac52bfc34b019e91fa58dc688306d872695ca7f8;hp=e7c447af52eb310da0d18b5a83cbc7272dfd5933;hb=f0621e41fdb96ce1bd58e7561e0aa76345072ba3;hpb=37bc14f5b28f66ccc1760f410091f98769616476 diff --git a/httpinput.h b/httpinput.h index e7c447a..ac52bfc 100644 --- a/httpinput.h +++ b/httpinput.h @@ -7,6 +7,7 @@ #include #include "input.h" +#include "metacube2.h" class InputProto; @@ -44,6 +45,8 @@ private: // and outputs a warning. void drop_pending_data(size_t num_bytes); + void process_metacube_metadata_block(const metacube2_block_header &hdr, const char *payload, uint32_t payload_size); + enum State { NOT_CONNECTED, SENDING_REQUEST, @@ -84,10 +87,10 @@ private: // If starts with a Metacube header, // this is true. - bool has_metacube_header; + bool has_metacube_header = false; // The socket we are downloading on (or -1). - int sock; + int sock = -1; // Mutex protecting . mutable pthread_mutex_t stats_mutex; @@ -96,15 +99,15 @@ private: InputStats stats; // Number of (started) connection attempts since last data byte was successfully read. - unsigned num_connection_attempts; + unsigned num_connection_attempts = 0; // If set, don't log anything related to connections. // (Only set if we've had enough unsuccessful connection attempts.) - bool suppress_logging; + bool suppress_logging = false; // Last time we made a connection with logging enabled. // (Initially at some point before the epoch.) - timespec last_verbose_connection; + timespec last_verbose_connection { -3600, 0 }; }; #endif // !defined(_HTTPINPUT_H)