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
|
/***************************************************************************
jabberbytestream.cpp - Byte Stream for Jabber
-------------------
begin : Wed Jul 7 2004
copyright : (C) 2004 by Till Gerken <[email protected]>
Kopete (C) 2004 Kopete developers <[email protected]>
***************************************************************************/
/***************************************************************************
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU Lesser General Public License as *
* published by the Free Software Foundation; either version 2.1 of the *
* License, or (at your option) any later version. *
* *
***************************************************************************/
#include <tqobject.h>
#include <kdebug.h>
#include "jabberbytestream.h"
#include <kbufferedsocket.h>
#include <kresolver.h>
#include "jabberprotocol.h"
JabberByteStream::JabberByteStream ( TQObject *parent, const char */*name*/ )
: ByteStream ( parent )
{
kdDebug ( JABBER_DEBUG_GLOBAL ) << k_funcinfo << "Instantiating new Jabber 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 JabberByteStream::connect ( TQString host, TQString service )
{
kdDebug ( JABBER_DEBUG_GLOBAL ) << k_funcinfo << "Connecting to " << host << ", service " << service << endl;
mClosing = false;
return socket()->connect ( host, service );
}
bool JabberByteStream::isOpen () const
{
// determine if socket is open
return socket()->isOpen ();
}
void JabberByteStream::close ()
{
kdDebug ( JABBER_DEBUG_GLOBAL ) << k_funcinfo << "Closing stream." << endl;
// close the socket and set flag that we are closing it ourselves
mClosing = true;
socket()->close();
}
int JabberByteStream::tryWrite ()
{
// send all data from the buffers to the socket
TQByteArray writeData = takeWrite();
socket()->writeBlock ( writeData.data (), writeData.size () );
return writeData.size ();
}
KNetwork::KBufferedSocket *JabberByteStream::socket () const
{
return mSocket;
}
JabberByteStream::~JabberByteStream ()
{
delete mSocket;
}
void JabberByteStream::slotConnected ()
{
emit connected ();
}
void JabberByteStream::slotConnectionClosed ()
{
kdDebug ( JABBER_DEBUG_GLOBAL ) << k_funcinfo << "Socket has been closed." << endl;
// depending on who closed the socket, emit different signals
if ( !mClosing )
{
emit connectionClosed ();
}
else
{
emit delayedCloseFinished ();
}
mClosing = false;
}
void JabberByteStream::slotReadyRead ()
{
// stuff all available data into our buffers
TQByteArray readBuffer ( socket()->bytesAvailable () );
socket()->readBlock ( readBuffer.data (), readBuffer.size () );
appendRead ( readBuffer );
emit readyRead ();
}
void JabberByteStream::slotBytesWritten ( int bytes )
{
emit bytesWritten ( bytes );
}
void JabberByteStream::slotError ( int code )
{
kdDebug ( JABBER_DEBUG_GLOBAL ) << k_funcinfo << "Socket error " << code << endl;
emit error ( code );
}
#include "jabberbytestream.moc"
|
