static void mbox_read_lock_methods(const char *str, const char *env,
enum mbox_lock_type *locks)
{
- enum mbox_lock_type type;
+ enum mbox_lock_type type;
const char *const *lock;
int i, dest;
memcpy(storage->write_locks, write_locks,
sizeof(*storage->write_locks) * (MBOX_LOCK_COUNT+1));
- storage->lock_settings_initialized = TRUE;
+ storage->lock_settings_initialized = TRUE;
}
static int mbox_file_open_latest(struct mbox_lock_context *ctx, int lock_type)
static bool dotlock_callback(unsigned int secs_left, bool stale, void *context)
{
- struct mbox_lock_context *ctx = context;
+ struct mbox_lock_context *ctx = context;
enum mbox_lock_type *lock_types;
int i;
MBOX_DOTLOCK_OP_UNLOCK);
ctx->using_privileges = FALSE;
}
- mbox->mbox_dotlocked = FALSE;
+ mbox->mbox_dotlocked = FALSE;
return 1;
}
if (mbox->mbox_dotlocked)
return 1;
- ctx->dotlock_last_stale = TRUE;
+ ctx->dotlock_last_stale = TRUE;
i_zero(&set);
set.use_excl_lock = mbox->storage->storage.set->dotlock_use_excl;
time_t max_wait_time, int idx)
{
enum mbox_lock_type *lock_types;
- enum mbox_lock_type type;
+ enum mbox_lock_type type;
int i, ret = 0;
bool locked_status;
*fcntl_locked_r = FALSE;
- index_storage_lock_notify_reset(&mbox->box);
+ index_storage_lock_notify_reset(&mbox->box);
if (!mbox->storage->lock_settings_initialized)
- mbox_init_lock_settings(mbox->storage);
+ mbox_init_lock_settings(mbox->storage);
if (mbox->mbox_fd == -1 && mbox->mbox_file_stream != NULL) {
/* read-only mbox stream. no need to lock. */
/* dropping to shared lock. first drop those that we
don't remove completely. */
const enum mbox_lock_type *read_locks =
- mbox->storage->read_locks;
+ mbox->storage->read_locks;
for (i = 0; i < MBOX_LOCK_COUNT; i++)
ctx.locked_status[i] = TRUE;
/* dropping to shared lock: drop the locks that are only
in write list */
const enum mbox_lock_type *read_locks =
- mbox->storage->read_locks;
+ mbox->storage->read_locks;
const enum mbox_lock_type *write_locks =
mbox->storage->write_locks;