X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=udpinput.h;h=e41266e0dc3340a151d1a1a44a45748dcc628f1a;hp=0f89d6828de79b9be3e27db77ed2d7efcf93fb70;hb=9abb89bcf7940e2ada9d708f86a218a56334f68d;hpb=ca9624c43b968a0f29ea44e47851ff686bb64bb6 diff --git a/udpinput.h b/udpinput.h index 0f89d68..e41266e 100644 --- a/udpinput.h +++ b/udpinput.h @@ -1,8 +1,8 @@ #ifndef _UDPINPUT_H #define _UDPINPUT_H 1 -#include #include +#include #include "input.h" @@ -10,7 +10,7 @@ class InputProto; class UDPInput : public Input { public: - UDPInput(const std::string &stream_id, const std::string &url); + UDPInput(const std::string &url); // Serialization/deserialization. UDPInput(const InputProto &serialized); @@ -19,6 +19,8 @@ public: virtual std::string get_url() const { return url; } virtual void close_socket(); + virtual void add_destination(int stream_index); + private: // Actually gets the packets. virtual void do_work(); @@ -26,12 +28,15 @@ private: // Create the HTTP header. void construct_header(); - std::string stream_id; + std::vector stream_indices; // The URL and its parsed components. std::string url; std::string host, port, path; + // The HTTP header we're sending to clients. + std::string http_header; + // The socket we are receiving on (or -1). int sock; };