When adding new streams that are copies of old streams, copy the HTTP header.

This was already fixed for UDP inputs, but not HTTP inputs. Also, we probably
do not do the right thing here for the stream header.

diff --git a/httpinput.cpp b/httpinput.cpp
index b066b241c0b540aa4f5fc9245af98f84f82748fd..2fe68061b44c89e7b8a2811df8c5aff3369cb3bd 100644 (file)
--- a/httpinput.cpp
+++ b/httpinput.cpp
@@ -539,6 +539,12 @@ void HTTPInput::drop_pending_data(size_t num_bytes)
        pending_data.erase(pending_data.begin(), pending_data.begin() + num_bytes);
 }
 
        pending_data.erase(pending_data.begin(), pending_data.begin() + num_bytes);
 }
 

+void HTTPInput::add_destination(int stream_index)
+{
+       stream_indices.push_back(stream_index);
+       servers->set_header(stream_index, http_header, "");
+}
+

 InputStats HTTPInput::get_stats() const
 {
        MutexLock lock(&stats_mutex);
 InputStats HTTPInput::get_stats() const
 {
        MutexLock lock(&stats_mutex);

diff --git a/httpinput.h b/httpinput.h
index bf7d9534d6eeced4d06319f982981f450c197745..78c49c3df0f0cde346487698d2afdcf1b925bb5e 100644 (file)
--- a/httpinput.h
+++ b/httpinput.h
@@ -21,10 +21,7 @@ public:
 
        virtual std::string get_url() const { return url; }
 
 
        virtual std::string get_url() const { return url; }
 

-       virtual void add_destination(int stream_index)
-       {
-               stream_indices.push_back(stream_index);
-       }
+       virtual void add_destination(int stream_index);

 
        virtual InputStats get_stats() const;
 
 
        virtual InputStats get_stats() const;