#define DBOX_READ_BLOCK_SIZE 4096
-#if DBOX_FILE_LOCK_METHOD == FILE_LOCK_METHOD_DOTLOCK
+#ifndef DBOX_FILE_LOCK_METHOD_FLOCK
static const struct dotlock_settings dotlock_set = {
.stale_timeout = 60*10,
.use_excl_lock = TRUE
i_assert(file->fd != -1);
-#if DBOX_FILE_LOCK_METHOD == FILE_LOCK_METHOD_DOTLOCK
- ret = file_dotlock_create(&dotlock_set, file->cur_path,
- DOTLOCK_CREATE_FLAG_NONBLOCK, &file->lock);
+#ifdef DBOX_FILE_LOCK_METHOD_FLOCK
+ ret = file_try_lock(file->fd, file->cur_path, F_WRLCK,
+ FILE_LOCK_METHOD_FLOCK, &file->lock);
if (ret < 0) {
mail_storage_set_critical(&file->storage->storage,
- "file_dotlock_create(%s) failed: %m", file->cur_path);
+ "file_try_lock(%s) failed: %m", file->cur_path);
}
#else
- ret = file_try_lock(file->fd, file->cur_path, F_WRLCK,
- DBOX_FILE_LOCK_METHOD, &file->lock);
+ ret = file_dotlock_create(&dotlock_set, file->cur_path,
+ DOTLOCK_CREATE_FLAG_NONBLOCK, &file->lock);
if (ret < 0) {
mail_storage_set_critical(&file->storage->storage,
- "file_try_lock(%s) failed: %m", file->cur_path);
+ "file_dotlock_create(%s) failed: %m", file->cur_path);
}
#endif
return ret;
i_assert(!file->appending || file->lock == NULL);
if (file->lock != NULL) {
-#if DBOX_FILE_LOCK_METHOD == FILE_LOCK_METHOD_DOTLOCK
- (void)file_dotlock_delete(&file->lock);
-#else
+#ifdef DBOX_FILE_LOCK_METHOD_FLOCK
file_unlock(&file->lock);
+#else
+ (void)file_dotlock_delete(&file->lock);
#endif
}
if (file->input != NULL)
same file from multiple mail_storages within same process. that's why we
fallback to dotlocks. */
#ifdef HAVE_FLOCK
-# define DBOX_FILE_LOCK_METHOD FILE_LOCK_METHOD_FLOCK
-#else
-# define DBOX_FILE_LOCK_METHOD FILE_LOCK_METHOD_DOTLOCK
+# define DBOX_FILE_LOCK_METHOD_FLOCK
#endif
struct dbox_file;
char *primary_path, *alt_path;
int fd;
struct istream *input;
-#if DBOX_FILE_LOCK_METHOD == FILE_LOCK_METHOD_DOTLOCK
- struct dotlock *lock;
-#else
+#ifdef DBOX_FILE_LOCK_METHOD_FLOCK
struct file_lock *lock;
+#else
+ struct dotlock *lock;
#endif
uoff_t cur_offset;