Searched defs:atomic (Results 1 - 7 of 7) sorted by relevance

/dovecot/src/lib-storage/index/dbox-multi/
H A Dmdbox-sync.h21 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_sync_context
29 struct mdbox_map_atomic_context *atomic,
H A Dmdbox-map-private.h34 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_map_append_context
H A Dmdbox-sync.c159 if (mdbox_map_atomic_is_locked(ctx->atomic)) {
160 ctx->map_trans = mdbox_map_transaction_begin(ctx->atomic, FALSE);
170 if (mdbox_map_atomic_is_locked(ctx->atomic)) {
180 mdbox_map_atomic_set_failed(ctx->atomic);
206 if (!mdbox_map_atomic_is_locked(ctx->atomic) &&
214 if (mdbox_map_atomic_lock(ctx->atomic, "mdbox syncing with expunges") < 0)
222 struct mdbox_map_atomic_context *atomic,
242 if (mdbox_storage_rebuild_in_context(mbox->storage, atomic) < 0)
251 ctx->atomic = atomic;
221 mdbox_sync_begin(struct mdbox_mailbox *mbox, enum mdbox_sync_flags flags, struct mdbox_map_atomic_context *atomic, struct mdbox_sync_context **ctx_r) argument
336 struct mdbox_map_atomic_context *atomic; local
[all...]
H A Dmdbox-save.c41 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_save_context
120 ctx->atomic = mdbox_map_atomic_begin(mbox->storage->map);
121 ctx->append_ctx = mdbox_map_append_begin(ctx->atomic);
293 if (mdbox_map_atomic_lock(ctx->atomic, "saving") < 0) {
299 up-to-date atomic->sync_view */
303 MDBOX_SYNC_FLAG_NO_REBUILD, ctx->atomic,
351 ctx->map_trans = mdbox_map_transaction_begin(ctx->atomic, FALSE);
382 mdbox_map_atomic_set_failed(ctx->atomic);
386 mdbox_map_atomic_set_failed(ctx->atomic);
391 (void)mdbox_map_atomic_finish(&ctx->atomic);
[all...]
H A Dmdbox-purge.c49 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_purge_context
197 ctx->append_ctx = mdbox_map_append_begin(ctx->atomic);
248 if (mdbox_map_atomic_lock(ctx->atomic, "purging check") < 0)
305 i_assert(ctx->atomic == NULL);
336 ctx->atomic = mdbox_map_atomic_begin(ctx->storage->map);
420 (void)mdbox_map_atomic_finish(&ctx->atomic);
H A Dmdbox-storage-rebuild.c48 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_storage_rebuild_context
69 struct mdbox_map_atomic_context *atomic)
77 ctx->atomic = atomic;
326 mail_index_append(ctx->atomic->sync_trans,
328 mail_index_update_ext(ctx->atomic->sync_trans, seq,
347 hdr = mail_index_get_header(ctx->atomic->sync_view);
349 if (mdbox_map_view_lookup_rec(map, ctx->atomic->sync_view,
369 mail_index_expunge(ctx->atomic->sync_trans, seq);
818 hdr = mail_index_get_header(ctx->atomic
68 mdbox_storage_rebuild_init(struct mdbox_storage *storage, struct mdbox_map_atomic_context *atomic) argument
961 mdbox_storage_rebuild_in_context(struct mdbox_storage *storage, struct mdbox_map_atomic_context *atomic) argument
988 struct mdbox_map_atomic_context *atomic; local
[all...]
H A Dmdbox-map.c24 struct mdbox_map_atomic_context *atomic; member in struct:mdbox_map_transaction_context
472 struct mdbox_map_atomic_context *atomic; local
474 atomic = i_new(struct mdbox_map_atomic_context, 1);
475 atomic->map = map;
476 return atomic;
498 int mdbox_map_atomic_lock(struct mdbox_map_atomic_context *atomic, argument
503 if (atomic->locked)
506 if (mdbox_map_open_or_create(atomic->map) < 0)
511 ret = mail_index_sync_begin(atomic->map->index, &atomic
531 mdbox_map_atomic_is_locked(struct mdbox_map_atomic_context *atomic) argument
536 mdbox_map_atomic_set_failed(struct mdbox_map_atomic_context *atomic) argument
542 mdbox_map_atomic_set_success(struct mdbox_map_atomic_context *atomic) argument
548 mdbox_map_atomic_unset_fscked(struct mdbox_map_atomic_context *atomic) argument
555 struct mdbox_map_atomic_context *atomic = *_atomic; local
577 mdbox_map_transaction_begin(struct mdbox_map_atomic_context *atomic, bool external) argument
704 struct mdbox_map_atomic_context *atomic; local
744 mdbox_map_append_begin(struct mdbox_map_atomic_context *atomic) argument
[all...]

Completed in 1108 milliseconds