struct io_logs *p;
p = calloc(1, sizeof(*l->pending));
- p->max_samples = l->td->o.iodepth;
+ p->max_samples = DEF_LOG_ENTRIES;
p->log = calloc(p->max_samples, log_entry_sz(l));
l->pending = p;
}
if (l->log_gz && !p->td)
l->log_gz = 0;
else if (l->log_gz || l->log_gz_store) {
- pthread_mutex_init(&l->chunk_lock, NULL);
+ mutex_init_pshared(&l->chunk_lock);
p->td->flags |= TD_F_COMPRESS_LOG;
}