File indexing completed on 2024-05-05 05:34:26

 /*
     KSysGuard, the KDE System Guard
 
     SPDX-FileCopyrightText: 1999-2001 Chris Schlaeger <cs@kde.org>
 
     SPDX-License-Identifier: GPL-2.0-only OR GPL-3.0-only OR LicenseRef-KDE-Accepted-GPL
 
 */
 
 //#include <stdlib.h>
 
 #include "ksgrd_debug.h"
 #include <klocalizedstring.h>
 
 #include "SensorClient.h"
 #include "SensorManager.h"
 
 #include "SensorSocketAgent.h"
 
 using namespace KSGRD;
 
 SensorSocketAgent::SensorSocketAgent(SensorManager *sm)
     : SensorAgent(sm)
 {
     connect(&mSocket, SIGNAL(error(QAbstractSocket::SocketError)), SLOT(error(QAbstractSocket::SocketError)));
     connect(&mSocket, &QIODevice::bytesWritten, this, &SensorSocketAgent::msgSent);
     connect(&mSocket, &QIODevice::readyRead, this, &SensorSocketAgent::msgRcvd);
     connect(&mSocket, &QAbstractSocket::disconnected, this, &SensorSocketAgent::connectionClosed);
 }
 
 SensorSocketAgent::~SensorSocketAgent()
 {
     mSocket.write("quit\n", sizeof("quit\n"));
     mSocket.flush();
 }
 
 bool SensorSocketAgent::start(const QString &host, const QString &, const QString &, int port)
 {
     if (port <= 0) {
         qCDebug(LIBKSYSGUARD_KSGRD) << "SensorSocketAgent::start: Invalid port " << port;
     }
 
     setHostName(host);
     mPort = port;
 
     mSocket.connectToHost(hostName(), mPort);
 
     return true;
 }
 
 void SensorSocketAgent::hostInfo(QString &shell, QString &command, int &port) const
 {
     shell.clear();
     command.clear();
     port = mPort;
 }
 
 void SensorSocketAgent::msgSent()
 {
     if (mSocket.bytesToWrite() != 0) {
         return;
     }
 
     // Try to send next request if available.
     executeCommand();
 }
 
 void SensorSocketAgent::msgRcvd()
 {
     int buflen = mSocket.bytesAvailable();
     char *buffer = new char[buflen];
 
     mSocket.read(buffer, buflen);
 
     processAnswer(buffer, buflen);
     delete[] buffer;
 }
 
 void SensorSocketAgent::connectionClosed()
 {
     setDaemonOnLine(false);
     if (sensorManager()) {
         sensorManager()->disengage(this); // delete ourselves
     }
 }
 
 void SensorSocketAgent::error(QAbstractSocket::SocketError id)
 {
     switch (id) {
     case QAbstractSocket::ConnectionRefusedError:
         SensorMgr->notify(i18n("Connection to %1 refused", hostName()));
         break;
     case QAbstractSocket::HostNotFoundError:
         SensorMgr->notify(i18n("Host %1 not found", hostName()));
         break;
     case QAbstractSocket::NetworkError:
         SensorMgr->notify(i18n("An error occurred with the network (e.g. the network cable was accidentally unplugged) for host %1.", hostName()));
         break;
     default:
         SensorMgr->notify(i18n("Error for host %1: %2", hostName(), mSocket.errorString()));
     }
 
     setDaemonOnLine(false);
     if (sensorManager()) {
         sensorManager()->disengage(this);
     }
 }
 
 bool SensorSocketAgent::writeMsg(const char *msg, int len)
 {
     int writtenLength = mSocket.write(msg, len);
     mSocket.flush();
     return writtenLength == len;
 }