Egalware/EgtExecutor
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

EgtExecutor :

Browse Source 
- in Redis piccola correzione.
This commit is contained in:
Riccardo Elitropi
2025-12-11 08:10:30 +01:00
parent e177fd8ccd
commit 9d64ca5d39
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
EXE_Redis.cpp
+3 -3
View File
@@ -721,7 +721,7 @@ RedisPubSubUnsubMsgCallback( redisAsyncContext* ctx, void* r, void*)
++ LockedMessage.nCount ;
LockedMessage.sMessage = sMessage ;
LockedMessage.Lock.clear( memory_order_release) ;
LockedMessage.Lock.notify_all() ;
LockedMessage.Lock.notify_one() ;
}
}
else {
@@ -1259,7 +1259,7 @@ ExeRedisAsyncUnsubscribe( int nIdConnection, const string& sChannel)
// Elimino i Messaggi dalla mappa
for ( auto Iter = vAsyncRedisMessages.begin() ; Iter != vAsyncRedisMessages.end() ; ) {
if ( Iter->first.rfind( GetMessageMapKey( nIdConnection, "")) == 0)
if ( Iter->first.rfind( GetMessageMapKey( nIdConnection, sChannel)) == 0)
Iter = vAsyncRedisMessages.erase( Iter) ;
else
++ Iter ;
@@ -1378,7 +1378,7 @@ ExeRedisAsyncGetMessage( int nIdConnection, const string& sChannel, int& nCount,
nCount = LockedMessage.nCount ;
sMessage = LockedMessage.sMessage ;
LockedMessage.Lock.clear( memory_order_release) ;
LockedMessage.Lock.notify_all() ;
LockedMessage.Lock.notify_one() ;
}
return true ;