pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add function sf_synchronize_counter_wait

storage_engine
YuQing 2021-10-12 10:54:30 +08:00
parent 0eb483f68c
commit cccb1c6d23
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/sf_func.h
View File

@ -19,6 +19,7 @@
#define _SF_FUNC_H
#include "fastcommon/pthread_func.h"
#include "fastcommon/fc_atomic.h"
#include "sf_types.h"
#include "sf_global.h"
@ -71,9 +72,19 @@ static inline void sf_binlog_buffer_destroy(SFBinlogBuffer *buffer)
static inline int sf_synchronize_ctx_init(SFSynchronizeContext *sctx)
{
sctx->waiting_count = 0;
return init_pthread_lock_cond_pair(&sctx->lcp);
}
static inline void sf_synchronize_counter_wait(SFSynchronizeContext *sctx)
{
PTHREAD_MUTEX_LOCK(&sctx->lcp.lock);
while (FC_ATOMIC_GET(sctx->waiting_count) != 0) {
pthread_cond_wait(&sctx->lcp.cond, &sctx->lcp.lock);
}
PTHREAD_MUTEX_UNLOCK(&sctx->lcp.lock);
}
#ifdef __cplusplus
}
#endif

1
src/sf_types.h
View File

@ -240,6 +240,7 @@ typedef struct sf_synchronize_context {
union {
bool done;
int result;
volatile int waiting_count;
};
} SFSynchronizeContext;