Skip to content

Commit 94d02f0

Browse files
committed
Add check for existing message center connection
1 parent 9a186fc commit 94d02f0

1 file changed

Lines changed: 12 additions & 1 deletion

File tree

Source/Processors/RecordNode/RecordNode.cpp

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,13 @@ void RecordNode::connectToMessageCenter()
7575
{
7676

7777
const EventChannel* orig = AccessClass::getMessageCenter()->messageCenter->getMessageChannel();
78+
79+
for (auto eventChannel : eventChannelArray)
80+
{
81+
if (eventChannel == orig)
82+
return;
83+
}
84+
7885
eventChannelArray.add(new EventChannel(*orig));
7986

8087
isConnectedToMessageCenter = true;
@@ -415,7 +422,7 @@ bool RecordNode::enable()
415422
{
416423

417424
connectToMessageCenter();
418-
425+
419426
if (hasRecorded)
420427
{
421428
hasRecorded = false;
@@ -457,6 +464,8 @@ void RecordNode::startRecording()
457464
int srcIndex = chan->getSourceNodeID();
458465
int subIndex = chan->getSubProcessorIdx();
459466

467+
//std::cout << "Channel: " << ch << " Source Node: " << srcIndex << " Sub Index: " << subIndex << std::endl;
468+
460469
if (dataChannelStates[srcIndex][subIndex][dataChannelOrder[ch]])
461470
{
462471

@@ -540,6 +549,8 @@ void RecordNode::startRecording()
540549
useSynchronizer = static_cast<RecordNodeEditor*> (getEditor())->getSelectedEngineIdx() == 0;
541550

542551
recordThread->setFileComponents(rootFolder, experimentNumber, recordingNumber);
552+
553+
std::cout << "Num event channels: " << eventChannelArray.size() << std::endl;
543554
recordThread->startThread();
544555
isRecording = true;
545556
}

0 commit comments

Comments
 (0)