QList<QObject*> senders = _relayHash.keys();
foreach(QObject* sender, senders)
detachObject(sender);
+
+ // close peer connections
+ foreach(QIODevice *device, _peerByteCount.keys()) {
+ device->close();
+ delete device;
+ }
}
void SignalProxy::setProxyMode(ProxyMode mode) {
}
Core::~Core() {
- foreach(QTcpSocket *socket, blocksizes.keys()) {
+ foreach(QTcpSocket *socket, blocksizes.keys()) { qDebug() << "disconnecting" << socket << blocksizes.keys();
socket->disconnectFromHost(); // disconnect local (i.e. non-authed) clients
}
qDeleteAll(sessions);
while(SignalProxy::readDataFromDevice(socket, blocksizes[socket], item)) {
QVariantMap msg = item.toMap();
processClientMessage(socket, msg);
+ if(!blocksizes.contains(socket)) break; // this socket is no longer ours to handle!
}
}
quasselVersion = "0.2.0-pre";
quasselDate = "2008-02-18";
- quasselBuild = 526;
+ quasselBuild = 528;
//! Minimum client build number the core needs
clientBuildNeeded = 526;