1 files changed, 137 insertions, 0 deletions
diff --git a/ksysguard/gui/ksgrd/SensorSocketAgent.cc b/ksysguard/gui/ksgrd/SensorSocketAgent.cc
new file mode 100644
index 000000000..dcb5b7f3b
--- /dev/null
+++ b/ksysguard/gui/ksgrd/SensorSocketAgent.cc
@@ -0,0 +1,137 @@
+/*
+    KSysGuard, the KDE System Guard
+   
+    Copyright (c) 1999 - 2001 Chris Schlaeger <cs@kde.org>
+    
+    This program is free software; you can redistribute it and/or
+    modify it under the terms of version 2 of the GNU General Public
+    License as published by the Free Software Foundation.
+
+    This program is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+    GNU General Public License for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with this program; if not, write to the Free Software
+    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+
+*/
+
+#include <stdlib.h>
+
+#include <kdebug.h>
+#include <klocale.h>
+#include <kpassdlg.h> 
+
+#include "SensorClient.h"
+#include "SensorManager.h"
+
+#include "SensorSocketAgent.h"
+
+using namespace KSGRD;
+
+SensorSocketAgent::SensorSocketAgent( SensorManager *sm )
+  : SensorAgent( sm )
+{
+  connect( &mSocket, SIGNAL( gotError( int ) ), SLOT( error( int ) ) );
+  connect( &mSocket, SIGNAL( bytesWritten( int ) ), SLOT( msgSent( int ) ) );
+  connect( &mSocket, SIGNAL( readyRead() ), SLOT( msgRcvd() ) );
+  connect( &mSocket, SIGNAL( closed() ), SLOT( connectionClosed() ) );
+}
+
+SensorSocketAgent::~SensorSocketAgent()
+{
+  mSocket.writeBlock( "quit\n", strlen( "quit\n" ) );
+  mSocket.flush();
+}
+	
+bool SensorSocketAgent::start( const QString &host, const QString&,
+                               const QString&, int port )
+{
+  if ( port <= 0 )
+    kdDebug(1215) << "SensorSocketAgent::start: Illegal port " << port << endl;
+
+  setHostName( host );
+  mPort = port;
+
+  mSocket.connect( hostName(), QString::number(mPort) );
+
+  return true;
+}
+
+void SensorSocketAgent::hostInfo( QString &shell, QString &command, int &port ) const
+{
+  shell = QString::null;
+  command = QString::null;
+  port = mPort;
+}
+
+void SensorSocketAgent::msgSent( int )
+{
+  if ( mSocket.bytesToWrite() != 0 )
+    return;
+
+  setTransmitting( false );
+
+  // Try to send next request if available.
+  executeCommand();
+}
+
+void SensorSocketAgent::msgRcvd()
+{
+  int buflen = mSocket.bytesAvailable();
+  char* buffer = new char[ buflen ];
+
+  mSocket.readBlock( buffer, buflen );
+  QString buf = QString::fromLocal8Bit( buffer, buflen );
+  delete [] buffer;
+
+  processAnswer( buf );
+}
+
+void SensorSocketAgent::connectionClosed()
+{
+  setDaemonOnLine( false );
+  sensorManager()->hostLost( this );
+  sensorManager()->requestDisengage( this );
+}
+
+void SensorSocketAgent::error( int id )
+{
+  switch ( id ) {
+    case KNetwork::KSocketBase::ConnectionRefused:
+      SensorMgr->notify( i18n( "Connection to %1 refused" )
+                         .arg( hostName() ) );
+      break;
+    case  KNetwork::KSocketBase::LookupFailure:
+      SensorMgr->notify( i18n( "Host %1 not found" )
+                         .arg( hostName() ) );
+      break;
+    case  KNetwork::KSocketBase::Timeout:
+      SensorMgr->notify( i18n( "Timeout at host %1")
+                         .arg( hostName() ) );
+      break;
+    case  KNetwork::KSocketBase::NetFailure:
+      SensorMgr->notify( i18n( "Network failure host %1")
+                         .arg( hostName() ) );
+      break;
+    default:
+      kdDebug(1215) << "SensorSocketAgent::error() unknown error " << id << endl;
+  }
+
+  setDaemonOnLine( false );
+  sensorManager()->requestDisengage( this );
+}
+
+bool SensorSocketAgent::writeMsg( const char *msg, int len )
+{
+  return ( mSocket.writeBlock( msg, len ) == len );
+}
+
+bool SensorSocketAgent::txReady()
+{
+  return !transmitting();
+}
+
+#include "SensorSocketAgent.moc"