1 /***************************************************************************
2 * Copyright (C) 2005-2013 by the Quassel Project *
3 * devel@quassel-irc.org *
5 * This program is free software; you can redistribute it and/or modify *
6 * it under the terms of the GNU General Public License as published by *
7 * the Free Software Foundation; either version 2 of the License, or *
8 * (at your option) version 3. *
10 * This program is distributed in the hope that it will be useful, *
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13 * GNU General Public License for more details. *
15 * You should have received a copy of the GNU General Public License *
16 * along with this program; if not, write to the *
17 * Free Software Foundation, Inc., *
18 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
19 ***************************************************************************/
21 #include <QCoreApplication>
24 #include "internalpeer.h"
26 using namespace Protocol;
29 class PeerMessageEvent : public QEvent
32 PeerMessageEvent(InternalPeer *sender, InternalPeer::EventType eventType, const T &message)
33 : QEvent(QEvent::Type(eventType)), sender(sender), message(message) {}
39 InternalPeer::InternalPeer(QObject *parent)
40 : SignalProxy::AbstractPeer(parent),
49 InternalPeer::~InternalPeer()
56 QString InternalPeer::description() const
58 return tr("internal connection");
62 bool InternalPeer::isOpen() const
68 bool InternalPeer::isSecure() const
74 bool InternalPeer::isLocal() const
80 void InternalPeer::close(const QString &reason)
84 qWarning() << "closing not implemented!";
88 int InternalPeer::lag() const
94 void InternalPeer::setSignalProxy(::SignalProxy *proxy)
96 if (!proxy && _proxy) {
105 if (proxy && !_proxy) {
110 qWarning() << Q_FUNC_INFO << "Changing the SignalProxy is not supported!";
114 void InternalPeer::setPeer(InternalPeer *peer)
117 qWarning() << Q_FUNC_INFO << "Peer already set, ignoring!";
121 connect(peer, SIGNAL(disconnected()), SLOT(peerDisconnected()));
125 void InternalPeer::peerDisconnected()
127 disconnect(_peer, 0, this, 0);
136 void InternalPeer::dispatch(const SyncMessage &msg)
138 dispatch(SyncMessageEvent, msg);
142 void InternalPeer::dispatch(const RpcCall &msg)
144 dispatch(RpcCallEvent, msg);
148 void InternalPeer::dispatch(const InitRequest &msg)
150 dispatch(InitRequestEvent, msg);
154 void InternalPeer::dispatch(const InitData &msg)
156 dispatch(InitDataEvent, msg);
161 void InternalPeer::dispatch(EventType eventType, const T &msg)
164 qWarning() << Q_FUNC_INFO << "Cannot dispatch a message without a peer!";
168 if(QThread::currentThread() == _peer->thread())
171 QCoreApplication::postEvent(_peer, new PeerMessageEvent<T>(this, eventType, msg));
176 void InternalPeer::handle(const T &msg)
179 qWarning() << Q_FUNC_INFO << "Cannot handle a message without having a signal proxy set!";
183 _proxy->handle(this, msg);
187 void InternalPeer::customEvent(QEvent *event)
189 switch ((int)event->type()) {
190 case SyncMessageEvent: {
191 PeerMessageEvent<SyncMessage> *e = static_cast<PeerMessageEvent<SyncMessage> *>(event);
196 PeerMessageEvent<RpcCall> *e = static_cast<PeerMessageEvent<RpcCall> *>(event);
200 case InitRequestEvent: {
201 PeerMessageEvent<InitRequest> *e = static_cast<PeerMessageEvent<InitRequest> *>(event);
205 case InitDataEvent: {
206 PeerMessageEvent<InitData> *e = static_cast<PeerMessageEvent<InitData> *>(event);
212 qWarning() << Q_FUNC_INFO << "Received unknown custom event:" << event->type();