X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=httpinput.h;h=890cc9ef91256b92145e58dcc3425831fa0747fc;hp=31819f947ec54f4e225e95609e6fb86562867898;hb=e3f2936e3c9ff3b5569759c1aaed16f03bf728f8;hpb=50651c954803c1941e6ad1bb494712891c18f7d2 diff --git a/httpinput.h b/httpinput.h index 31819f9..890cc9e 100644 --- a/httpinput.h +++ b/httpinput.h @@ -8,9 +8,12 @@ #include "input.h" #include "metacube2.h" +#include "stream.h" class InputProto; +// Despite the name, covers input over both HTTP and pipes, both typically +// wrapped in Metacube. class HTTPInput : public Input { public: HTTPInput(const std::string &url, Input::Encoding encoding); @@ -34,6 +37,10 @@ private: // Open a socket that connects to the given host and port. Does DNS resolving. int lookup_and_connect(const std::string &host, const std::string &port); + // Open a child process with the given command line (given to /bin/sh). + // Returns a pipe to its standard output. + int open_child_process(const std::string &cmdline); + // Parses a HTTP response. Returns false if it not a 200. bool parse_response(const std::string &response); @@ -108,6 +115,12 @@ private: // Last time we made a connection with logging enabled. // (Initially at some point before the epoch.) timespec last_verbose_connection { -3600, 0 }; + + // If we've received a Metacube2 PTS metadata block, it belongs to the + // next regular block we receive, and is stored here in the meantime. + // If we haven't received one yet (or we've already received the + // corresponding data block), this is empty, ie., timebase_num == 0. + RationalPTS next_block_pts; }; #endif // !defined(_HTTPINPUT_H)