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.
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);
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;