mbox-lock.c revision 43d32cbe60fdaef2699d99f1ca259053e9350411
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen/* Copyright (C) 2002-2007 Timo Sirainen */
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "lib.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "nfs-workarounds.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "mail-index-private.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "mbox-storage.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "mbox-file.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include "mbox-lock.h"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include <time.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include <stdlib.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include <unistd.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include <fcntl.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#include <sys/stat.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen#ifdef HAVE_FLOCK
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen# include <sys/file.h>
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#endif
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen/* 0.1 .. 0.2msec */
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#define LOCK_RANDOM_USLEEP_TIME (100000 + (unsigned int)rand() % 100000)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen/* lock methods to use in wanted order */
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#define DEFAULT_READ_LOCK_METHODS "fcntl"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#define DEFAULT_WRITE_LOCK_METHODS "dotlock fcntl"
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen/* lock timeout */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen#define MBOX_DEFAULT_LOCK_TIMEOUT (5*60)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen/* assume stale dotlock if mbox file hasn't changed for n seconds */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen#define DEFAULT_DOTLOCK_CHANGE_TIMEOUT (120)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenenum mbox_lock_type {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MBOX_LOCK_DOTLOCK,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MBOX_LOCK_DOTLOCK_TRY,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MBOX_LOCK_FCNTL,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MBOX_LOCK_FLOCK,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MBOX_LOCK_LOCKF,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MBOX_LOCK_COUNT
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen};
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstruct mbox_lock_context {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen struct mbox_mailbox *mbox;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen int lock_status[MBOX_LOCK_COUNT];
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen bool checked_file;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen int lock_type;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen bool dotlock_last_stale;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen bool fcntl_locked;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen};
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstruct mbox_lock_data {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen enum mbox_lock_type type;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen const char *name;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen int (*func)(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen};
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_dotlock(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_dotlock_try(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_fcntl(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#ifdef HAVE_FLOCK
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_flock(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time);
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen#else
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen# define mbox_lock_flock NULL
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#endif
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#ifdef HAVE_LOCKF
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainenstatic int mbox_lock_lockf(struct mbox_lock_context *ctx, int lock_type,
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen time_t max_wait_time);
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen#else
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen# define mbox_lock_lockf NULL
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen#endif
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainenstruct mbox_lock_data lock_data[] = {
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen { MBOX_LOCK_DOTLOCK, "dotlock", mbox_lock_dotlock },
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen { MBOX_LOCK_DOTLOCK_TRY, "dotlock_try", mbox_lock_dotlock_try },
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen { MBOX_LOCK_FCNTL, "fcntl", mbox_lock_fcntl },
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen { MBOX_LOCK_FLOCK, "flock", mbox_lock_flock },
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen { MBOX_LOCK_LOCKF, "lockf", mbox_lock_lockf },
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen { 0, NULL, NULL }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen};
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic bool lock_settings_initialized = FALSE;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic enum mbox_lock_type read_locks[MBOX_LOCK_COUNT+1];
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic enum mbox_lock_type write_locks[MBOX_LOCK_COUNT+1];
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int lock_timeout, dotlock_change_timeout;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_list(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time, int idx);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_unlock_files(struct mbox_lock_context *ctx);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic void mbox_read_lock_methods(const char *str, const char *env,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen enum mbox_lock_type *locks)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen enum mbox_lock_type type;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen const char *const *lock;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen int i, dest;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen for (lock = t_strsplit(str, " "), dest = 0; *lock != NULL; lock++) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (type = 0; lock_data[type].name != NULL; type++) {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (strcasecmp(*lock, lock_data[type].name) == 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen type = lock_data[type].type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen break;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen if (lock_data[type].name == NULL)
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen i_fatal("%s: Invalid value %s", env, *lock);
78fa3c578c14ee8a612f86cf73b6181c7f16463fTimo Sirainen if (lock_data[type].func == NULL) {
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen i_fatal("%s: Support for lock type %s "
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen "not compiled into binary", env, *lock);
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen for (i = 0; i < dest; i++) {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (locks[i] == type)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen i_fatal("%s: Duplicated value %s", env, *lock);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen /* @UNSAFE */
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen locks[dest++] = type;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen locks[dest] = (enum mbox_lock_type)-1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic void mbox_init_lock_settings(void)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen{
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen const char *str;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen int r, w;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen str = getenv("MBOX_READ_LOCKS");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (str == NULL) str = DEFAULT_READ_LOCK_METHODS;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen mbox_read_lock_methods(str, "MBOX_READ_LOCKS", read_locks);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
6d2b3ce2c6ef62334985ece4f0ab8b154e0e9560Timo Sirainen str = getenv("MBOX_WRITE_LOCKS");
6d2b3ce2c6ef62334985ece4f0ab8b154e0e9560Timo Sirainen if (str == NULL) str = DEFAULT_WRITE_LOCK_METHODS;
6d2b3ce2c6ef62334985ece4f0ab8b154e0e9560Timo Sirainen mbox_read_lock_methods(str, "MBOX_WRITE_LOCKS", write_locks);
6d2b3ce2c6ef62334985ece4f0ab8b154e0e9560Timo Sirainen
6d2b3ce2c6ef62334985ece4f0ab8b154e0e9560Timo Sirainen /* check that read/write list orders match. write_locks must contain
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen at least read_locks and possibly more. */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (r = w = 0; write_locks[w] != (enum mbox_lock_type)-1; w++) {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (read_locks[r] == (enum mbox_lock_type)-1)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen break;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (read_locks[r] == write_locks[w])
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen r++;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (read_locks[r] != (enum mbox_lock_type)-1) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen i_fatal("mbox read/write lock list settings are invalid. "
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen "Lock ordering must be the same with both, "
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen "and write locks must contain all read locks "
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen "(and possibly more)");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen str = getenv("MBOX_LOCK_TIMEOUT");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen lock_timeout = str == NULL ? MBOX_DEFAULT_LOCK_TIMEOUT : atoi(str);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen str = getenv("MBOX_DOTLOCK_CHANGE_TIMEOUT");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen dotlock_change_timeout = str == NULL ?
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen DEFAULT_DOTLOCK_CHANGE_TIMEOUT : atoi(str);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen lock_settings_initialized = TRUE;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_file_open_latest(struct mbox_lock_context *ctx, int lock_type)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen{
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen struct mbox_mailbox *mbox = ctx->mbox;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen struct stat st;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (ctx->checked_file || lock_type == F_UNLCK)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 0;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (mbox->mbox_fd != -1) {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if ((mbox->storage->storage.flags &
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MAIL_STORAGE_FLAG_NFS_FLUSH_STORAGE) != 0)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen nfs_flush_attr_cache(mbox->path);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (nfs_safe_stat(mbox->path, &st) < 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_set_syscall_error(mbox, "stat()");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return -1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (st.st_ino != mbox->mbox_ino ||
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen !CMP_DEV_T(st.st_dev, mbox->mbox_dev))
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen mbox_file_close(mbox);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox->mbox_fd == -1) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox_file_open(mbox) < 0)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen ctx->checked_file = TRUE;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 0;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic bool dotlock_callback(unsigned int secs_left, bool stale, void *context)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen{
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen struct mbox_lock_context *ctx = context;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen enum mbox_lock_type *lock_types;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen int i;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (stale && !ctx->dotlock_last_stale) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* get next index we wish to try locking. it's the one after
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen dotlocking. */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_types = ctx->lock_type == F_WRLCK ||
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen (ctx->lock_type == F_UNLCK &&
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->mbox->mbox_lock_type == F_WRLCK) ?
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen write_locks : read_locks;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (i = 0; lock_types[i] != (enum mbox_lock_type)-1; i++) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (lock_types[i] == MBOX_LOCK_DOTLOCK)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen break;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (lock_types[i] != (enum mbox_lock_type)-1 &&
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_types[i+1] != (enum mbox_lock_type)-1) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen i++;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox_lock_list(ctx, ctx->lock_type, 0, i) <= 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* we couldn't get fd lock -
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen it's really locked */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->dotlock_last_stale = TRUE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return FALSE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen (void)mbox_lock_list(ctx, F_UNLCK, 0, i);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->dotlock_last_stale = stale;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen index_storage_lock_notify(&ctx->mbox->ibox, stale ?
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAILBOX_LOCK_NOTIFY_MAILBOX_OVERRIDE :
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAILBOX_LOCK_NOTIFY_MAILBOX_ABORT,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen secs_left);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return TRUE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen}
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic int
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenmbox_lock_dotlock_int(struct mbox_lock_context *ctx, int lock_type, bool try)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen struct mbox_mailbox *mbox = ctx->mbox;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen struct dotlock_settings set;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen int ret;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (lock_type == F_UNLCK) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (!mbox->mbox_dotlocked)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (file_dotlock_delete(&mbox->mbox_dotlock) <= 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_set_syscall_error(mbox, "file_dotlock_delete()");
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ret = -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox->mbox_dotlocked = FALSE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox->mbox_dotlocked)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->dotlock_last_stale = -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen memset(&set, 0, sizeof(set));
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen set.use_excl_lock = (mbox->storage->storage.flags &
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAIL_STORAGE_FLAG_DOTLOCK_USE_EXCL) != 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen set.timeout = lock_timeout;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen set.stale_timeout = dotlock_change_timeout;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen set.callback = dotlock_callback;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen set.context = ctx;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ret = file_dotlock_create(&set, mbox->path, 0, &mbox->mbox_dotlock);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (ret < 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if ((ENOSPACE(errno) || errno == EACCES) && try)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen mbox_set_syscall_error(mbox, "file_lock_dotlock()");
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return -1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (ret == 0) {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen mail_storage_set_error(&mbox->storage->storage,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen MAIL_ERROR_TEMP, MAIL_ERRSTR_LOCK_TIMEOUT);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 0;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen mbox->mbox_dotlocked = TRUE;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (mbox_file_open_latest(ctx, lock_type) < 0)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return -1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_dotlock(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time ATTR_UNUSED)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen{
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return mbox_lock_dotlock_int(ctx, lock_type, FALSE);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_dotlock_try(struct mbox_lock_context *ctx, int lock_type,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t max_wait_time ATTR_UNUSED)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return mbox_lock_dotlock_int(ctx, lock_type, TRUE);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen}
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen#ifdef HAVE_FLOCK
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic int mbox_lock_flock(struct mbox_lock_context *ctx, int lock_type,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t max_wait_time)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t now, last_notify;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox_file_open_latest(ctx, lock_type) < 0)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (lock_type == F_UNLCK && ctx->mbox->mbox_fd == -1)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (lock_type == F_WRLCK)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_type = LOCK_EX;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen else if (lock_type == F_RDLCK)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_type = LOCK_SH;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen else
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_type = LOCK_UN;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen last_notify = 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen while (flock(ctx->mbox->mbox_fd, lock_type | LOCK_NB) < 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (errno != EWOULDBLOCK) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_set_syscall_error(ctx->mbox, "flock()");
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen now = time(NULL);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (now >= max_wait_time)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (now != last_notify) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen index_storage_lock_notify(&ctx->mbox->ibox,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAILBOX_LOCK_NOTIFY_MAILBOX_ABORT,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen max_wait_time - now);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen usleep(LOCK_RANDOM_USLEEP_TIME);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen }
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen}
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#endif
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen#ifdef HAVE_LOCKF
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainenstatic int mbox_lock_lockf(struct mbox_lock_context *ctx, int lock_type,
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen time_t max_wait_time)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t now, last_notify;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox_file_open_latest(ctx, lock_type) < 0)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (lock_type == F_UNLCK && ctx->mbox->mbox_fd == -1)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (lock_type != F_UNLCK)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen lock_type = F_TLOCK;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen else
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen lock_type = F_ULOCK;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen last_notify = 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen while (lockf(ctx->mbox->mbox_fd, lock_type, 0) < 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (errno != EAGAIN) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_set_syscall_error(ctx->mbox, "lockf()");
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen now = time(NULL);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (now >= max_wait_time)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (now != last_notify) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen index_storage_lock_notify(&ctx->mbox->ibox,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAILBOX_LOCK_NOTIFY_MAILBOX_ABORT,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen max_wait_time - now);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen usleep(LOCK_RANDOM_USLEEP_TIME);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen}
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen#endif
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic int mbox_lock_fcntl(struct mbox_lock_context *ctx, int lock_type,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t max_wait_time)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen struct flock fl;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t now;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen unsigned int next_alarm;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen int wait_type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox_file_open_latest(ctx, lock_type) < 0)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (lock_type == F_UNLCK && ctx->mbox->mbox_fd == -1)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen return 1;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen memset(&fl, 0, sizeof(fl));
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen fl.l_type = lock_type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen fl.l_whence = SEEK_SET;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen fl.l_start = 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen fl.l_len = 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (max_wait_time == 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* usually we're waiting here, but if we came from
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_lock_dotlock(), we just want to try locking */
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen wait_type = F_SETLK;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen } else {
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen wait_type = F_SETLKW;
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen now = time(NULL);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen if (now >= max_wait_time)
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen alarm(1);
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen else
8d3278a82b964217d95c340ec6f82037cdc59d19Timo Sirainen alarm(I_MIN(max_wait_time - now, 5));
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen while (fcntl(ctx->mbox->mbox_fd, wait_type, &fl) < 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (errno != EINTR) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if ((errno == EACCES || errno == EAGAIN) &&
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen wait_type == F_SETLK) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* non-blocking lock trying failed */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_set_syscall_error(ctx->mbox, "fcntl()");
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen alarm(0);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return -1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen now = time(NULL);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (now >= max_wait_time) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen alarm(0);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* notify locks once every 5 seconds.
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen try to use rounded values. */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen next_alarm = (max_wait_time - now) % 5;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (next_alarm == 0)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen next_alarm = 5;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen alarm(next_alarm);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen index_storage_lock_notify(&ctx->mbox->ibox,
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen MAILBOX_LOCK_NOTIFY_MAILBOX_ABORT,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen max_wait_time - now);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen alarm(0);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->fcntl_locked = TRUE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen}
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic int mbox_lock_list(struct mbox_lock_context *ctx, int lock_type,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t max_wait_time, int idx)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen enum mbox_lock_type *lock_types;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen enum mbox_lock_type type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen int i, ret = 0, lock_status;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx->lock_type = lock_type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_types = lock_type == F_WRLCK ||
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen (lock_type == F_UNLCK && ctx->mbox->mbox_lock_type == F_WRLCK) ?
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen write_locks : read_locks;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (i = idx; lock_types[i] != (enum mbox_lock_type)-1; i++) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen type = lock_types[i];
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen lock_status = lock_type != F_UNLCK;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen if (ctx->lock_status[type] == lock_status)
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen continue;
7487ff578435377bbeefffdbfb78ca09ed1292dfTimo Sirainen ctx->lock_status[type] = lock_status;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ret = lock_data[type].func(ctx, lock_type, max_wait_time);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (ret <= 0)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen break;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return ret;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen}
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainenstatic int mbox_update_locking(struct mbox_mailbox *mbox, int lock_type,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen bool *fcntl_locked_r)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen{
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen struct mbox_lock_context ctx;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen time_t max_wait_time;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen int ret, i;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen bool drop_locks;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen *fcntl_locked_r = FALSE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen index_storage_lock_notify_reset(&mbox->ibox);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (!lock_settings_initialized)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox_init_lock_settings();
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox->mbox_fd == -1 && mbox->mbox_file_stream != NULL) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* read-only mbox stream. no need to lock. */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen i_assert(mbox->mbox_readonly);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox->mbox_lock_type = lock_type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen max_wait_time = time(NULL) + lock_timeout;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen memset(&ctx, 0, sizeof(ctx));
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx.mbox = mbox;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (mbox->mbox_lock_type == F_WRLCK) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen /* dropping to shared lock. first drop those that we
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen don't remove completely. */
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (i = 0; i < MBOX_LOCK_COUNT; i++)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx.lock_status[i] = 1;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen for (i = 0; read_locks[i] != (enum mbox_lock_type)-1; i++)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ctx.lock_status[read_locks[i]] = 0;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen drop_locks = TRUE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen } else {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen drop_locks = FALSE;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mbox->mbox_lock_type = lock_type;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen ret = mbox_lock_list(&ctx, lock_type, max_wait_time, 0);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (ret <= 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (!drop_locks)
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen (void)mbox_unlock_files(&ctx);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (ret == 0) {
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen mail_storage_set_error(&mbox->storage->storage,
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen MAIL_ERROR_TEMP, MAIL_ERRSTR_LOCK_TIMEOUT);
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen return ret;
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen }
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen
d176f84ce5ca2073f4dfbafb457b9c74f6bf0d76Timo Sirainen if (drop_locks) {
/* dropping to shared lock: drop the locks that are only
in write list */
memset(ctx.lock_status, 0, sizeof(ctx.lock_status));
for (i = 0; write_locks[i] != (enum mbox_lock_type)-1; i++)
ctx.lock_status[write_locks[i]] = 1;
for (i = 0; read_locks[i] != (enum mbox_lock_type)-1; i++)
ctx.lock_status[read_locks[i]] = 0;
mbox->mbox_lock_type = F_WRLCK;
(void)mbox_lock_list(&ctx, F_UNLCK, 0, 0);
mbox->mbox_lock_type = F_RDLCK;
}
*fcntl_locked_r = ctx.fcntl_locked;
return 1;
}
int mbox_lock(struct mbox_mailbox *mbox, int lock_type,
unsigned int *lock_id_r)
{
bool fcntl_locked;
int ret;
/* allow only unlock -> shared/exclusive or exclusive -> shared */
i_assert(lock_type == F_RDLCK || lock_type == F_WRLCK);
i_assert(lock_type == F_RDLCK || mbox->mbox_lock_type != F_RDLCK);
/* mbox must be locked before index */
i_assert(mbox->ibox.index->lock_type != F_WRLCK);
if (mbox->mbox_lock_type == F_UNLCK) {
ret = mbox_update_locking(mbox, lock_type, &fcntl_locked);
if (ret <= 0)
return ret;
if ((mbox->storage->storage.flags &
MAIL_STORAGE_FLAG_NFS_FLUSH_STORAGE) != 0) {
nfs_flush_read_cache(mbox->path, mbox->mbox_fd,
fcntl_locked ? lock_type : F_UNLCK,
fcntl_locked);
}
mbox->mbox_lock_id += 2;
}
if (lock_type == F_RDLCK) {
mbox->mbox_shared_locks++;
*lock_id_r = mbox->mbox_lock_id;
} else {
mbox->mbox_excl_locks++;
*lock_id_r = mbox->mbox_lock_id + 1;
}
return 1;
}
static int mbox_unlock_files(struct mbox_lock_context *ctx)
{
int ret = 0;
if (mbox_lock_list(ctx, F_UNLCK, 0, 0) < 0)
ret = -1;
ctx->mbox->mbox_lock_id += 2;
ctx->mbox->mbox_lock_type = F_UNLCK;
return ret;
}
int mbox_unlock(struct mbox_mailbox *mbox, unsigned int lock_id)
{
struct mbox_lock_context ctx;
bool fcntl_locked;
int i;
i_assert(mbox->mbox_lock_id == (lock_id & ~1));
if (lock_id & 1) {
/* dropping exclusive lock */
i_assert(mbox->mbox_excl_locks > 0);
if (--mbox->mbox_excl_locks > 0)
return 0;
if (mbox->mbox_shared_locks > 0) {
/* drop to shared lock */
if (mbox_update_locking(mbox, F_RDLCK,
&fcntl_locked) < 0)
return -1;
return 0;
}
} else {
/* dropping shared lock */
i_assert(mbox->mbox_shared_locks > 0);
if (--mbox->mbox_shared_locks > 0)
return 0;
if (mbox->mbox_excl_locks > 0)
return 0;
}
/* all locks gone */
memset(&ctx, 0, sizeof(ctx));
ctx.mbox = mbox;
for (i = 0; i < MBOX_LOCK_COUNT; i++)
ctx.lock_status[i] = 1;
return mbox_unlock_files(&ctx);
}