* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. *
***************************************************************************/
-#include "signalproxy.h"
-
-#include <QObject>
-#include <QIODevice>
-#include <QAbstractSocket>
+#include <QCoreApplication>
#include <QHostAddress>
-#include <QHash>
-#include <QMultiHash>
-#include <QList>
-#include <QSet>
-#include <QDebug>
#include <QMetaMethod>
#include <QMetaProperty>
-#include <QRegExp>
+#include <QThread>
+
#ifdef HAVE_SSL
-#include <QSslSocket>
+ #include <QSslSocket>
#endif
-#include <QThread>
-#include <QTime>
-#include <QEvent>
-#include <QCoreApplication>
+#include "signalproxy.h"
+
+#include "peer.h"
#include "protocol.h"
#include "syncableobject.h"
#include "util.h"
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;
};
}
-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 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 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 InitData &initData)
+void SignalProxy::handle(Peer *peer, const InitData &initData)
{
Q_UNUSED(peer)
}
-void SignalProxy::handle(SignalProxy::AbstractPeer *peer, const 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();
}