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
|
#include "../ipc/client/ocopclient.h"
#include <qcopchannel_qws.h>
QCopChannel::QCopChannel( const QCString& channel, QObject* parent,
const char* name )
: QObject( parent, name ),m_chan(channel) {
init();
}
QCopChannel::~QCopChannel() {
m_client->delChannel( m_chan );
delete m_client;
}
void QCopChannel::init() {
m_client = new OCOPClient(QString::null, this );
m_client->addChannel(m_chan );
connect(m_client, SIGNAL(called(const QCString&, const QCString&, const QByteArray& ) ),
this, SLOT(rev(const QCString&, const QCString&, const QByteArray&) ) );
}
QCString QCopChannel::channel()const {
return m_chan;
}
bool QCopChannel::isRegistered( const QCString& chan) {
OCOPClient client;
return client.isRegistered( chan );
}
bool QCopChannel::send( const QCString& chan, const QCString& msg ) {
QByteArray ar(0);
return return sendLocally(chan, msg, ar );
}
bool QCString::send( const QCString& chan, const QCString& msg,
const QByteArray& ar ) {
return sendLocally( chan, msg, ar );
}
bool QCopChannel::sendLocally( const QCString& chan, const QCString& msg,
const QByteArray& ar ) {
OCOPClient client;
client.send( chan, msg, ar );
return true;
}
void QCopChannel::rev( const QCString& chan, const QCString& msg, const QByteArray& ar ) {
if (chan == m_chan )
emit received(chan, msg, ar );
}
|
