X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=udpinput.h;h=481b006549f9f249a7ddd971874a78353c26dcd9;hp=a5f71b98209a57f1f719d5a447ec2c8e38914d09;hb=3b8ad87137cff7522ed12f4675d5ff26933bc94a;hpb=488f28bf7070f44469a006ed4a9d4c423788d175 diff --git a/udpinput.h b/udpinput.h index a5f71b9..481b006 100644 --- a/udpinput.h +++ b/udpinput.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(const std::string &stream_id); + 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_ids; // 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; };