aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias P. Braendli <matthias.braendli@mpb.li>2016-12-24 11:11:03 +0100
committerMatthias P. Braendli <matthias.braendli@mpb.li>2016-12-24 11:11:03 +0100
commite1acfdd90d331e032170fba70a73a0588d6121cc (patch)
treed013823d9c56db172268bdd880956200acdbf896
parent2b014e2f00df81eefe977b901ab601ea11ccb895 (diff)
downloaddabmux-e1acfdd90d331e032170fba70a73a0588d6121cc.tar.gz
dabmux-e1acfdd90d331e032170fba70a73a0588d6121cc.tar.bz2
dabmux-e1acfdd90d331e032170fba70a73a0588d6121cc.zip
Directly create the outputs in shared_ptrs
-rw-r--r--src/DabMux.cpp27
1 files changed, 13 insertions, 14 deletions
diff --git a/src/DabMux.cpp b/src/DabMux.cpp
index 450179d..069af48 100644
--- a/src/DabMux.cpp
+++ b/src/DabMux.cpp
@@ -341,49 +341,49 @@ int main(int argc, char *argv[])
string proto = uri.substr(0, proto_pos);
string location = uri.substr(proto_pos + 3);
- DabOutput *output;
+ std::shared_ptr<DabOutput> output;
if (0) {
#if defined(HAVE_OUTPUT_FILE)
} else if (proto == "file") {
- output = new DabOutputFile();
+ output = make_shared<DabOutputFile>();
#endif // defined(HAVE_OUTPUT_FILE)
#if defined(HAVE_OUTPUT_FIFO)
} else if (proto == "fifo") {
- output = new DabOutputFifo();
+ output = make_shared<DabOutputFifo>();
#endif // !defined(HAVE_OUTPUT_FIFO)
#if defined(HAVE_OUTPUT_RAW)
} else if (proto == "raw") {
- output = new DabOutputRaw();
+ output = make_shared<DabOutputRaw>();
#endif // defined(HAVE_OUTPUT_RAW)
#if defined(HAVE_OUTPUT_UDP)
} else if (proto == "udp") {
- output = new DabOutputUdp();
+ output = make_shared<DabOutputUdp>();
#endif // defined(HAVE_OUTPUT_UDP)
#if defined(HAVE_OUTPUT_TCP)
} else if (proto == "tcp") {
- output = new DabOutputTcp();
+ output = make_shared<DabOutputTcp>();
#endif // defined(HAVE_OUTPUT_TCP)
#if defined(HAVE_OUTPUT_SIMUL)
} else if (proto == "simul") {
- output = new DabOutputSimul();
+ output = make_shared<DabOutputSimul>();
#endif // defined(HAVE_OUTPUT_SIMUL)
#if defined(HAVE_OUTPUT_ZEROMQ)
} else if (proto == "zmq+tcp") {
- output = new DabOutputZMQ("tcp");
+ output = make_shared<DabOutputZMQ>("tcp");
} else if (proto == "zmq+ipc") {
- output = new DabOutputZMQ("ipc");
+ output = make_shared<DabOutputZMQ>("ipc");
} else if (proto == "zmq+pgm") {
- output = new DabOutputZMQ("pgm");
+ output = make_shared<DabOutputZMQ>("pgm");
} else if (proto == "zmq+epgm") {
- output = new DabOutputZMQ("epgm");
+ output = make_shared<DabOutputZMQ>("epgm");
#endif // defined(HAVE_OUTPUT_ZEROMQ)
} else {
etiLog.level(error) << "Output protocol unknown: " << proto;
throw MuxInitException();
}
- if (output == nullptr) {
+ if (not output) {
etiLog.level(error) <<
"Unable to init output " <<
uri;
@@ -397,8 +397,7 @@ int main(int argc, char *argv[])
return -1;
}
- std::shared_ptr<DabOutput> dabout(output);
- outputs.push_back(dabout);
+ outputs.push_back(output);
}
}