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