X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=httpinput.h;h=bf7d9534d6eeced4d06319f982981f450c197745;hb=b3cabe9eb67ad22e671cc47408641b4a24a1af0a;hp=9a2787176c4c2b8eb2ed27e1d2bf19d5b4aa4210;hpb=340489a8e732519182ecbc92116e7dfa2997143c;p=cubemap diff --git a/httpinput.h b/httpinput.h index 9a27871..bf7d953 100644 --- a/httpinput.h +++ b/httpinput.h @@ -21,11 +21,13 @@ public: virtual std::string get_url() const { return url; } - virtual void add_destination(const std::string &stream_id) + virtual void add_destination(int stream_index) { - stream_ids.push_back(stream_id); + stream_indices.push_back(stream_index); } + virtual InputStats get_stats() const; + private: // Actually does the download. virtual void do_work(); @@ -53,7 +55,7 @@ private: }; State state; - std::vector stream_ids; + std::vector stream_indices; // The URL and its parsed components. std::string url; @@ -81,7 +83,13 @@ private: bool has_metacube_header; // The socket we are downloading on (or -1). - int sock; + int sock; + + // Mutex protecting . + mutable pthread_mutex_t stats_mutex; + + // The current statistics for this connection. Protected by . + InputStats stats; }; #endif // !defined(_HTTPINPUT_H)