X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;f=src%2Fcore%2Fnetworkconnection.cpp;h=d177d4c1ed866383af222eee2f21da83a754f193;hb=77397f5e999830077fee13187c6a1ee044d92545;hp=67137653c40b5205fa31179ad78bcd37c34b4b7a;hpb=0d66a6f9ed6ea90493bca69ff781a1131d981503;p=quassel.git diff --git a/src/core/networkconnection.cpp b/src/core/networkconnection.cpp index 67137653..d177d4c1 100644 --- a/src/core/networkconnection.cpp +++ b/src/core/networkconnection.cpp @@ -89,7 +89,7 @@ NetworkConnection::NetworkConnection(Network *network, CoreSession *session) connect(network, SIGNAL(autoReconnectIntervalSet(quint32)), this, SLOT(autoReconnectSettingsChanged())); connect(network, SIGNAL(autoReconnectRetriesSet(quint16)), this, SLOT(autoReconnectSettingsChanged())); -#ifndef QT_NO_OPENSSL +#ifdef HAVE_SSL connect(&socket, SIGNAL(encrypted()), this, SLOT(socketEncrypted())); connect(&socket, SIGNAL(sslErrors(const QList &)), this, SLOT(sslErrors(const QList &))); #endif @@ -179,11 +179,11 @@ void NetworkConnection::connectToIrc(bool reconnecting) { QVariantList serverList = network()->serverList(); Identity *identity = coreSession()->identity(network()->identity()); if(!serverList.count()) { - quWarning() << "Server list empty, ignoring connect request!"; + qWarning() << "Server list empty, ignoring connect request!"; return; } if(!identity) { - quWarning() << "Invalid identity configures, ignoring connect request!"; + qWarning() << "Invalid identity configures, ignoring connect request!"; return; } // use a random server? @@ -253,19 +253,24 @@ void NetworkConnection::sendPerform() { if(!joinString.isEmpty()) userInputHandler()->handleJoin(statusBuf, joinString); } -void NetworkConnection::disconnectFromIrc(bool requested) { +void NetworkConnection::disconnectFromIrc(bool requested, const QString &reason) { _quitRequested = requested; // see socketDisconnected(); _autoReconnectTimer.stop(); _autoReconnectCount = 0; // prohibiting auto reconnect displayMsg(Message::Server, BufferInfo::StatusBuffer, "", tr("Disconnecting.")); if(socket.state() == QAbstractSocket::UnconnectedState) { socketDisconnected(); - } else if(socket.state() < QAbstractSocket::ConnectedState) { + } else if(socket.state() < QAbstractSocket::ConnectedState || !requested) { + // we might be in a state waiting for a timeout... + // or (!requested) this is a core shutdown... + // in both cases we don't really care... set a disconnected state socket.close(); - // we might be in a state waiting for a timeout... we don't care... set a disconnected state socketDisconnected(); } else { - _socketCloseTimer.start(10000); // the irc server has 10 seconds to close the socket + // quit gracefully if it's user requested quit + userInputHandler()->issueQuit(reason); + // the irc server has 10 seconds to close the socket + _socketCloseTimer.start(10000); } } @@ -278,7 +283,7 @@ void NetworkConnection::socketHasData() { void NetworkConnection::socketError(QAbstractSocket::SocketError) { _previousConnectionAttemptFailed = true; - quWarning() << qPrintable(tr("Could not connect to %1 (%2)").arg(network()->networkName(), socket.errorString())); + qWarning() << qPrintable(tr("Could not connect to %1 (%2)").arg(network()->networkName(), socket.errorString())); emit connectionError(socket.errorString()); emit displayMsg(Message::Error, BufferInfo::StatusBuffer, "", tr("Connection failure: %1").arg(socket.errorString())); network()->emitConnectionError(socket.errorString()); @@ -291,7 +296,7 @@ void NetworkConnection::socketError(QAbstractSocket::SocketError) { //exit(1); } -#ifndef QT_NO_OPENSSL +#ifdef HAVE_SSL void NetworkConnection::sslErrors(const QList &sslErrors) { Q_UNUSED(sslErrors) @@ -315,10 +320,10 @@ void NetworkConnection::socketEncrypted() { socketInitialized(); } -#endif // QT_NO_OPENSSL +#endif // HAVE_SSL void NetworkConnection::socketConnected() { -#ifdef QT_NO_OPENSSL +#ifndef HAVE_SSL socketInitialized(); return; #else @@ -335,7 +340,7 @@ void NetworkConnection::socketInitialized() { //emit connected(networkId()); initialize first! Identity *identity = coreSession()->identity(network()->identity()); if(!identity) { - quError() << "Identity invalid!"; + qCritical() << "Identity invalid!"; disconnectFromIrc(); return; } @@ -381,7 +386,13 @@ void NetworkConnection::socketDisconnected() { _autoWhoInProgress.clear(); _socketCloseTimer.stop(); - + + IrcUser *me = network()->me(); + if(me) { + foreach(QString channel, me->channels()) + emit displayMsg(Message::Quit, BufferInfo::ChannelBuffer, channel, "", me->hostmask()); + } + network()->setConnected(false); emit disconnected(networkId()); if(_quitRequested) { @@ -398,7 +409,7 @@ void NetworkConnection::socketDisconnected() { void NetworkConnection::doAutoReconnect() { if(connectionState() != Network::Disconnected && connectionState() != Network::Reconnecting) { - quWarning() << "NetworkConnection::doAutoReconnect(): Cannot reconnect while not being disconnected!"; + qWarning() << "NetworkConnection::doAutoReconnect(): Cannot reconnect while not being disconnected!"; return; } if(_autoReconnectCount > 0) _autoReconnectCount--; @@ -470,12 +481,9 @@ void NetworkConnection::putCmd(const QString &cmd, const QList ¶ if(cmd == "PRIVMSG" && params.count() > 1) { int overrun = lastParamOverrun(cmd, params); if(overrun) { - QList paramCopy1; - QList paramCopy2; - for(int i = 0; i < params.count() - 1; i++) { - paramCopy1 << params[i]; - paramCopy2 << params[i]; - } + QList paramCopy1 = params; + paramCopy1.removeLast(); + QList paramCopy2 = paramCopy1; QByteArray lastPart = params.last(); QByteArray splitter(" .,-"); @@ -484,8 +492,7 @@ void NetworkConnection::putCmd(const QString &cmd, const QList ¶ for(int i = 0; i < splitter.size(); i++) { splitPos = qMax(splitPos, lastPart.lastIndexOf(splitter[i], maxSplitPos)); } - - if(splitPos == -1) { + if(splitPos <= 0) { splitPos = maxSplitPos; }