void fr_cbuff_rp_insert(fr_cbuff_t *cbuff, void *obj)
{
#ifdef HAVE_PTHREAD_H
- if (cbuff->lock) {
- PTHREAD_MUTEX_LOCK(cbuff);
- }
+ if (cbuff->lock) PTHREAD_MUTEX_LOCK(cbuff);
#endif
if (cbuff->elem[cbuff->in]) {
}
#ifdef HAVE_PTHREAD_H
- if (cbuff->lock) {
- PTHREAD_MUTEX_UNLOCK(cbuff);
- }
+ if (cbuff->lock) PTHREAD_MUTEX_UNLOCK(cbuff);
#endif
}
void *fr_cbuff_rp_next(fr_cbuff_t *cbuff, TALLOC_CTX *ctx)
{
void *obj = NULL;
+
#ifdef HAVE_PTHREAD_H
- if (cbuff->lock) {
- PTHREAD_MUTEX_LOCK(cbuff);
- }
+ if (cbuff->lock) PTHREAD_MUTEX_LOCK(cbuff);
#endif
/* Buffer is empty */
done:
#ifdef HAVE_PTHREAD_H
- if (cbuff->lock) {
- PTHREAD_MUTEX_UNLOCK(cbuff);
- }
+ if (cbuff->lock) PTHREAD_MUTEX_UNLOCK(cbuff);
#endif
return obj;
}