kmessageio.h

Go to the documentation of this file.

/*
    This file is part of the KDE games library
    Copyright (C) 2001 Burkhard Lehner (Burkhard.Lehner@gmx.de)

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Library General Public
    License version 2 as published by the Free Software Foundation.

    This library 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
    Library General Public License for more details.

    You should have received a copy of the GNU Library General Public License
    along with this library; see the file COPYING.LIB.  If not, write to
    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
    Boston, MA 02110-1301, USA.
*/

/*
     KMessageIO class and subclasses KMessageSocket and KMessageDirect
*/

#ifndef _KMESSAGEIO_H_
#define _KMESSAGEIO_H_

#include <QtCore/QObject>
#include <QtCore/QProcess>
#include <QtCore/QString>
#include <QtNetwork/QHostAddress>
#include <kdebug.h>
#include "../libkdegamesprivate_export.h"

class QTcpSocket;
class KProcess;
class QFile;


class KDEGAMESPRIVATE_EXPORT KMessageIO : public QObject
{
  Q_OBJECT

public:
  KMessageIO (QObject *parent = 0);

  ~KMessageIO ();

  virtual int rtti() const {return 0;}

  //virtual bool isNetwork () const = 0;
  virtual bool isNetwork () const
  {
   kError(11001) << "Calling PURE virtual isNetwork...BAD";
   return false;
  }

  //virtual bool isConnected () const = 0;
  virtual bool isConnected () const
  {
   kError(11001) << "Calling PURE virtual isConencted...BAD";
   return false;
  }

  void setId (quint32 id);

  quint32 id ();

  virtual quint16 peerPort () const { return 0; }

  virtual QString peerName () const { return QString::fromLatin1("localhost"); }


Q_SIGNALS:
  void received (const QByteArray &msg);

  void connectionBroken ();

public Q_SLOTS:

  virtual void send (const QByteArray &msg) = 0;

protected:
  quint32 m_id;
};


class KMessageSocket : public KMessageIO
{
  Q_OBJECT

public:
  KMessageSocket (const QString& host, quint16 port, QObject *parent = 0 );

  KMessageSocket (QHostAddress host, quint16 port, QObject *parent = 0);

  explicit KMessageSocket (QTcpSocket *socket, QObject *parent = 0);

  explicit KMessageSocket (int socketFD, QObject *parent = 0);

  ~KMessageSocket ();

  virtual int rtti() const {return 1;}

  virtual quint16 peerPort () const;

  virtual QString peerName () const;

  bool isNetwork() const { return true; }

  bool isConnected () const;

  void send (const QByteArray &msg);

protected Q_SLOTS:
  virtual void processNewData ();

protected:
  void initSocket ();
  QTcpSocket *mSocket;
  bool mAwaitingHeader;
  quint32 mNextBlockLength;

  bool isRecursive;  // workaround for "bug" in QSocket, Qt 2.2.3 or older
};


class KMessageDirect : public KMessageIO
{
  Q_OBJECT

public:
  explicit KMessageDirect (KMessageDirect *partner = 0, QObject *parent = 0);

  ~KMessageDirect ();

  virtual int rtti() const {return 2;}


  bool isNetwork() const { return false; }

  bool isConnected () const;

  void send (const QByteArray &msg);

protected:
  KMessageDirect *mPartner;
};

class KMessageProcess : public KMessageIO
{
  Q_OBJECT 

  public:
    KMessageProcess(QObject *parent, const QString& file);
    ~KMessageProcess();
    bool isConnected() const;
    void send (const QByteArray &msg);

    bool isNetwork() const { return false; }

  virtual int rtti() const {return 3;}



  public Q_SLOTS:
  void  slotReceivedStdout();
  void  slotReceivedStderr();
  void  slotProcessExited(int, QProcess::ExitStatus);

  Q_SIGNALS:
    void signalReceivedStderr(QString msg);

  private:
    QString mProcessName;
    KProcess *mProcess;
    QByteArray* mSendBuffer;
    QByteArray mReceiveBuffer;
    int mReceiveCount;
};

#endif