}
}
- // Parse input encoding.
- map<string, string>::const_iterator src_encoding_parm_it = line.parameters.find("src_encoding");
- if (src_encoding_parm_it == line.parameters.end() ||
- src_encoding_parm_it->second == "metacube") {
- udpstream.src_encoding = StreamConfig::STREAM_ENCODING_METACUBE;
- } else if (src_encoding_parm_it->second == "raw") {
- udpstream.src_encoding = StreamConfig::STREAM_ENCODING_RAW;
- } else {
- log(ERROR, "Parameter 'src_encoding' must be either 'raw' or 'metacube' (default)");
- return false;
- }
-
config->udpstreams.push_back(udpstream);
return true;
}
uint32_t pacing_rate; // In bytes per second. Default is ~0U (no limit).
int ttl; // Default is -1 (use operating system default).
int multicast_iface_index; // Default is -1 (use operating system default).
- StreamConfig::Encoding src_encoding;
};
struct Gen204Config {
}
for (unsigned i = 0; i < config.udpstreams.size(); ++i) {
const UDPStreamConfig &udpstream_config = config.udpstreams[i];
- create_config_input(udpstream_config.src, Input::Encoding(udpstream_config.src_encoding), inputs);
+ create_config_input(udpstream_config.src, Input::INPUT_ENCODING_RAW, inputs);
}
}
udpstream_config.multicast_iface_index);
string src = udpstream_config.src;
- Input::Encoding src_encoding = Input::Encoding(udpstream_config.src_encoding);
if (!src.empty()) {
- multimap<InputKey, InputWithRefcount>::iterator input_it = inputs->find(make_pair(src, src_encoding));
+ multimap<InputKey, InputWithRefcount>::iterator input_it = inputs->find(make_pair(src, Input::INPUT_ENCODING_RAW));
assert(input_it != inputs->end());
input_it->second.input->add_destination(stream_index);
++input_it->second.refcount;