#include "acceptor.h"
#include "config.h"
+#include "input.h"
#include "log.h"
#include "parse.h"
stream.url = line.arguments[0];
const auto src_it = line.parameters.find("src");
+ bool input_is_udp = false;
if (src_it == line.parameters.end()) {
log(WARNING, "stream '%s' has no src= attribute, clients will not get any data.",
stream.url.c_str());
} else {
stream.src = src_it->second;
- // TODO: Verify that the URL is parseable?
+
+ string protocol, user, host, port, path;
+ if (!parse_url(stream.src, &protocol, &user, &host, &port, &path)) {
+ log(ERROR, "could not parse URL '%s'", stream.src.c_str());
+ return false;
+ }
+ if (protocol == "udp") {
+ input_is_udp = true;
+ }
}
const auto backlog_it = line.parameters.find("backlog_size");
// Parse input encoding.
const auto src_encoding_parm_it = line.parameters.find("src_encoding");
- if (src_encoding_parm_it == line.parameters.end() ||
- src_encoding_parm_it->second == "metacube") {
+ if (src_encoding_parm_it == line.parameters.end()) {
+ stream.src_encoding = input_is_udp ? StreamConfig::STREAM_ENCODING_RAW : StreamConfig::STREAM_ENCODING_METACUBE;
+ } else if (src_encoding_parm_it->second == "metacube") {
+ if (input_is_udp) {
+ log(ERROR, "UDP streams cannot have Metacube input");
+ return false;
+ }
stream.src_encoding = StreamConfig::STREAM_ENCODING_METACUBE;
} else if (src_encoding_parm_it->second == "raw") {
stream.src_encoding = StreamConfig::STREAM_ENCODING_RAW;
} else {
- log(ERROR, "Parameter 'src_encoding' must be either 'raw' or 'metacube' (default)");
+ log(ERROR, "Parameter 'src_encoding' must be either 'raw' (default for UDP) or 'metacube' (default for HTTP)");
return false;
}