X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fcore.cpp;h=d03ca6b6c2bfdb35fb6e4d084ce95106b863eb18;hb=a86c3a08e57e0a23b3e57d0b9ee9d27cc5113d21;hp=ee93bcd8da2395588b31974e62d5545d3067bef7;hpb=9ac6ae4ee26819874d8843ba09f38a24088d663d;p=quassel.git diff --git a/src/core/core.cpp b/src/core/core.cpp index ee93bcd8..d03ca6b6 100644 --- a/src/core/core.cpp +++ b/src/core/core.cpp @@ -21,8 +21,8 @@ #include "core.h" #include "coresession.h" #include "coresettings.h" +#include "signalproxy.h" #include "sqlitestorage.h" -#include "util.h" #include #include @@ -176,7 +176,7 @@ void Core::clientHasData() { Q_ASSERT(socket && blockSizes.contains(socket)); quint32 bsize = blockSizes.value(socket); QVariant item; - if(readDataFromDevice(socket, bsize, item)) { + if(SignalProxy::readDataFromDevice(socket, bsize, item)) { // we need to auth the client try { QVariantMap msg = item.toMap(); @@ -238,7 +238,7 @@ void Core::processClientInit(QTcpSocket *socket, const QVariantMap &msg) { disconnect(socket, 0, this, 0); sessions[uid]->addClient(socket); qDebug() << "Client initialized successfully."; - writeDataToDevice(socket, reply); + SignalProxy::writeDataToDevice(socket, reply); } void Core::processCoreSetup(QTcpSocket *socket, QVariantMap &msg) { @@ -261,7 +261,7 @@ void Core::processCoreSetup(QTcpSocket *socket, QVariantMap &msg) { QVariantMap reply; reply["StartWizard"] = true; reply["StorageProviders"] = availableStorageProviders(); - writeDataToDevice(socket, reply); + SignalProxy::writeDataToDevice(socket, reply); } else { // write coresettings CoreSettings s; @@ -277,7 +277,7 @@ void Core::processCoreSetup(QTcpSocket *socket, QVariantMap &msg) { QVariantMap reply; reply["StartWizard"] = true; reply["StorageProviders"] = availableStorageProviders(); - writeDataToDevice(socket, reply); + SignalProxy::writeDataToDevice(socket, reply); } }