***************************************************************************/
#include "internalpeer.h"
+#include "util.h"
using namespace Protocol;
bool InternalPeer::isOpen() const
{
- return true;
+ return _isOpen;
}
void InternalPeer::close(const QString &reason)
{
- // FIXME
- Q_UNUSED(reason)
- qWarning() << "closing not implemented!";
+ Q_UNUSED(reason);
+ _isOpen = false;
}
if (proxy && !_proxy) {
_proxy = proxy;
+ _isOpen = true;
return;
}
void InternalPeer::setPeer(InternalPeer *peer)
{
- connect(peer, SIGNAL(dispatchMessage(Protocol::SyncMessage)), SLOT(handleMessage(Protocol::SyncMessage)));
- connect(peer, SIGNAL(dispatchMessage(Protocol::RpcCall)) , SLOT(handleMessage(Protocol::RpcCall)));
- connect(peer, SIGNAL(dispatchMessage(Protocol::InitRequest)), SLOT(handleMessage(Protocol::InitRequest)));
- connect(peer, SIGNAL(dispatchMessage(Protocol::InitData)) , SLOT(handleMessage(Protocol::InitData)));
+ connect(peer, selectOverload<const Protocol::SyncMessage&>(&InternalPeer::dispatchMessage),
+ this, selectOverload<const Protocol::SyncMessage&>(&InternalPeer::handleMessage));
+ connect(peer, selectOverload<const Protocol::RpcCall&>(&InternalPeer::dispatchMessage),
+ this, selectOverload<const Protocol::RpcCall&>(&InternalPeer::handleMessage));
+ connect(peer, selectOverload<const Protocol::InitRequest&>(&InternalPeer::dispatchMessage),
+ this, selectOverload<const Protocol::InitRequest&>(&InternalPeer::handleMessage));
+ connect(peer, selectOverload<const Protocol::InitData&>(&InternalPeer::dispatchMessage),
+ this, selectOverload<const Protocol::InitData&>(&InternalPeer::handleMessage));
- connect(peer, SIGNAL(disconnected()), SLOT(peerDisconnected()));
+ connect(peer, &Peer::disconnected, this, &InternalPeer::peerDisconnected);
_isOpen = true;
}