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)
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 ::SignalProxy *InternalPeer::signalProxy() const
100 void InternalPeer::setSignalProxy(::SignalProxy *proxy)
102 if (!proxy && _proxy) {
111 if (proxy && !_proxy) {
116 qWarning() << Q_FUNC_INFO << "Changing the SignalProxy is not supported!";
120 void InternalPeer::setPeer(InternalPeer *peer)
123 qWarning() << Q_FUNC_INFO << "Peer already set, ignoring!";
127 connect(peer, SIGNAL(disconnected()), SLOT(peerDisconnected()));
131 void InternalPeer::peerDisconnected()
133 disconnect(_peer, 0, this, 0);
142 void InternalPeer::dispatch(const SyncMessage &msg)
144 dispatch(SyncMessageEvent, msg);
148 void InternalPeer::dispatch(const RpcCall &msg)
150 dispatch(RpcCallEvent, msg);
154 void InternalPeer::dispatch(const InitRequest &msg)
156 dispatch(InitRequestEvent, msg);
160 void InternalPeer::dispatch(const InitData &msg)
162 dispatch(InitDataEvent, msg);
167 void InternalPeer::dispatch(EventType eventType, const T &msg)
170 qWarning() << Q_FUNC_INFO << "Cannot dispatch a message without a peer!";
174 if(QThread::currentThread() == _peer->thread())
177 QCoreApplication::postEvent(_peer, new PeerMessageEvent<T>(this, eventType, msg));
181 void InternalPeer::customEvent(QEvent *event)
183 switch ((int)event->type()) {
184 case SyncMessageEvent: {
185 PeerMessageEvent<SyncMessage> *e = static_cast<PeerMessageEvent<SyncMessage> *>(event);
190 PeerMessageEvent<RpcCall> *e = static_cast<PeerMessageEvent<RpcCall> *>(event);
194 case InitRequestEvent: {
195 PeerMessageEvent<InitRequest> *e = static_cast<PeerMessageEvent<InitRequest> *>(event);
199 case InitDataEvent: {
200 PeerMessageEvent<InitData> *e = static_cast<PeerMessageEvent<InitData> *>(event);
206 qWarning() << Q_FUNC_INFO << "Received unknown custom event:" << event->type();