summaryrefslogtreecommitdiffstats
path: root/src/core
diff options
context:
space:
mode:
Diffstat (limited to 'src/core')
-rw-r--r--src/core/pvsClient.cpp1
-rw-r--r--src/core/pvsConnectionManager.cpp19
2 files changed, 19 insertions, 1 deletions
diff --git a/src/core/pvsClient.cpp b/src/core/pvsClient.cpp
index f048b54..0448f97 100644
--- a/src/core/pvsClient.cpp
+++ b/src/core/pvsClient.cpp
@@ -316,6 +316,5 @@ void PVSClient::processesVectorAdd(QString msg)
else if (msg.indexOf("vector ready") == 0)
{
emit processVectorReady(true);
- ConsoleLog writeError("processVectorReady(true)!");
}
}
diff --git a/src/core/pvsConnectionManager.cpp b/src/core/pvsConnectionManager.cpp
index d0f1479..db302c4 100644
--- a/src/core/pvsConnectionManager.cpp
+++ b/src/core/pvsConnectionManager.cpp
@@ -260,6 +260,25 @@ void PVSConnectionManager::onCommand(PVSMsg command)
else tmp->processesVectorAdd(message);
}
}
+ else if (ident == "MCASTFTANNOUNCE")
+ {
+ _pvsServer.sendToAll(command);
+ }
+ else if (ident == "MCASTFTRETRY")
+ {
+ QStringList fields = message.split(':');
+ if (!fields.size() == 2)
+ {
+ qDebug() << "Malformed MCASTFTRETRY message:" << message;
+ return;
+ }
+
+ PVSClient* client = getClientFromUsername(fields[0]);
+ if (client)
+ {
+ client->sendMessage(command);
+ }
+ }
}
void PVSConnectionManager::onChat(PVSMsg chatMsg)
{