Function _fdb_kvs_remove

src/kv_instance.cc:1889–2089

}

static
fdb_status _fdb_kvs_remove(fdb_file_handle *fhandle,
                           const char *kvs_name,
                           bool rollback_recreate)
{
    size_t size_chunk, size_id;
    uint8_t *_kv_id;
    fdb_status fs = FDB_RESULT_SUCCESS;
    fdb_kvs_id_t kv_id = 0;
    fdb_kvs_handle *root_handle;
    struct avl_node *a = NULL;
    struct list_elem *e;
    struct filemgr *file;
    struct kvs_node *node, query;
    struct kvs_header *kv_header;
    struct kvs_opened_node *opened_node;

    if (!fhandle) {
        return FDB_RESULT_INVALID_HANDLE;
    }
    root_handle = fhandle->root;

    if (root_handle->config.multi_kv_instances == false) {
        // cannot remove the KV instance under single DB instance mode
        return FDB_RESULT_INVALID_CONFIG;
    }
    if (root_handle->kvs->type != KVS_ROOT) {
        return FDB_RESULT_INVALID_HANDLE;
    }

fdb_kvs_remove_start:
    if (!rollback_recreate) {
        fdb_check_file_reopen(root_handle, NULL);
        filemgr_mutex_lock(root_handle->file);
        fdb_sync_db_header(root_handle);

        if (filemgr_is_rollback_on(root_handle->file)) {
            filemgr_mutex_unlock(root_handle->file);
            return FDB_RESULT_FAIL_BY_ROLLBACK;
        }
    } else {
        filemgr_mutex_lock(root_handle->file);
    }

    file = root_handle->file;

    file_status_t fstatus = filemgr_get_file_status(file);
    if (fstatus == FILE_REMOVED_PENDING) {
        // we must not write into this file
        // file status was changed by other thread .. start over
        filemgr_mutex_unlock(file);
        goto fdb_kvs_remove_start;
    } else if (fstatus == FILE_COMPACT_OLD) {
        // Cannot remove existing KV store during compaction.
        // To remove a KV store, the corresponding first chunk in HB+trie
        // should be unlinked. This can be possible in the old file during
        // compaction, but impossible in the new file, since existing documents
        // (including docs belonging to the KV store to be removed) are being moved.