mirrors
/
redis
mirror of https://mirror.osredm.com/root/redis.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Count threaded exec time in stats.

This commit is contained in:
antirez 2025-03-26 16:48:02 +01:00
parent 08e3f958fa
commit 707c132392
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
vset.c
View File

@ -327,6 +327,7 @@ void *VADD_thread(void *arg) {
/* Unblock the client so that our read reply will be invoked. */ /* Unblock the client so that our read reply will be invoked. */
pthread_rwlock_unlock(&vset->in_use_lock); pthread_rwlock_unlock(&vset->in_use_lock);
RedisModule_BlockedClientMeasureTimeEnd(bc);
RedisModule_UnblockClient(bc,targ); // Use targ as privdata. RedisModule_UnblockClient(bc,targ); // Use targ as privdata.
return NULL; return NULL;
} }
@ -609,6 +610,7 @@ int VADD_RedisCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {
targ[7] = attrib; targ[7] = attrib;
RedisModule_RetainString(ctx,val); RedisModule_RetainString(ctx,val);
if (attrib) RedisModule_RetainString(ctx,attrib); if (attrib) RedisModule_RetainString(ctx,attrib);
RedisModule_BlockedClientMeasureTimeStart(bc);
if (pthread_create(&tid,NULL,VADD_thread,targ) != 0) { if (pthread_create(&tid,NULL,VADD_thread,targ) != 0) {
pthread_rwlock_unlock(&vset->in_use_lock); pthread_rwlock_unlock(&vset->in_use_lock);
RedisModule_AbortBlock(bc); RedisModule_AbortBlock(bc);
@ -741,6 +743,7 @@ void *VSIM_thread(void *arg) {
// Cleanup. // Cleanup.
RedisModule_FreeThreadSafeContext(ctx); RedisModule_FreeThreadSafeContext(ctx);
pthread_rwlock_unlock(&vset->in_use_lock); pthread_rwlock_unlock(&vset->in_use_lock);
RedisModule_BlockedClientMeasureTimeEnd(bc);
RedisModule_UnblockClient(bc,NULL); RedisModule_UnblockClient(bc,NULL);
return NULL; return NULL;
} }
@ -958,6 +961,7 @@ int VSIM_RedisCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {
targ[7] = (void*)filter_expr; targ[7] = (void*)filter_expr;
targ[8] = (void*)(unsigned long)filter_ef; targ[8] = (void*)(unsigned long)filter_ef;
targ[9] = (void*)(unsigned long)ground_truth; targ[9] = (void*)(unsigned long)ground_truth;
RedisModule_BlockedClientMeasureTimeStart(bc);
if (pthread_create(&tid,NULL,VSIM_thread,targ) != 0) { if (pthread_create(&tid,NULL,VSIM_thread,targ) != 0) {
pthread_rwlock_unlock(&vset->in_use_lock); pthread_rwlock_unlock(&vset->in_use_lock);
RedisModule_AbortBlock(bc); RedisModule_AbortBlock(bc);