kopete/protocols/groupwise/gwbytestream.cpp

   1
   2 /***************************************************************************
   3                    gwbytestream.cpp  -  Byte Stream using KNetwork sockets
   4                              -------------------
   5     begin                : Wed Jul 7 2004
   6     copyright            : (C) 2004 by Till Gerken <till@tantalo.net>
   7     Copyright                    : (c) 2006      Novell, Inc                     http://www.opensuse.org
   8
   9                            Kopete (C) 2004-2007 Kopete developers <kopete-devel@kde.org>
  10  ***************************************************************************/
  11
  12 /***************************************************************************
  13  *                                                                         *
  14  *   This program is free software; you can redistribute it and/or modify  *
  15  *   it under the terms of the GNU General Public License as published by  *
  16  *   the Free Software Foundation; either version 2 of the License, or     *
  17  *   (at your option) any later version.                                   *
  18  *                                                                         *
  19  ***************************************************************************/
  20
  21 #include "gwbytestream.h"
  22 #include <ksocketfactory.h>
  23
  24 #include <kdebug.h>
  25
  26 #include "gwerror.h"
  27
  28 KNetworkByteStream::KNetworkByteStream ( QObject *parent )
  29  : ByteStream ( parent )
  30 {
  31         kDebug () << "Instantiating new KNetwork byte stream.";
  32
  33         // reset close tracking flag
  34         mClosing = false;
  35
  36         mSocket = 0;
  37
  38 }
  39
  40 bool KNetworkByteStream::connect ( QString host, QString service )
  41 {
  42         kDebug () << "Connecting to " << host << ", service " << service;
  43         mSocket = KSocketFactory::connectToHost( "gwims", host, service.toUInt(), this );
  44
  45         QObject::connect( mSocket, SIGNAL(error(QAbstractSocket::SocketError)),
  46                         this, SLOT(slotError(QAbstractSocket::SocketError)) );
  47         QObject::connect( mSocket, SIGNAL(connected()), this, SLOT(slotConnected()) );
  48         QObject::connect( mSocket, SIGNAL(disconnected()), this, SLOT(slotConnectionClosed()) );
  49         QObject::connect( mSocket, SIGNAL(readyRead()), this, SLOT(slotReadyRead()) );
  50         QObject::connect( mSocket, SIGNAL(bytesWritten(qint64)), this, SLOT(slotBytesWritten(qint64)) );
  51         return true;
  52 }
  53
  54 bool KNetworkByteStream::isOpen () const
  55 {
  56
  57         // determine if socket is open
  58         if ( socket() )
  59         {
  60                 return socket()->isOpen ();
  61         }
  62         else
  63         {
  64                 return false;
  65         }
  66
  67 }
  68
  69 void KNetworkByteStream::close ()
  70 {
  71         kDebug () << "Closing stream.";
  72
  73         // close the socket and set flag that we are closing it ourselves
  74         mClosing = true;
  75         if ( socket() )
  76                 socket()->close();
  77
  78 }
  79
  80 int KNetworkByteStream::tryWrite ()
  81 {
  82
  83         // send all data from the buffers to the socket
  84         QByteArray writeData = takeWrite();
  85         socket()->write ( writeData.data (), writeData.size () );
  86
  87         return writeData.size ();
  88
  89 }
  90
  91 QTcpSocket *KNetworkByteStream::socket () const
  92 {
  93
  94         return mSocket;
  95
  96 }
  97
  98 KNetworkByteStream::~KNetworkByteStream ()
  99 {
 100 }
 101
 102 void KNetworkByteStream::slotConnected ()
 103 {
 104
 105         emit connected ();
 106
 107 }
 108
 109 void KNetworkByteStream::slotConnectionClosed ()
 110 {
 111         kDebug () << "Socket has been closed.";
 112
 113         // depending on who closed the socket, emit different signals
 114         if ( mClosing )
 115         {
 116                 kDebug () << "..by ourselves!";
 117                 kDebug() << "socket error is \"" << socket()->errorString() << "\"";
 118                 emit connectionClosed ();
 119         }
 120         else
 121         {
 122                 kDebug () << "..by the other end";
 123                 emit delayedCloseFinished ();
 124         }
 125
 126 }
 127
 128 void KNetworkByteStream::slotReadyRead ()
 129 {
 130         appendRead ( socket()->readAll() );
 131
 132         emit readyRead ();
 133
 134 }
 135
 136 void KNetworkByteStream::slotBytesWritten ( qint64 bytes )
 137 {
 138
 139         emit bytesWritten ( bytes );
 140
 141 }
 142
 143 void KNetworkByteStream::slotError ( QAbstractSocket::SocketError code )
 144 {
 145         kDebug () << "Socket error " <<  mSocket->errorString() <<  "' - Code : " << code;
 146         emit error ( code );
 147 }
 148
 149 #include "gwbytestream.moc"