X-Git-Url: https://git.quassel-irc.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcommon%2Fsignalproxy.h;h=be6b804bf8e0ac75e3c032a92c24ee35e7a89b95;hb=e625531efd04c0e77e540fbb1a0fc80457bc7aba;hp=b0933968f6fbdd51cfa4f3be042c02c487ffe650;hpb=1e7b6cda464041cac334b03a8b01679b4b9a56d3;p=quassel.git diff --git a/src/common/signalproxy.h b/src/common/signalproxy.h index b0933968..be6b804b 100644 --- a/src/common/signalproxy.h +++ b/src/common/signalproxy.h @@ -78,13 +78,39 @@ public: void dumpProxyStats(); void dumpSyncMap(SyncableObject *object); - void restrictTargetPeers(std::initializer_list peerIds, std::function closure); + /**@{*/ + /** + * This method allows to send a signal only to a limited set of peers + * @param peerIds A list of peers that should receive it + * @param closure Code you want to execute within of that restricted environment + */ + void restrictTargetPeers(QSet peers, std::function closure); + void restrictTargetPeers(Peer *peer, std::function closure) { + QSet set; + set.insert(peer); + restrictTargetPeers(set, std::move(closure)); + } + + //A better version, but only implemented on Qt5 if Initializer Lists exist +#if QT_VERSION >= QT_VERSION_CHECK(5, 0, 0) +#ifdef Q_COMPILER_INITIALIZER_LISTS + void restrictTargetPeers(std::initializer_list peers, std::function closure) { + restrictTargetPeers(QSet(peers), std::move(closure)); + } +#endif +#endif + /**}@*/ inline int peerCount() const { return _peers.size(); } QVariantList peerData(); Peer *peerById(int peerId); + /** + * @return If handling a signal, the Peer from which the current signal originates + */ + Peer *sourcePeer() { return _sourcePeer; } + public slots: void detachObject(QObject *obj); void detachSignals(QObject *sender); @@ -178,6 +204,8 @@ private: QSet _restrictedTargets; bool _restrictMessageTarget = false; + Peer *_sourcePeer; + friend class SignalRelay; friend class SyncableObject; friend class Peer;