complete the removal of a terminated universe
This commit is contained in:
parent
ef59af7207
commit
053339d2d1
@ -82,21 +82,8 @@ void Source::terminate(const uint16_t num)
|
|||||||
universes_mutext_.lock();
|
universes_mutext_.lock();
|
||||||
auto metadata = universes_[num]->provenance();
|
auto metadata = universes_[num]->provenance();
|
||||||
metadata->options.stream_terminated = true;
|
metadata->options.stream_terminated = true;
|
||||||
universes_[num]->setProvenance(metadata);
|
universes_.at(num)->setProvenance(metadata);
|
||||||
universes_mutext_.unlock();
|
delete universes_.at(num);
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* @brief Source::end
|
|
||||||
* @param num
|
|
||||||
*/
|
|
||||||
void Source::end(const uint16_t num)
|
|
||||||
{
|
|
||||||
if (!universes_.count(num))
|
|
||||||
return;
|
|
||||||
|
|
||||||
universes_mutext_.lock();
|
|
||||||
universes_.erase(num);
|
universes_.erase(num);
|
||||||
universes_mutext_.unlock();
|
universes_mutext_.unlock();
|
||||||
}
|
}
|
||||||
|
@ -56,7 +56,6 @@ public:
|
|||||||
Universe * universe(const uint16_t);
|
Universe * universe(const uint16_t);
|
||||||
|
|
||||||
protected:
|
protected:
|
||||||
virtual void end(const uint16_t);
|
|
||||||
virtual void discoveryAnnounce();
|
virtual void discoveryAnnounce();
|
||||||
|
|
||||||
void sendExtendedFrame(const uint16_t vector,
|
void sendExtendedFrame(const uint16_t vector,
|
||||||
|
Loading…
Reference in New Issue
Block a user