Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 08:41:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clear channels & transports containers in Reset()

Browse Source
This commit is contained in:
Alexey Rybalchenko 2019-07-11 17:44:53 +02:00 committed by Dennis Klein
parent 5c943bbedb
commit 937c9e8921
1 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
fairmq/FairMQDevice.cxx
View File

@ -836,21 +836,15 @@ void FairMQDevice::ResetTaskWrapper()
void FairMQDevice::ResetWrapper() void FairMQDevice::ResetWrapper()
{ {
for (auto& t : fTransports) { for (auto& transport : fTransports) {
t.second->Reset(); transport.second->Reset();
}
// iterate over the channels map
for (auto& mi : fChannels) {
// iterate over the channels vector
for (auto& vi : mi.second) {
// vi.fReset = true;
vi.fSocket.reset(); // destroy FairMQSocket
}
} }
Reset(); Reset();
fChannels.clear();
fTransports.clear();
fTransportFactory.reset();
ChangeState(Transition::Auto); ChangeState(Transition::Auto);
} }