/***************************************************************************
- * Copyright (C) 2005-2012 by the Quassel Project *
+ * Copyright (C) 2005-2013 by the Quassel Project *
* devel@quassel-irc.org *
* *
* This program is free software; you can redistribute it and/or modify *
#include <QEvent>
#include <QCoreApplication>
+#include "peer.h"
+#include "protocol.h"
#include "syncableobject.h"
#include "util.h"
+using namespace Protocol;
+
class RemovePeerEvent : public QEvent
{
public:
- RemovePeerEvent(SignalProxy::AbstractPeer *peer) : QEvent(QEvent::Type(SignalProxy::RemovePeerEvent)), peer(peer) {}
- SignalProxy::AbstractPeer *peer;
+ RemovePeerEvent(Peer *peer) : QEvent(QEvent::Type(SignalProxy::RemovePeerEvent)), peer(peer) {}
+ Peer *peer;
};
params << QVariant(argTypes[i], _a[i+1]);
}
- proxy()->dispatch(SignalProxy::RpcCall(signal.signature, params));
+ proxy()->dispatch(RpcCall(signal.signature, params));
}
_id -= _slots.count();
}
}
-bool SignalProxy::addPeer(AbstractPeer *peer)
+bool SignalProxy::addPeer(Peer *peer)
{
if (!peer)
return false;
{
Q_ASSERT(proxyMode() == Server || _peers.count() <= 1);
// wee need to copy that list since we modify it in the loop
- QSet<AbstractPeer *> peers = _peers;
- foreach(AbstractPeer *peer, peers) {
+ QSet<Peer *> peers = _peers;
+ foreach(Peer *peer, peers) {
removePeer(peer);
}
}
-void SignalProxy::removePeer(AbstractPeer *peer)
+void SignalProxy::removePeer(Peer *peer)
{
if (!peer) {
qWarning() << Q_FUNC_INFO << "Trying to remove a null peer!";
void SignalProxy::removePeerBySender()
{
- removePeer(qobject_cast<SignalProxy::AbstractPeer *>(sender()));
+ removePeer(qobject_cast<Peer *>(sender()));
}
template<class T>
void SignalProxy::dispatch(const T &protoMessage)
{
- foreach (AbstractPeer *peer, _peers) {
+ foreach (Peer *peer, _peers) {
if (peer->isOpen())
peer->dispatch(protoMessage);
else
}
-void SignalProxy::handle(SignalProxy::AbstractPeer *peer, const SignalProxy::SyncMessage &syncMessage)
+void SignalProxy::handle(Peer *peer, const SyncMessage &syncMessage)
{
if (!_syncSlave.contains(syncMessage.className()) || !_syncSlave[syncMessage.className()].contains(syncMessage.objectName())) {
qWarning() << QString("no registered receiver for sync call: %1::%2 (objectName=\"%3\"). Params are:").arg(syncMessage.className(), syncMessage.slotName(), syncMessage.objectName())
}
-void SignalProxy::handle(SignalProxy::AbstractPeer *peer, const SignalProxy::InitRequest &initRequest)
+void SignalProxy::handle(Peer *peer, const InitRequest &initRequest)
{
if (!_syncSlave.contains(initRequest.className())) {
qWarning() << "SignalProxy::handleInitRequest() received initRequest for unregistered Class:"
}
-void SignalProxy::handle(SignalProxy::AbstractPeer *peer, const SignalProxy::InitData &initData)
+void SignalProxy::handle(Peer *peer, const InitData &initData)
{
Q_UNUSED(peer)
}
-void SignalProxy::handle(SignalProxy::AbstractPeer *peer, const SignalProxy::RpcCall &rpcCall)
+void SignalProxy::handle(Peer *peer, const RpcCall &rpcCall)
{
Q_UNUSED(peer)
bool wasSecure = _secure;
_secure = !_peers.isEmpty();
- foreach (const AbstractPeer *peer, _peers) {
+ foreach (const Peer *peer, _peers) {
_secure &= peer->isSecure();
}