mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
Fix subscribing to "real time" transactions.
This commit is contained in:
@@ -2742,14 +2742,14 @@ bool NetworkOPsImp::unsubTransactions (uint64 uSeq)
|
||||
bool NetworkOPsImp::subRTTransactions (InfoSub::ref isrListener)
|
||||
{
|
||||
ScopedLockType sl (mLock, __FILE__, __LINE__);
|
||||
return mSubTransactions.emplace (isrListener->getSeq (), isrListener).second;
|
||||
return mSubRTTransactions.emplace (isrListener->getSeq (), isrListener).second;
|
||||
}
|
||||
|
||||
// <-- bool: true=erased, false=was not there
|
||||
bool NetworkOPsImp::unsubRTTransactions (uint64 uSeq)
|
||||
{
|
||||
ScopedLockType sl (mLock, __FILE__, __LINE__);
|
||||
return !!mSubTransactions.erase (uSeq);
|
||||
return !!mSubRTTransactions.erase (uSeq);
|
||||
}
|
||||
|
||||
InfoSub::pointer NetworkOPsImp::findRpcSub (const std::string& strUrl)
|
||||
|
||||
Reference in New Issue
Block a user