X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=main.cpp;h=04d0d3da33b26bd6ae0a44942964d08c230682b2;hp=db3be63f2d05a2cbcff27afa620205b97405f524;hb=239a9eab1a2468b401183745a24b2fbd590a6998;hpb=684496ba9c7def1421d045435b6b92e80bc54c74 diff --git a/main.cpp b/main.cpp index db3be63..04d0d3d 100644 --- a/main.cpp +++ b/main.cpp @@ -25,6 +25,7 @@ #include "server.h" #include "serverpool.h" #include "input.h" +#include "httpinput.h" #include "stats.h" #include "state.pb.h" @@ -267,7 +268,7 @@ vector create_inputs(const vector &config, deserialized_inputs->erase(deserialized_input_it); } if (input == NULL) { - input = new Input(stream_id, src); + input = new HTTPInput(stream_id, src); } input->run(); inputs.push_back(input); @@ -358,7 +359,7 @@ int main(int argc, char **argv) for (int i = 0; i < loaded_state.inputs_size(); ++i) { deserialized_inputs.insert(make_pair( loaded_state.inputs(i).stream_id(), - new Input(loaded_state.inputs(i)))); + new HTTPInput(loaded_state.inputs(i)))); } // Convert the acceptor from older serialized formats.