1 /***************************************************************************
2 * Copyright (C) 2005-2016 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)
45 setFeatures(Quassel::Features{});
49 InternalPeer::~InternalPeer()
56 QString InternalPeer::description() const
58 return tr("internal connection");
61 QString InternalPeer::address() const
63 return tr("internal connection");
66 quint16 InternalPeer::port() const
71 bool InternalPeer::isOpen() const
77 bool InternalPeer::isSecure() const
83 bool InternalPeer::isLocal() const
89 void InternalPeer::close(const QString &reason)
93 qWarning() << "closing not implemented!";
97 int InternalPeer::lag() const
103 ::SignalProxy *InternalPeer::signalProxy() const
109 void InternalPeer::setSignalProxy(::SignalProxy *proxy)
111 if (!proxy && _proxy) {
120 if (proxy && !_proxy) {
125 qWarning() << Q_FUNC_INFO << "Changing the SignalProxy is not supported!";
129 void InternalPeer::setPeer(InternalPeer *peer)
132 qWarning() << Q_FUNC_INFO << "Peer already set, ignoring!";
136 connect(peer, SIGNAL(disconnected()), SLOT(peerDisconnected()));
140 void InternalPeer::peerDisconnected()
142 disconnect(_peer, 0, this, 0);
151 void InternalPeer::dispatch(const SyncMessage &msg)
153 dispatch(SyncMessageEvent, msg);
157 void InternalPeer::dispatch(const RpcCall &msg)
159 dispatch(RpcCallEvent, msg);
163 void InternalPeer::dispatch(const InitRequest &msg)
165 dispatch(InitRequestEvent, msg);
169 void InternalPeer::dispatch(const InitData &msg)
171 dispatch(InitDataEvent, msg);
176 void InternalPeer::dispatch(EventType eventType, const T &msg)
179 qWarning() << Q_FUNC_INFO << "Cannot dispatch a message without a peer!";
183 if(QThread::currentThread() == _peer->thread())
186 QCoreApplication::postEvent(_peer, new PeerMessageEvent<T>(this, eventType, msg));
190 void InternalPeer::customEvent(QEvent *event)
192 switch ((int)event->type()) {
193 case SyncMessageEvent: {
194 PeerMessageEvent<SyncMessage> *e = static_cast<PeerMessageEvent<SyncMessage> *>(event);
199 PeerMessageEvent<RpcCall> *e = static_cast<PeerMessageEvent<RpcCall> *>(event);
203 case InitRequestEvent: {
204 PeerMessageEvent<InitRequest> *e = static_cast<PeerMessageEvent<InitRequest> *>(event);
208 case InitDataEvent: {
209 PeerMessageEvent<InitData> *e = static_cast<PeerMessageEvent<InitData> *>(event);
215 qWarning() << Q_FUNC_INFO << "Received unknown custom event:" << event->type();