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