Added check for failure to open metadata in DTSC pull input.
Change-Id: I690d12bd458afc1efef64f34ab2513f0f338e6a0
This commit is contained in:
parent
a84e1ef4b4
commit
f3803aeceb
1 changed files with 6 additions and 0 deletions
|
@ -171,6 +171,12 @@ namespace Mist{
|
||||||
DTSC::Packet metaPack(dataPacket.data(), dataPacket.size());
|
DTSC::Packet metaPack(dataPacket.data(), dataPacket.size());
|
||||||
DTSC::Meta nM("", metaPack.getScan());
|
DTSC::Meta nM("", metaPack.getScan());
|
||||||
meta.reInit(streamName, false);
|
meta.reInit(streamName, false);
|
||||||
|
if (!meta){
|
||||||
|
FAIL_MSG("Could not open stream metadata to merge in remote tracks; aborting!");
|
||||||
|
Util::logExitReason(ER_INTERNAL_ERROR, "Could not open stream metadata to merge in remote tracks");
|
||||||
|
config->is_active = false;
|
||||||
|
break;
|
||||||
|
}
|
||||||
meta.merge(nM, true, false);
|
meta.merge(nM, true, false);
|
||||||
meta.setBootMsOffset(nM.getBootMsOffset());
|
meta.setBootMsOffset(nM.getBootMsOffset());
|
||||||
std::set<size_t> validTracks = M.getMySourceTracks(getpid());
|
std::set<size_t> validTracks = M.getMySourceTracks(getpid());
|
||||||
|
|
Loading…
Add table
Reference in a new issue