Home
last modified time | relevance | path

Searched refs:file (Results 1 - 25 of 388) sorted by relevance

12345678910>>...16

/6.6.0/forestdb/src/
H A Dfilemgr.cc6 * you may not use this file except in compliance with the License.
229 "Error in %s on a database file '%s', %s", what, filename, errno_msg); in _log_errno_str()
235 struct filemgr *file = _get_entry(e, struct filemgr, e); in _file_hash() local
236 int len = strlen(file->filename); in _file_hash()
238 return get_checksum(reinterpret_cast<const uint8_t*>(file->filename), len) & in _file_hash()
357 // Read a block from the file, decrypting if necessary.
358 static ssize_t filemgr_read_block(struct filemgr *file, void *buf, bid_t bid) { in filemgr_read_block() argument
359 ssize_t result = file->ops->pread(file->fd, buf, file in filemgr_read_block()
372 filemgr_write_blocks(struct filemgr *file, void *buf, unsigned num_blocks, bid_t start_bid) filemgr_write_blocks() argument
400 filemgr_is_writable(struct filemgr *file, bid_t bid) filemgr_is_writable() argument
416 filemgr_get_sb_bmp_revnum(struct filemgr *file) filemgr_get_sb_bmp_revnum() argument
425 _filemgr_read_header(struct filemgr *file, err_log_callback *log_callback) _filemgr_read_header() argument
633 filemgr_get_ref_count(struct filemgr *file) filemgr_get_ref_count() argument
654 struct filemgr *file; global() member
729 filemgr_prefetch(struct filemgr *file, struct filemgr_config *config, err_log_callback *log_callback) filemgr_prefetch() argument
768 _filemgr_load_sb(struct filemgr *file, err_log_callback *log_callback) _filemgr_load_sb() argument
796 struct filemgr *file = NULL; get_instance_UNLOCKED() local
809 struct filemgr *file = get_instance_UNLOCKED(filename); filemgr_get_instance() local
819 struct filemgr *file = NULL; filemgr_open() local
1148 filemgr_update_header(struct filemgr *file, void *buf, size_t len, bool inc_revnum) filemgr_update_header() argument
1172 filemgr_get_header_revnum(struct filemgr *file) filemgr_get_header_revnum() argument
1184 filemgr_get_seqnum(struct filemgr *file) filemgr_get_seqnum() argument
1189 filemgr_set_seqnum(struct filemgr *file, fdb_seqnum_t seqnum) filemgr_set_seqnum() argument
1194 filemgr_get_header(struct filemgr *file, void *buf, size_t *len, bid_t *header_bid, fdb_seqnum_t *seqnum, filemgr_header_revnum_t *header_revnum) filemgr_get_header() argument
1225 filemgr_fetch_header(struct filemgr *file, uint64_t bid, void *buf, size_t *len, fdb_seqnum_t *seqnum, filemgr_header_revnum_t *header_revnum, uint64_t *deltasize, uint64_t *version, uint64_t *sb_bmp_revnum, err_log_callback *log_callback) filemgr_fetch_header() argument
1330 filemgr_fetch_prev_header(struct filemgr *file, uint64_t bid, void *buf, size_t *len, fdb_seqnum_t *seqnum, filemgr_header_revnum_t *revnum, uint64_t *deltasize, uint64_t *version, uint64_t *sb_bmp_revnum, err_log_callback *log_callback) filemgr_fetch_prev_header() argument
1510 filemgr_close(struct filemgr *file, bool cleanup_cache_onclose, const char *orig_file_name, err_log_callback *log_callback) filemgr_close() argument
1658 filemgr_remove_all_buffer_blocks(struct filemgr *file) filemgr_remove_all_buffer_blocks() argument
1673 struct filemgr *file = _get_entry(h, struct filemgr, e); filemgr_free_func() local
1769 filemgr_remove_file(struct filemgr *file, err_log_callback *log_callback) filemgr_remove_file() argument
1796 struct filemgr *file = _get_entry(h, struct filemgr, e); _filemgr_is_closed() local
1857 filemgr_alloc(struct filemgr *file, err_log_callback *log_callback) filemgr_alloc() argument
1887 filemgr_alloc_multiple(struct filemgr *file, int nblock, bid_t *begin, bid_t *end, err_log_callback *log_callback) filemgr_alloc_multiple() argument
1906 filemgr_alloc_multiple_cond(struct filemgr *file, bid_t nextbid, int nblock, bid_t *begin, bid_t *end, err_log_callback *log_callback) filemgr_alloc_multiple_cond() argument
1934 _filemgr_crc32_check(struct filemgr *file, void *buf) _filemgr_crc32_check() argument
1952 filemgr_invalidate_dbheader(struct filemgr *file, bid_t bid, err_log_callback *log_callback) filemgr_invalidate_dbheader() argument
1985 filemgr_invalidate_block(struct filemgr *file, bid_t bid) filemgr_invalidate_block() argument
1999 filemgr_is_fully_resident(struct filemgr *file) filemgr_is_fully_resident() argument
2016 filemgr_flush_immutable(struct filemgr *file, err_log_callback *log_callback) filemgr_flush_immutable() argument
2039 filemgr_read(struct filemgr *file, bid_t bid, void *buf, err_log_callback *log_callback, bool read_on_cache_miss) filemgr_read() argument
2221 filemgr_write_offset(struct filemgr *file, bid_t bid, uint64_t offset, uint64_t len, void *buf, bool final_write, err_log_callback *log_callback) filemgr_write_offset() argument
2388 filemgr_write(struct filemgr *file, bid_t bid, void *buf, err_log_callback *log_callback) filemgr_write() argument
2396 filemgr_commit(struct filemgr *file, bool sync, err_log_callback *log_callback) filemgr_commit() argument
2408 filemgr_commit_bid(struct filemgr *file, bid_t bid, uint64_t bmp_revnum, bool sync, err_log_callback *log_callback) filemgr_commit_bid() argument
2588 filemgr_sync(struct filemgr *file, bool sync_option, err_log_callback *log_callback) filemgr_sync() argument
2629 filemgr_update_file_status(struct filemgr *file, file_status_t status) filemgr_update_file_status() argument
2636 assign_old_filename(struct filemgr *file, const char *old_filename) assign_old_filename() argument
2647 assign_new_filename(struct filemgr *file, const char *new_filename) assign_new_filename() argument
2658 filemgr_update_file_linkage(struct filemgr *file, const char *old_filename, const char *new_filename) filemgr_update_file_linkage() argument
2699 filemgr_set_kv_header(struct filemgr *file, struct kvs_header *kv_header, void (*free_kv_header)(struct filemgr *file)) filemgr_set_kv_header() argument
2718 filemgr_get_kv_header(struct filemgr *file) filemgr_get_kv_header() argument
2732 struct filemgr *file = _get_entry(h, struct filemgr, e); _filemgr_check_stale_link() local
2907 struct filemgr *file = NULL; filemgr_destroy_file() local
3067 filemgr_is_rollback_on(struct filemgr *file) filemgr_is_rollback_on() argument
3076 filemgr_set_rollback(struct filemgr *file, uint8_t new_val) filemgr_set_rollback() argument
3087 filemgr_set_cancel_compaction(struct filemgr *file, bool cancel) filemgr_set_cancel_compaction() argument
3098 filemgr_is_compaction_cancellation_requested(struct filemgr *file) filemgr_is_compaction_cancellation_requested() argument
3107 filemgr_set_successfully_compacted(struct filemgr *file) filemgr_set_successfully_compacted() argument
3114 filemgr_is_successfully_compacted(struct filemgr *file) filemgr_is_successfully_compacted() argument
3123 filemgr_set_in_place_compaction(struct filemgr *file, bool in_place_compaction) filemgr_set_in_place_compaction() argument
3130 filemgr_is_in_place_compaction_set(struct filemgr *file) filemgr_is_in_place_compaction_set() argument
3152 filemgr_mutex_lock(struct filemgr *file) filemgr_mutex_lock() argument
3158 filemgr_mutex_trylock(struct filemgr *file) filemgr_mutex_trylock() argument
3166 filemgr_mutex_unlock(struct filemgr *file) filemgr_mutex_unlock() argument
3207 filemgr_set_throttling_delay(struct filemgr *file, uint64_t delay_us) filemgr_set_throttling_delay() argument
3213 filemgr_get_throttling_delay(struct filemgr *file) filemgr_get_throttling_delay() argument
3219 filemgr_clear_stale_list(struct filemgr *file) filemgr_clear_stale_list() argument
3236 filemgr_clear_stale_info_tree(struct filemgr *file) filemgr_clear_stale_info_tree() argument
3261 filemgr_clear_mergetree(struct filemgr *file) filemgr_clear_mergetree() argument
3275 filemgr_add_stale_block(struct filemgr *file, bid_t pos, size_t len) filemgr_add_stale_block() argument
3301 filemgr_actual_stale_length(struct filemgr *file, bid_t offset, size_t length) filemgr_actual_stale_length() argument
3322 filemgr_actual_stale_regions(struct filemgr *file, bid_t offset, size_t length) filemgr_actual_stale_regions() argument
3395 filemgr_mark_stale(struct filemgr *file, bid_t offset, size_t length) filemgr_mark_stale() argument
3452 filemgr_fhandle_add(struct filemgr *file, void *fhandle) filemgr_fhandle_add() argument
3476 filemgr_fhandle_remove(struct filemgr *file, void *fhandle) filemgr_fhandle_remove() argument
3503 filemgr_dirty_update_init(struct filemgr *file) filemgr_dirty_update_init() argument
3511 filemgr_dirty_update_free(struct filemgr *file) filemgr_dirty_update_free() argument
3543 filemgr_dirty_update_new_node(struct filemgr *file) filemgr_dirty_update_new_node() argument
3563 filemgr_dirty_update_get_latest(struct filemgr *file) filemgr_dirty_update_get_latest() argument
3587 filemgr_dirty_update_flush(struct filemgr *file, struct filemgr_dirty_update_node *node, err_log_callback *log_callback) filemgr_dirty_update_flush() argument
3610 filemgr_dirty_update_commit(struct filemgr *file, struct filemgr_dirty_update_node *commit_node, err_log_callback *log_callback) filemgr_dirty_update_commit() argument
3652 filemgr_dirty_update_set_immutable(struct filemgr *file, struct filemgr_dirty_update_node *prev_node, struct filemgr_dirty_update_node *node) filemgr_dirty_update_set_immutable() argument
3764 _filemgr_dirty_update_remove_node(struct filemgr *file, struct filemgr_dirty_update_node *node) _filemgr_dirty_update_remove_node() argument
3787 filemgr_dirty_update_remove_node(struct filemgr *file, struct filemgr_dirty_update_node *node) filemgr_dirty_update_remove_node() argument
3797 filemgr_dirty_update_close_node(struct filemgr *file, struct filemgr_dirty_update_node *node) filemgr_dirty_update_close_node() argument
3809 filemgr_write_dirty(struct filemgr *file, bid_t bid, void *buf, struct filemgr_dirty_update_node *node, err_log_callback *log_callback) filemgr_write_dirty() argument
3837 filemgr_read_dirty(struct filemgr *file, bid_t bid, void *buf, struct filemgr_dirty_update_node *node_reader, struct filemgr_dirty_update_node *node_writer, err_log_callback *log_callback, bool read_on_cache_miss) filemgr_read_dirty() argument
3874 _kvs_stat_set(struct filemgr *file, fdb_kvs_id_t kv_id, struct kvs_stat stat) _kvs_stat_set() argument
3898 _kvs_stat_update_attr(struct filemgr *file, fdb_kvs_id_t kv_id, kvs_stat_attr_t attr, int delta) _kvs_stat_update_attr() argument
3989 fdb_kvs_get_seqnum(struct filemgr *file, fdb_kvs_id_t id) fdb_kvs_get_seqnum() argument
4000 _kvs_stat_get(struct filemgr *file, fdb_kvs_id_t kv_id, struct kvs_stat *stat) _kvs_stat_get() argument
4021 _kvs_stat_get_sum(struct filemgr *file, kvs_stat_attr_t attr) _kvs_stat_get_sum() argument
4095 _kvs_ops_stat_get(struct filemgr *file, fdb_kvs_id_t kv_id, struct kvs_ops_stat *stat) _kvs_ops_stat_get() argument
4126 filemgr_get_ops_stats(struct filemgr *file, struct kvs_info *kvs) filemgr_get_ops_stats() argument
4203 filemgr_update_latency_stat(struct filemgr *file, fdb_latency_stat_type type, uint32_t val) filemgr_update_latency_stat() argument
4237 filemgr_get_latency_stat(struct filemgr *file, fdb_latency_stat_type type, fdb_latency_stat *stat) filemgr_get_latency_stat() argument
4257 filemgr_dump_latency_stat(struct filemgr *file, err_log_callback *log_callback) filemgr_dump_latency_stat() argument
[all...]
H A Dfilemgr.h6 * you may not use this file except in compliance with the License.
103 #define LATENCY_STAT_END(file, type)
107 #define LATENCY_STAT_END(file, type)\
110 filemgr_update_latency_stat(file, type, ts_diff(begin, end));} while(0)
180 char *filename; // Current file name.
198 char *old_filename; // Old file name before compaction
199 char *new_filename; // New file name after compaction
206 void (*free_kv_header)(struct filemgr *file); // callback function
238 // CRC the file is using.
266 * Spin lock for file handl
310 struct filemgr *file; global() member
336 filemgr_incr_ref_count(struct filemgr *file) filemgr_incr_ref_count() argument
362 filemgr_get_header_bid(struct filemgr *file) filemgr_get_header_bid() argument
400 filemgr_get_next_alloc_block(struct filemgr *file) filemgr_get_next_alloc_block() argument
433 filemgr_set_io_inprog(struct filemgr *file) filemgr_set_io_inprog() argument
438 filemgr_clear_io_inprog(struct filemgr *file) filemgr_clear_io_inprog() argument
561 filemgr_get_file_status(struct filemgr *file) filemgr_get_file_status() argument
565 filemgr_get_pos(struct filemgr *file) filemgr_get_pos() argument
615 filemgr_set_stale_list(struct filemgr *file, struct list *stale_list) filemgr_set_stale_list() argument
624 filemgr_get_stale_list(struct filemgr *file) filemgr_get_stale_list() argument
800 filemgr_dirty_update_set_root(struct filemgr *file, struct filemgr_dirty_update_node *node, bid_t dirty_idtree_root, bid_t dirty_seqtree_root) filemgr_dirty_update_set_root() argument
820 filemgr_dirty_update_get_root(struct filemgr *file, struct filemgr_dirty_update_node *node, bid_t *dirty_idtree_root, bid_t *dirty_seqtree_root) filemgr_dirty_update_get_root() argument
[all...]
H A Dtransaction.cc6 * you may not use this file except in compliance with the License.
44 struct filemgr *file; in fdb_begin_transaction() local
61 do { // repeat until file status is not REMOVED_PENDING in fdb_begin_transaction()
63 filemgr_mutex_lock(handle->file); in fdb_begin_transaction()
66 if (filemgr_is_rollback_on(handle->file)) { in fdb_begin_transaction()
68 filemgr_mutex_unlock(handle->file); in fdb_begin_transaction()
73 file = handle->file; in fdb_begin_transaction()
74 fstatus = filemgr_get_file_status(file); in fdb_begin_transaction()
76 // we must not create transaction on this file in fdb_begin_transaction()
127 struct filemgr *file; _fdb_abort_transaction() local
183 struct filemgr *file; fdb_end_transaction() local
[all...]
H A Dwal.cc6 * you may not use this file except in compliance with the License.
174 fdb_status wal_init(struct filemgr *file, int nbucket) in wal_init() argument
177 atomic_init_uint8_t(&file->wal->isPopulated, 0); in wal_init()
178 file->wal->flag = WAL_FLAG_INITIALIZED; in wal_init()
179 atomic_init_uint32_t(&file->wal->size, 0); in wal_init()
180 atomic_init_uint32_t(&file->wal->num_flushable, 0); in wal_init()
181 atomic_init_uint64_t(&file->wal->datasize, 0); in wal_init()
182 atomic_init_uint64_t(&file->wal->mem_overhead, 0); in wal_init()
183 file->wal->wal_dirty = FDB_WAL_CLEAN; in wal_init()
185 list_init(&file in wal_init()
220 wal_destroy(struct filemgr *file) wal_destroy() argument
239 wal_is_initialized(struct filemgr *file) wal_is_initialized() argument
331 _wal_snapshot_init(struct snap_handle *shandle, filemgr *file, fdb_txn *txn, fdb_seqnum_t seqnum, _fdb_key_cmp_info *key_cmp_info) _wal_snapshot_init() argument
374 wal_snapshot_open(struct filemgr *file, fdb_txn *txn, fdb_kvs_id_t kv_id, fdb_seqnum_t seqnum, _fdb_key_cmp_info *key_cmp_info, struct snap_handle **shandle) wal_snapshot_open() argument
483 _wal_update_stat(struct filemgr *file, fdb_kvs_id_t kv_id, _wal_update_type type) _wal_update_stat() argument
506 _wal_insert(fdb_txn *txn, struct filemgr *file, struct _fdb_key_cmp_info *cmp_info, fdb_doc *doc, uint64_t offset, wal_insert_by caller, bool immediate_remove) _wal_insert() argument
803 wal_insert(fdb_txn *txn, struct filemgr *file, struct _fdb_key_cmp_info *cmp_info, fdb_doc *doc, uint64_t offset, wal_insert_by caller) wal_insert() argument
813 wal_immediate_remove(fdb_txn *txn, struct filemgr *file, struct _fdb_key_cmp_info *cmp_info, fdb_doc *doc, uint64_t offset, wal_insert_by caller) wal_immediate_remove() argument
905 _wal_find(fdb_txn *txn, struct filemgr *file, fdb_kvs_id_t kv_id, struct _fdb_key_cmp_info *cmp_info, struct snap_handle *shandle, fdb_doc *doc, uint64_t *offset) _wal_find() argument
1055 wal_find(fdb_txn *txn, struct filemgr *file, struct _fdb_key_cmp_info *cmp_info, struct snap_handle *shandle, fdb_doc *doc, uint64_t *offset) wal_find() argument
1068 wal_find_kv_id(fdb_txn *txn, struct filemgr *file, fdb_kvs_id_t kv_id, struct _fdb_key_cmp_info *cmp_info, struct snap_handle *shandle, fdb_doc *doc, uint64_t *offset) wal_find_kv_id() argument
1240 wal_commit(fdb_txn *txn, struct filemgr *file, wal_commit_mark_func *func, err_log_callback *log_callback) wal_commit() argument
1411 _wal_release_item(struct filemgr *file, size_t shard_num, fdb_kvs_id_t kv_id, struct wal_item *item) _wal_release_item() argument
1437 _wal_release_items(struct filemgr *file, size_t shard_num, struct wal_item *item) _wal_release_items() argument
1513 wal_release_flushed_items(struct filemgr *file, union wal_flush_items *flush_items) wal_release_flushed_items() argument
1628 _wal_flush(struct filemgr *file, void *dbhandle, wal_flush_func *flush_func, wal_get_old_offset_func *get_old_offset, wal_flush_seq_purge_func *seq_purge_func, wal_flush_kvs_delta_stats_func *delta_stats_func, union wal_flush_items *flush_items, bool by_compactor) _wal_flush() argument
1776 wal_flush(struct filemgr *file, void *dbhandle, wal_flush_func *flush_func, wal_get_old_offset_func *get_old_offset, wal_flush_seq_purge_func *seq_purge_func, wal_flush_kvs_delta_stats_func *delta_stats_func, union wal_flush_items *flush_items) wal_flush() argument
1789 wal_flush_by_compactor(struct filemgr *file, void *dbhandle, wal_flush_func *flush_func, wal_get_old_offset_func *get_old_offset, wal_flush_seq_purge_func *seq_purge_func, wal_flush_kvs_delta_stats_func *delta_stats_func, union wal_flush_items *flush_items) wal_flush_by_compactor() argument
1821 wal_dur_snapshot_open(fdb_seqnum_t seqnum, _fdb_key_cmp_info *key_cmp_info, struct filemgr *file, fdb_txn *txn, struct snap_handle **shandle) wal_dur_snapshot_open() argument
1910 wal_copyto_snapshot(struct filemgr *file, struct snap_handle *shandle, bool is_multi_kv) wal_copyto_snapshot() argument
2042 wal_snapshot_close(struct snap_handle *shandle, struct filemgr *file) wal_snapshot_close() argument
2072 wal_itr_init(struct filemgr *file, struct snap_handle *shandle, bool by_key, struct wal_iterator **wal_iterator) wal_itr_init() argument
2804 wal_discard(struct filemgr *file, fdb_txn *txn) wal_discard() argument
2872 _wal_close(struct filemgr *file, wal_discard_t type, void *aux, err_log_callback *log_callback) _wal_close() argument
3034 wal_close(struct filemgr *file, err_log_callback *log_callback) wal_close() argument
3040 wal_shutdown(struct filemgr *file, err_log_callback *log_callback) wal_shutdown() argument
3052 wal_close_kv_ins(struct filemgr *file, fdb_kvs_id_t kv_id, err_log_callback *log_callback) wal_close_kv_ins() argument
3059 wal_try_restore(struct filemgr *file) wal_try_restore() argument
3063 wal_get_size(struct filemgr *file) wal_get_size() argument
3068 wal_get_num_shards(struct filemgr *file) wal_get_num_shards() argument
3073 wal_get_num_flushable(struct filemgr *file) wal_get_num_flushable() argument
3078 wal_get_num_docs(struct filemgr *file) wal_get_num_docs() argument
3082 wal_get_num_deletes(struct filemgr *file) wal_get_num_deletes() argument
3086 wal_get_datasize(struct filemgr *file) wal_get_datasize() argument
3091 wal_get_mem_overhead(struct filemgr *file) wal_get_mem_overhead() argument
3096 wal_set_dirty_status(struct filemgr *file, wal_dirty_t status, bool set_on_non_pending) wal_set_dirty_status() argument
3109 wal_get_dirty_status(struct filemgr *file) wal_get_dirty_status() argument
3118 wal_add_transaction(struct filemgr *file, fdb_txn *txn) wal_add_transaction() argument
3125 wal_remove_transaction(struct filemgr *file, fdb_txn *txn) wal_remove_transaction() argument
3132 wal_earliest_txn(struct filemgr *file, fdb_txn *cur_txn) wal_earliest_txn() argument
3160 wal_txn_exists(struct filemgr *file) wal_txn_exists() argument
[all...]
H A Dkv_instance.cc6 * you may not use this file except in compliance with the License.
43 // (in-memory data: managed by the file handle)
96 struct filemgr *file = fhandle->root->file; in _fdb_kvs_any_handle_opened() local
103 spin_lock(&file->fhandle_idx_lock); in _fdb_kvs_any_handle_opened()
104 a = avl_first(&file->fhandle_idx); in _fdb_kvs_any_handle_opened()
118 spin_unlock(&file->fhandle_idx_lock); in _fdb_kvs_any_handle_opened()
125 spin_unlock(&file->fhandle_idx_lock); in _fdb_kvs_any_handle_opened()
242 void fdb_cmp_func_list_from_filemgr(struct filemgr *file, struct list *cmp_func_list) in fdb_cmp_func_list_from_filemgr() argument
244 if (!file || !fil in fdb_cmp_func_list_from_filemgr()
324 struct filemgr *file = handle->file; fdb_kvs_cmp_check() local
480 struct filemgr *file; fdb_kvs_find_cmp_chunk() local
511 _fdb_kvs_init_root(fdb_kvs_handle *handle, struct filemgr *file) _fdb_kvs_init_root() argument
522 fdb_kvs_info_create(fdb_kvs_handle *root_handle, fdb_kvs_handle *handle, struct filemgr *file, const char *kvs_name) fdb_kvs_info_create() argument
603 fdb_kvs_header_create(struct filemgr *file) fdb_kvs_header_create() argument
613 fdb_kvs_header_reset_all_stats(struct filemgr *file) fdb_kvs_header_reset_all_stats() argument
1102 struct filemgr *file = handle->file; fdb_kvs_header_append() local
1167 struct filemgr *file = handle->file; fdb_kvs_get_committed_seqnum() local
1242 struct filemgr *file; fdb_get_kvs_seqnum() local
1258 fdb_kvs_set_seqnum(struct filemgr *file, fdb_kvs_id_t id, fdb_seqnum_t seqnum) fdb_kvs_set_seqnum() argument
1299 fdb_kvs_header_free(struct filemgr *file) fdb_kvs_header_free() argument
1316 struct filemgr *file; _fdb_kvs_create() local
1466 _fdb_kvs_get_name(fdb_kvs_handle *handle, struct filemgr *file) _fdb_kvs_get_name() argument
1498 struct filemgr *file = handle->file; _fdb_kvs_extract_name_off() local
1566 _fdb_kvs_open(fdb_kvs_handle *root_handle, fdb_config *config, fdb_kvs_config *kvs_config, struct filemgr *file, const char *filename, const char *kvs_name, fdb_kvs_handle *handle) _fdb_kvs_open() argument
1641 struct filemgr *file = NULL; fdb_kvs_open() local
1899 struct filemgr *file; _fdb_kvs_remove() local
2075 struct filemgr *file = fhandle->root->file; _fdb_kvs_is_busy() local
2348 struct filemgr *file; fdb_get_kvs_info() local
2440 struct filemgr *file; fdb_get_kvs_ops_info() local
[all...]
H A Dwal.h6 * you may not use this file except in compliance with the License.
168 typedef void wal_flush_kvs_delta_stats_func(struct filemgr *file,
252 fdb_status wal_init(struct filemgr *file, int nbucket);
253 int wal_is_initialized(struct filemgr *file);
254 bool wal_try_restore(struct filemgr *file);
256 struct filemgr *file,
262 struct filemgr *file,
267 fdb_status wal_find(fdb_txn *txn, struct filemgr *file,
272 struct filemgr *file,
284 fdb_status wal_commit(fdb_txn *txn, struct filemgr *file, wal_commit_mark_fun
[all...]
H A Dforestdb.cc6 * you may not use this file except in compliance with the License.
96 "offset %" _F64 " in a database file '%s' " in _fdb_readkey_wrap()
100 dhandle->file->filename, fs, dhandle->lastbid, in _fdb_readkey_wrap()
102 dbg_print_buf(dhandle->readbuffer, dhandle->file->blocksize, true, 16); in _fdb_readkey_wrap()
112 filemgr_invalidate_dbheader(handle->file, hdr_bid, &handle->log_callback); in _fdb_invalidate_dbheader()
124 size_chunk = dhandle->file->config->chunksize; in _fdb_readseq_wrap()
264 uint8_t *buf = alca(uint8_t, handle->file->blocksize); in _fdb_get_header_revnum()
271 fs = filemgr_fetch_header(handle->file, bid, buf, &header_len, in _fdb_get_header_revnum()
282 uint8_t *buf = alca(uint8_t, handle->file->blocksize); in _fdb_get_bmp_revnum()
289 fs = filemgr_fetch_header(handle->file, bi in _fdb_get_bmp_revnum()
311 struct filemgr *file = handle->file; _fdb_restore_wal() local
1008 filemgr *file; fdb_snapshot_open() local
1351 struct filemgr *file; fdb_rollback_all() local
2603 _fdb_wal_flush_kvs_delta_stats(struct filemgr *file, struct avl_tree *kvs_delta_stats) _fdb_wal_flush_kvs_delta_stats() argument
2644 struct filemgr *file = handle->dhandle->file; _fdb_wal_flush_func() local
3786 struct filemgr *file; fdb_set() local
5834 struct filemgr *file = rhandle->file; _fdb_compact_move_docs_upto_marker() local
5971 struct filemgr *file = handle->file; _fdb_clone_batched_delta() local
7900 struct filemgr *file; fdb_estimate_space_used() local
7930 struct filemgr *file; fdb_estimate_space_used_from() local
8311 filemgr *file = fhandle->root->file; fdb_set_block_reusing_params() local
[all...]
H A Dsuperblock.h6 * you may not use this file except in compliance with the License.
53 * Reserved bitmap is being written into the DB file.
105 * active in the file.
110 * file.
134 * is written back into file.
143 * sb_reclaim_reusable_blocks called during commit in writer thread if file
214 * active in the file.
219 * file.
237 fdb_status (*init)(struct filemgr *file,
241 fdb_status (*read_latest)(struct filemgr *file,
[all...]
H A Dblockcache.h6 * you may not use this file except in compliance with the License.
33 int bcache_read(struct filemgr *file, bid_t bid, void *buf);
34 bool bcache_invalidate_block(struct filemgr *file, bid_t bid);
35 int bcache_write(struct filemgr *file, bid_t bid, void *buf,
37 int bcache_write_partial(struct filemgr *file, bid_t bid, void *buf,
39 void bcache_remove_dirty_blocks(struct filemgr *file);
40 void bcache_remove_clean_blocks(struct filemgr *file);
41 bool bcache_remove_file(struct filemgr *file);
42 uint64_t bcache_get_num_blocks(struct filemgr *file);
43 fdb_status bcache_flush(struct filemgr *file);
[all...]
H A Ddocio.cc6 * you may not use this file except in compliance with the License.
33 struct filemgr *file, in docio_init()
36 handle->file = file; in docio_init()
43 malloc_align(handle->readbuffer, FDB_SECTOR_SIZE, file->blocksize); in docio_init()
47 "database file '%s'\n", in docio_init()
48 handle->file->filename); in docio_init()
60 #define _add_blk_marker(file, bid, blocksize, marker, log_callback) \
61 filemgr_write_offset((file), (bid), (blocksize), BLK_MARKER_SIZE,\
64 #define _add_blk_marker(file, bi
32 docio_init(struct docio_handle *handle, struct filemgr *file, bool compress_document_body) docio_init() argument
[all...]
H A Dsuperblock.cc6 * you may not use this file except in compliance with the License.
37 * 0x00 [file version (magic number)]: 8 bytes
282 // (1MB bitmap covers 32GB DB file) in sb_bmp_append_doc()
286 struct superblock *sb = handle->file->sb; in sb_bmp_append_doc()
291 filemgr_mark_stale(handle->file, sb->bmp_doc_offset[i], in sb_bmp_append_doc()
344 struct superblock *sb = handle->file->sb; in sb_rsv_append_doc()
403 struct superblock *sb = handle->file->sb; in sb_bmp_fetch_doc()
496 struct superblock *sb = handle->file->sb; in sb_check_sync_period()
498 if (sb && sb->num_alloc * handle->file->blocksize > SB_SYNC_PERIOD) { in sb_check_sync_period()
507 struct superblock *sb = handle->file in sb_update_header()
949 sb_switch_reserved_blocks(struct filemgr *file) sb_switch_reserved_blocks() argument
1014 sb_alloc_block(struct filemgr *file) sb_alloc_block() argument
1105 sb_bmp_is_writable(struct filemgr *file, bid_t bid) sb_bmp_is_writable() argument
1229 sb_write(struct filemgr *file, size_t sb_no, err_log_callback * log_callback) sb_write() argument
1378 _sb_read_given_no(struct filemgr *file, size_t sb_no, struct superblock *sb, err_log_callback *log_callback) _sb_read_given_no() argument
1639 sb_read_latest(struct filemgr *file, struct sb_config sconfig, err_log_callback *log_callback) sb_read_latest() argument
1717 sb_get_bmp_revnum(struct filemgr *file) sb_get_bmp_revnum() argument
1726 sb_get_min_live_revnum(struct filemgr *file) sb_get_min_live_revnum() argument
1735 sb_get_num_free_blocks(struct filemgr *file) sb_get_num_free_blocks() argument
1751 sb_init(struct filemgr *file, struct sb_config sconfig, err_log_callback * log_callback) sb_init() argument
1796 sb_free(struct filemgr *file) sb_free() argument
[all...]
H A Dbgflusher.cc6 * you may not use this file except in compliance with the License.
68 struct filemgr *file; member
76 // compares file names
89 struct filemgr *file; in bgflusher_thread() local
101 file = elem->file; in bgflusher_thread()
102 if (!file) { in bgflusher_thread()
114 ffs = filemgr_open(file->filename, file->ops, in bgflusher_thread()
115 file in bgflusher_thread()
229 bgflusher_register_file(struct filemgr *file, fdb_config *config, err_log_callback *log_callback) bgflusher_register_file() argument
298 bgflusher_deregister_file(struct filemgr *file) bgflusher_deregister_file() argument
[all...]
/6.6.0/couchstore/src/
H A Dcouch_file_read.cc24 couchstore_error_t tree_file_open(tree_file* file, in tree_file_open() argument
31 if(filename == nullptr || file == nullptr || ops == nullptr) { in tree_file_open()
37 memset(file, 0, sizeof(*file)); in tree_file_open()
39 file->crc_mode = crc_mode; in tree_file_open()
40 file->options = file_options; in tree_file_open()
42 file->path = (const char *) cb_strdup(filename); in tree_file_open()
43 error_unless(file->path, COUCHSTORE_ERROR_ALLOC_FAIL); in tree_file_open()
53 file->ops = couch_get_buffered_file_ops(&file in tree_file_open()
91 tree_file_close(tree_file* file) tree_file_close() argument
104 read_skipping_prefixes(tree_file *file, cs_off_t *pos, ssize_t len, void *dst) read_skipping_prefixes() argument
139 pread_bin_internal(tree_file *file, cs_off_t pos, char **ret_ptr, uint32_t max_header_size) pread_bin_internal() argument
190 pread_header(tree_file *file, cs_off_t pos, char **ret_ptr, uint32_t max_header_size) pread_header() argument
203 pread_compressed(tree_file *file, cs_off_t pos, char **ret_ptr) pread_compressed() argument
239 pread_bin(tree_file *file, cs_off_t pos, char **ret_ptr) pread_bin() argument
[all...]
H A Dos.cc6 * you may not use this file except in compliance with the License.
71 // State of a single file handle, as returned by open().
108 auto* file = to_file(handle); in pread() local
111 rv = ::pread(file->fd, buf, nbyte, offset); in pread()
131 auto* file = to_file(handle); in pwrite() local
134 rv = ::pwrite(file->fd, buf, nbyte, offset); in pwrite()
138 if (file->tracing_enabled) { in pwrite()
150 if (file->write_validation_enabled) { in pwrite()
159 ssize_t got_bytes = ::pread(file->fd, read_buf, len, read_offset); in pwrite()
160 if ((file in pwrite()
210 auto* file = to_file(*handle); open() local
239 auto* file = to_file(handle); close() local
259 auto* file = to_file(handle); set_periodic_sync() local
265 auto* file = to_file(handle); set_tracing_enabled() local
272 auto* file = to_file(handle); set_write_validation_enabled() local
279 auto* file = to_file(handle); set_mprotect_enabled() local
286 auto* file = to_file(handle); goto_eof() local
299 auto* file = to_file(handle); sync() local
325 auto* file = to_file(handle); destructor() local
336 auto* file = to_file(handle); advise() local
[all...]
H A Dos_win.cc6 * you may not use this file except in compliance with the License.
81 // State of a single file handle, as returned by open().
115 auto* file = to_file(handle); in pread() local
122 rv = ReadFile(file->fh, buf, nbyte, &bytesread, &winoffs); in pread()
140 auto* file = to_file(handle); in pwrite() local
147 rv = WriteFile(file->fh, buf, nbyte, &byteswritten, &winoffs); in pwrite()
153 file->bytes_written_since_last_sync += rv; in pwrite()
154 if ((file->periodic_sync_bytes > 0) && in pwrite()
155 (file->bytes_written_since_last_sync >= file in pwrite()
171 auto* file = to_file(*handle); open() local
204 auto* file = to_file(handle); close() local
214 auto* file = to_file(handle); set_periodic_sync() local
222 auto* file = to_file(handle); goto_eof() local
235 auto* file = to_file(handle); sync() local
255 auto* file = to_file(handle); destructor() local
[all...]
H A Dcouch_file_write.cc17 static ssize_t write_entire_buffer(tree_file *file, const void* buf, in write_entire_buffer() argument
23 if (file->options.tracing_enabled) { in write_entire_buffer()
34 ssize_t written = file->ops->pwrite(&file->lastError, file->handle, in write_entire_buffer()
46 static ssize_t raw_write(tree_file *file, const sized_buf *buf, cs_off_t pos) in raw_write() argument
64 written = write_entire_buffer(file, &blockprefix, 1, write_pos); in raw_write()
71 written = write_entire_buffer(file, buf->buf + buf_pos, block_remain, write_pos); in raw_write()
82 couchstore_error_t write_header(tree_file *file, sized_buf *buf, cs_off_t *pos) in write_header() argument
84 cs_off_t write_pos = align_to_next_block(file in write_header()
120 db_write_buf(tree_file *file, const sized_buf *buf, cs_off_t *pos, size_t *disk_size) db_write_buf() argument
170 db_write_buf_compressed(tree_file *file, const sized_buf *buf, cs_off_t *pos, size_t *disk_size) db_write_buf_compressed() argument
[all...]
H A Dtracking_file_ops.cc6 * you may not use this file except in compliance with the License.
53 // Information for each block of the file.
91 /// The granularity at which we track the file (in bytes).
94 /// Handle of the underlying file ops interface.
100 // State machine for couchstore file access
109 /// Vector of blockInfos, indexed by the file block number.
117 auto* file = new File(errinfo); in constructor() local
118 return reinterpret_cast<couch_file_handle>(file); in constructor()
125 auto* file = reinterpret_cast<File*>(*handle); in open() local
127 errinfo, &file in open()
132 auto* file = reinterpret_cast<File*>(handle); close() local
145 auto* file = reinterpret_cast<File*>(handle); pread() local
156 auto* file = reinterpret_cast<File*>(handle); pwrite() local
163 auto* file = reinterpret_cast<File*>(handle); goto_eof() local
169 auto* file = reinterpret_cast<File*>(handle); sync() local
178 auto* file = reinterpret_cast<File*>(handle); advise() local
184 auto* file = reinterpret_cast<File*>(handle); tag() local
189 auto* file = reinterpret_cast<File*>(handle); destructor() local
391 auto* file = reinterpret_cast<File*>(handle); setTree() local
396 auto* file = reinterpret_cast<File*>(handle); setHistoricData() local
[all...]
/6.6.0/forestdb/tests/unit/
H A Dbcache_test.cc6 * you may not use this file except in compliance with the License.
41 struct filemgr *file; in basic_test() local
53 file = result.file; in basic_test()
56 filemgr_alloc(file, NULL); in basic_test()
57 filemgr_write(file, i, buf, NULL); in basic_test()
59 filemgr_commit(file, true, NULL); in basic_test()
61 filemgr_alloc(file, NULL); in basic_test()
62 filemgr_write(file, i, buf, NULL); in basic_test()
64 filemgr_commit(file, tru in basic_test()
87 struct filemgr *file; basic_test2() local
123 struct filemgr *file; global() member
195 struct filemgr *file; multi_thread_test() local
[all...]
H A Dbtreeblock_test.cc6 * you may not use this file except in compliance with the License.
44 struct filemgr *file; in basic_test() local
63 file = result.file; in basic_test()
64 btreeblk_init(&btree_handle, file, nodesize); in basic_test()
93 filemgr_commit(file, true, NULL); in basic_test()
102 filemgr_commit(file, true, NULL); in basic_test()
111 filemgr_commit(file, true, NULL); in basic_test()
123 filemgr_close(file, true, NULL, NULL); in basic_test()
137 struct filemgr *file; in iterator_test() local
221 struct filemgr *file; two_btree_test() local
268 struct filemgr *file; range_test() local
340 struct filemgr *file; subblock_test() local
589 struct filemgr *file; btree_reverse_iterator_test() local
[all...]
H A Dfilemgr_test.cc6 * you may not use this file except in compliance with the License.
30 struct filemgr *file; in basic_test() local
48 file = result.file; in basic_test()
50 filemgr_update_header(file, (void*)dbheader, strlen(dbheader)+1, true); in basic_test()
52 filemgr_close(file, true, NULL, NULL); in basic_test()
54 file = result.file; in basic_test()
56 memcpy(buf, file->header.data, file in basic_test()
[all...]
/6.6.0/godeps/src/golang.org/x/tools/godoc/
H A Dtemplate.go3 // license that can be found in the LICENSE file.
9 // This file defines functions for those templates to invoke.
17 // Whole file:
25 // to signify the end of the file. In multi-line matches,
44 // Functions in this file panic on error, but the panic is recovered
47 // contents reads and returns the content of the named file
48 // (from the virtual file system, so for example /doc refers to $GOROOT/doc).
50 file, err := vfs.ReadFile(c.fs, name)
54 return string(file)
73 func (p *Presentation) code(file strin
[all...]
/6.6.0/godeps/src/github.com/blevesearch/snowballstem/
H A Dgengen.go34 for _, file := range files {
35 if _, ok := excludeAlgorithms[file.Name()]; ok {
38 if _, err = os.Stat(filepath.Join(flag.Arg(0), file.Name(), "stem_Unicode.sbl")); err == nil {
40 file.Name(), file.Name(), file.Name(), file.Name())
41 } else if _, err = os.Stat(filepath.Join(flag.Arg(0), file.Name(), "stem_ISO_8859_1.sbl")); err == nil {
43 file.Name(), file
[all...]
/6.6.0/goproj/src/github.com/couchbase/indexing/secondary/collatejson/tools/checkfiles/
H A Dcheckfiles.go28 var usageHelp = `Usage : checkfiles [OPTIONS] <file> | <dir>
29 specifying a file <file> will sort each line in the file,
31 specifying a dir <dir> will pick each file in dir and sort each
32 line in the file, if corresponding <file>.ref is found inside
33 the same dir, the output will compared with <file>.ref file.
59 file
[all...]
/6.6.0/ns_server/scripts/
H A Dcopyright7 # you may not use this file except in compliance with the License.
28 file "$1" | grep -q -E '\<text\>'
76 local file="$1"
78 ext=$(get_extension "$file") || return 1
98 shebang=$(get_shebang "$file") || return 1
152 local file="$1"
156 name=$(basename "$file") || return 1
161 # preserve file mode
162 cp -a "$file" "$tmpfile" || return 1
167 mv "$tmpfile" "$file"
[all...]
/6.6.0/third_party/spdlog/include/spdlog/fmt/bundled/
H A Dposix.h141 // A buffered file.
147 friend class file;
155 // Constructs a buffered_file object which doesn't represent any file.
158 // Destroys the object closing the file it represents if any.
170 FILE *file; member
175 buffered_file(Proxy p) FMT_NOEXCEPT : file_(p.file) {} in file_()
187 file_ = p.file; in operator =()
201 // buffered_file file = buffered_file(...);
228 // Opens a file.
231 // Closes the file
262 class file global() class
268 explicit file(int fd) file() function in file
[all...]

Completed in 94 milliseconds

12345678910>>...16