/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/wiredtiger/src/btree/ |
H A D | bt_curnext.c | 59 cbt->iface.value.data = &cbt->v; in __cursor_fix_append_next() 64 cbt->iface.value.data = &cbt->v; in __cursor_fix_append_next() 107 cbt->ins_head, cbt->ins_stack, cbt->next_stack, cbt->recno); in __cursor_fix_next() 108 if (cbt->ins != NULL && cbt->recno != WT_INSERT_RECNO(cbt->ins)) in __cursor_fix_next() 113 cbt->v = __bit_getv_recno(cbt->ref, cbt->recno, btree->bitcnt); in __cursor_fix_next() 114 cbt->iface.value.data = &cbt->v; in __cursor_fix_next() 203 cbt->ins = __col_insert_search_match(cbt->ins_head, cbt->recno); in __cursor_var_next() 391 cbt->lastrecno = cbt->recno; in __cursor_key_order_check_col() 426 cbt->lastkey, cbt->iface.key.data, cbt->iface.key.size)); in __cursor_key_order_check_row() 484 cbt->lastrecno = cbt->recno; in __wt_cursor_key_order_init() [all …]
|
H A D | bt_curprev.c | 58 cbt->ins_stack, cbt->next_stack, in __cursor_skip_prev() 119 cbt->ins = PREV_INS(cbt, 0); in __cursor_skip_prev() 202 if (cbt->ins == NULL || cbt->recno > WT_INSERT_RECNO(cbt->ins)) { in __cursor_fix_append_prev() 204 cbt->iface.value.data = &cbt->v; in __cursor_fix_append_prev() 210 cbt->iface.value.data = &cbt->v; in __cursor_fix_append_prev() 252 cbt->ins_head, cbt->ins_stack, cbt->next_stack, cbt->recno); in __cursor_fix_prev() 253 if (cbt->ins != NULL && cbt->recno != WT_INSERT_RECNO(cbt->ins)) in __cursor_fix_prev() 259 cbt->v = __bit_getv_recno(cbt->ref, cbt->recno, btree->bitcnt); in __cursor_fix_prev() 260 cbt->iface.value.data = &cbt->v; in __cursor_fix_prev() 350 cbt->ins = __col_insert_search_match(cbt->ins_head, cbt->recno); in __cursor_var_prev() [all …]
|
H A D | bt_cursor.c | 296 if (cbt->recno >= cbt->ref->ref_recno + page->entries) in __wt_cursor_valid() 373 cbt, cbt->iface.recno, leaf, false, leaf_foundp)); in __cursor_col_search() 425 cbt, cbt->iface.recno, &cbt->iface.value, in __cursor_col_modify() 437 cbt, &cbt->iface.key, &cbt->iface.value, in __cursor_row_modify() 524 __cursor_col_search(cbt, cbt->ref, &leaf_found)); in __wt_btcur_search() 639 cbt->slot != cbt->ref->page->entries - 1))) in __wt_btcur_search_near() 1288 || (cbt->slot != 0 && cbt->slot != cbt->ref->page->entries - 1))) in __btcur_update() 1352 ret = __cursor_kv_return(cbt, cbt->modify_update); in __btcur_update() 1902 cbt->row_key = &cbt->_row_key; in __wt_btcur_open() 1903 cbt->tmp = &cbt->_tmp; in __wt_btcur_open() [all …]
|
H A D | col_srch.c | 27 cbt->compare = 0; in __check_leaf_key_range() 216 cbt->ref = current; in __wt_col_search() 225 cbt->compare = -1; in __wt_col_search() 245 cbt->compare = 1; in __wt_col_search() 253 cbt->compare = 0; in __wt_col_search() 259 cbt->slot = 0; in __wt_col_search() 260 cbt->compare = 1; in __wt_col_search() 285 ins_head, cbt->ins_stack, cbt->next_stack, recno)) != NULL) in __wt_col_search() 288 cbt->ins = ins; in __wt_col_search() 303 cbt->ins_head, cbt->ins_stack, cbt->next_stack, recno)) == NULL) in __wt_col_search() [all …]
|
H A D | col_modify.c | 36 btree = cbt->btree; in __wt_col_modify() 38 page = cbt->ref->page; in __wt_col_modify() 72 cbt->ins = NULL; in __wt_col_modify() 103 if (cbt->ins == NULL && cbt->ins_head != NULL) { in __wt_col_modify() 105 cbt->ins_head, cbt->ins_stack, cbt->next_stack, recno); in __wt_col_modify() 108 cbt->compare = 0; in __wt_col_modify() 116 cbt->ins = NULL; in __wt_col_modify() 131 if (cbt->compare == 0 && cbt->ins != NULL) { in __wt_col_modify() 191 cbt->ins = ins; in __wt_col_modify() 240 session, page, cbt->ins_head, cbt->ins_stack, in __wt_col_modify() [all …]
|
H A D | bt_ret.c | 24 page = cbt->ref->page; in __key_return() 25 cursor = &cbt->iface; in __key_return() 38 if (cbt->ins != NULL) { in __key_return() 44 if (cbt->compare == 0) { in __key_return() 56 tmp = cbt->row_key; in __key_return() 57 cbt->row_key = cbt->tmp; in __key_return() 58 cbt->tmp = tmp; in __key_return() 97 page = cbt->ref->page; in __value_return() 98 cursor = &cbt->iface; in __value_return() 152 cursor = &cbt->iface; in __wt_value_return_upd() [all …]
|
H A D | bt_random.c | 26 page = cbt->ref->page; in __wt_row_random_leaf() 31 __cursor_pos_clear(cbt); in __wt_row_random_leaf() 35 cbt->compare = 0; in __wt_row_random_leaf() 43 page, page->pg_row + cbt->slot, cbt->tmp, false)); in __wt_row_random_leaf() 152 cbt->ins = ins; in __wt_row_random_leaf() 154 cbt->compare = 0; in __wt_row_random_leaf() 310 btree = cbt->btree; in __wt_btcur_next_random() 311 cursor = &cbt->iface; in __wt_btcur_next_random() 343 if (cbt->ref == NULL || cbt->next_random_sample_size == 0) { in __wt_btcur_next_random() 407 for (skip = cbt->next_random_leaf_skip; cbt->ref == NULL || skip > 0;) { in __wt_btcur_next_random() [all …]
|
H A D | row_srch.c | 54 cbt->compare = -cmp; in __search_insert_append() 55 cbt->ins = ins; in __search_insert_append() 56 cbt->ins_head = ins_head; in __search_insert_append() 127 cbt->compare = -cmp; in __wt_search_insert() 150 item = cbt->tmp; in __check_leaf_key_range() 157 cbt->compare = 0; in __check_leaf_key_range() 229 item = cbt->tmp; in __wt_row_search() 463 cbt->ref = current; in __wt_row_search() 595 cbt->compare = 1; in __wt_row_search() 596 cbt->slot = 0; in __wt_row_search() [all …]
|
/dports/security/tor-devel/tor-0.4.7.2-alpha/src/core/or/ |
H A D | circuitstats.c | 567 memset(cbt, 0, sizeof(*cbt)); in circuit_build_times_init() 1147 cbt->Xm = circuit_build_times_get_xm(cbt); in circuit_build_times_update_alpha() 1254 ret = 1.0-pow(cbt->Xm/x,cbt->alpha); in circuit_build_times_cdf() 1587 cbt->timeout_ms, cbt->close_ms); in circuit_build_times_network_check_changed() 1593 cbt->close_ms = cbt->timeout_ms in circuit_build_times_network_check_changed() 1658 cbt->close_ms = cbt->timeout_ms in circuit_build_times_count_close() 1689 cbt->close_ms = cbt->timeout_ms in circuit_build_times_count_timeout() 1772 if (cbt->close_ms < cbt->timeout_ms) { in circuit_build_times_set_timeout() 1792 cbt->timeout_ms, cbt->close_ms, cbt->Xm, cbt->alpha, in circuit_build_times_set_timeout() 1803 cbt->timeout_ms, cbt->close_ms, cbt->Xm, cbt->alpha, in circuit_build_times_set_timeout() [all …]
|
H A D | circuitstats.h | 28 void circuit_build_times_update_state(const circuit_build_times_t *cbt, 30 int circuit_build_times_parse_state(circuit_build_times_t *cbt, 32 void circuit_build_times_count_timeout(circuit_build_times_t *cbt, 34 int circuit_build_times_count_close(circuit_build_times_t *cbt, 36 void circuit_build_times_set_timeout(circuit_build_times_t *cbt); 37 int circuit_build_times_add_time(circuit_build_times_t *cbt, 43 void circuit_build_times_init(circuit_build_times_t *cbt); 44 void circuit_build_times_free_timeouts(circuit_build_times_t *cbt); 50 void circuit_build_times_update_last_circ(circuit_build_times_t *cbt); 52 void circuit_build_times_reset(circuit_build_times_t *cbt); [all …]
|
/dports/security/tor/tor-0.4.6.8/src/core/or/ |
H A D | circuitstats.c | 567 memset(cbt, 0, sizeof(*cbt)); in circuit_build_times_init() 1147 cbt->Xm = circuit_build_times_get_xm(cbt); in circuit_build_times_update_alpha() 1254 ret = 1.0-pow(cbt->Xm/x,cbt->alpha); in circuit_build_times_cdf() 1587 cbt->timeout_ms, cbt->close_ms); in circuit_build_times_network_check_changed() 1593 cbt->close_ms = cbt->timeout_ms in circuit_build_times_network_check_changed() 1658 cbt->close_ms = cbt->timeout_ms in circuit_build_times_count_close() 1689 cbt->close_ms = cbt->timeout_ms in circuit_build_times_count_timeout() 1772 if (cbt->close_ms < cbt->timeout_ms) { in circuit_build_times_set_timeout() 1792 cbt->timeout_ms, cbt->close_ms, cbt->Xm, cbt->alpha, in circuit_build_times_set_timeout() 1803 cbt->timeout_ms, cbt->close_ms, cbt->Xm, cbt->alpha, in circuit_build_times_set_timeout() [all …]
|
H A D | circuitstats.h | 28 void circuit_build_times_update_state(const circuit_build_times_t *cbt, 30 int circuit_build_times_parse_state(circuit_build_times_t *cbt, 32 void circuit_build_times_count_timeout(circuit_build_times_t *cbt, 34 int circuit_build_times_count_close(circuit_build_times_t *cbt, 36 void circuit_build_times_set_timeout(circuit_build_times_t *cbt); 37 int circuit_build_times_add_time(circuit_build_times_t *cbt, 43 void circuit_build_times_init(circuit_build_times_t *cbt); 44 void circuit_build_times_free_timeouts(circuit_build_times_t *cbt); 50 void circuit_build_times_update_last_circ(circuit_build_times_t *cbt); 52 void circuit_build_times_reset(circuit_build_times_t *cbt); [all …]
|
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/examples/ |
H A D | data_filter_snippets.cc | 37 cbt::Filter filter = cbt::Filter::RowSample(0.75); in FilterLimitRowSample() 65 cbt::Filter filter = cbt::Filter::RowKeysRegex("key.*9$"); in FilterLimitRowRegex() 90 cbt::Filter filter = cbt::Filter::Latest(2); in FilterLimitCellsPerColumn() 115 cbt::Filter filter = cbt::Filter::CellsRowLimit(2); in FilterLimitCellsPerRow() 139 cbt::Filter filter = cbt::Filter::CellsRowOffset(2); in FilterLimitCellsPerRowOfset() 163 cbt::Filter filter = cbt::Filter::FamilyRegex("fam-1.*"); in FilterLimitColFamilyRegex() 308 cbt::Filter filter = cbt::Filter::BlockAllFilter(); in FilterLimitBlockAll() 333 cbt::Filter filter = cbt::Filter::PassAllFilter(); in FilterLimitPassAll() 410 cbt::Filter filter = cbt::Filter::Chain(cbt::Filter::Latest(1), in FilterComposingChain() 435 cbt::Filter filter = cbt::Filter::Interleave( in FilterComposingInterleave() [all …]
|
H A D | read_snippets.cc | 48 cbt::BulkMutation bulk; in PrepareReadSamples() 112 [](cbt::Table table) { in ReadRowsWithLimit() 118 cbt::Filter filter = cbt::Filter::Chain( in ReadRowsWithLimit() 161 cbt::Filter filter = cbt::Filter::Latest(1); in ReadKeysSet() 183 cbt::Filter filter = cbt::Filter::Latest(1); in ReadPrefixList() 248 [](cbt::Table table) { in ReadRows() 266 [](cbt::Table table) { in ReadRowRange() 285 [](cbt::Table table) { in ReadRowRanges() 288 cbt::RowSet({cbt::RowRange::Range("phone#4c410523#20190501", in ReadRowRanges() 309 cbt::RowRange::Prefix("phone"), cbt::Filter::PassAllFilter())) { in ReadRowPrefix() [all …]
|
H A D | data_snippets.cc | 35 [](cbt::Table table) { in Apply() 57 cbt::Table table(cbt::CreateDefaultDataClient(project_id, instance_id, in ApplyRelaxedIdempotency() 78 cbt::Table table(cbt::CreateDefaultDataClient(project_id, instance_id, in ApplyCustomRetry() 142 cbt::Filter filter = cbt::Filter::Latest(1); in ReadRow() 174 cbt::Filter predicate = cbt::Filter::Chain( in CheckAndMutate() 176 cbt::Filter::Latest(1), cbt::Filter::ValueRegex("on")); in CheckAndMutate() 206 cbt::Filter predicate = cbt::Filter::Chain( in CheckAndMutateNotPresent() 319 cbt::Filter filter = cbt::Filter::StripValueTransformer(); in RowExists() 390 cbt::SingleRowMutation(row_key, cbt::DeleteFromRow())); in MutateDeleteRows() 689 cbt::Filter predicate = cbt::Filter::Chain( in WriteConditionally() [all …]
|
H A D | data_async_snippets.cc | 31 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncApply() 57 [](cbt::Table table, cbt::CompletionQueue cq) { in AsyncBulkApply() 115 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRows() 156 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRowsWithLimit() 199 cbt::Filter filter = cbt::Filter::Latest(1); in AsyncReadRow() 238 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncCheckAndMutate() 240 cbt::Filter predicate = cbt::Filter::Chain( in AsyncCheckAndMutate() 242 cbt::Filter::Latest(1), cbt::Filter::ValueRegex("on")); in AsyncCheckAndMutate() 274 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncReadModifyWrite() 314 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll() [all …]
|
H A D | table_admin_snippets.cc | 28 namespace cbt = google::cloud::bigtable; in CreateTable() 33 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}, in CreateTable() 47 namespace cbt = google::cloud::bigtable; in ListTables() 49 [](cbt::TableAdmin admin) { in ListTables() 65 namespace cbt = google::cloud::bigtable; in GetTable() 112 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}}, {})); in GetOrCreateTable() 215 cbt::GcRule::Union( in CreateUnionFamily() 261 cbt::GcRule::Union( in CreateNestedFamily() 531 cbt::TableAdmin admin( in RunAll() 532 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll() [all …]
|
H A D | bigtable_hello_world.cc | 41 namespace cbt = google::cloud::bigtable; in BigtableHelloWorld() 47 cbt::TableAdmin table_admin( in BigtableHelloWorld() 48 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions()), in BigtableHelloWorld() 54 cbt::GcRule gc_rule = cbt::GcRule::MaxNumVersions(1); in BigtableHelloWorld() 64 cbt::Table table(cbt::CreateDefaultDataClient(project_id, instance_id, in BigtableHelloWorld() 96 cbt::Filter filter = cbt::Filter::ColumnRangeClosed("family", "c0", "c0"); in BigtableHelloWorld() 117 cbt::RowRange::InfiniteRange(), cbt::Filter::PassAllFilter())) { in BigtableHelloWorld() 120 for (cbt::Cell const& c : row->cells()) { in BigtableHelloWorld() 137 namespace cbt = google::cloud::bigtable; in RunAll() 151 cbt::TableAdmin admin( in RunAll() [all …]
|
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/bigtable/examples/ |
H A D | data_filter_snippets.cc | 37 cbt::Filter filter = cbt::Filter::RowSample(0.75); in FilterLimitRowSample() 65 cbt::Filter filter = cbt::Filter::RowKeysRegex("key.*9$"); in FilterLimitRowRegex() 90 cbt::Filter filter = cbt::Filter::Latest(2); in FilterLimitCellsPerColumn() 115 cbt::Filter filter = cbt::Filter::CellsRowLimit(2); in FilterLimitCellsPerRow() 139 cbt::Filter filter = cbt::Filter::CellsRowOffset(2); in FilterLimitCellsPerRowOfset() 163 cbt::Filter filter = cbt::Filter::FamilyRegex("fam-1.*"); in FilterLimitColFamilyRegex() 308 cbt::Filter filter = cbt::Filter::BlockAllFilter(); in FilterLimitBlockAll() 333 cbt::Filter filter = cbt::Filter::PassAllFilter(); in FilterLimitPassAll() 410 cbt::Filter filter = cbt::Filter::Chain(cbt::Filter::Latest(1), in FilterComposingChain() 435 cbt::Filter filter = cbt::Filter::Interleave( in FilterComposingInterleave() [all …]
|
H A D | read_snippets.cc | 48 cbt::BulkMutation bulk; in PrepareReadSamples() 112 [](cbt::Table table) { in ReadRowsWithLimit() 118 cbt::Filter filter = cbt::Filter::Chain( in ReadRowsWithLimit() 161 cbt::Filter filter = cbt::Filter::Latest(1); in ReadKeysSet() 183 cbt::Filter filter = cbt::Filter::Latest(1); in ReadPrefixList() 248 [](cbt::Table table) { in ReadRows() 266 [](cbt::Table table) { in ReadRowRange() 285 [](cbt::Table table) { in ReadRowRanges() 288 cbt::RowSet({cbt::RowRange::Range("phone#4c410523#20190501", in ReadRowRanges() 309 cbt::RowRange::Prefix("phone"), cbt::Filter::PassAllFilter())) { in ReadRowPrefix() [all …]
|
H A D | data_snippets.cc | 34 [](cbt::Table table) { in Apply() 56 cbt::Table table(cbt::CreateDefaultDataClient(project_id, instance_id, in ApplyRelaxedIdempotency() 77 cbt::Table table(cbt::CreateDefaultDataClient(project_id, instance_id, in ApplyCustomRetry() 141 cbt::Filter filter = cbt::Filter::Latest(1); in ReadRow() 173 cbt::Filter predicate = cbt::Filter::Chain( in CheckAndMutate() 175 cbt::Filter::Latest(1), cbt::Filter::ValueRegex("on")); in CheckAndMutate() 205 cbt::Filter predicate = cbt::Filter::Chain( in CheckAndMutateNotPresent() 318 cbt::Filter filter = cbt::Filter::StripValueTransformer(); in RowExists() 389 cbt::SingleRowMutation(row_key, cbt::DeleteFromRow())); in MutateDeleteRows() 693 cbt::Filter predicate = cbt::Filter::Chain( in WriteConditionally() [all …]
|
H A D | data_async_snippets.cc | 31 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncApply() 57 [](cbt::Table table, cbt::CompletionQueue cq) { in AsyncBulkApply() 115 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRows() 156 [](cbt::CompletionQueue cq, cbt::Table table) { in AsyncReadRowsWithLimit() 199 cbt::Filter filter = cbt::Filter::Latest(1); in AsyncReadRow() 238 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncCheckAndMutate() 240 cbt::Filter predicate = cbt::Filter::Chain( in AsyncCheckAndMutate() 242 cbt::Filter::Latest(1), cbt::Filter::ValueRegex("on")); in AsyncCheckAndMutate() 274 [](cbt::Table table, cbt::CompletionQueue cq, std::string const& row_key) { in AsyncReadModifyWrite() 314 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll() [all …]
|
H A D | table_admin_snippets.cc | 28 namespace cbt = google::cloud::bigtable; in CreateTable() 33 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}, in CreateTable() 47 namespace cbt = google::cloud::bigtable; in ListTables() 49 [](cbt::TableAdmin admin) { in ListTables() 65 namespace cbt = google::cloud::bigtable; in GetTable() 112 cbt::TableConfig({{"fam", cbt::GcRule::MaxNumVersions(10)}}, {})); in GetOrCreateTable() 215 cbt::GcRule::Union( in CreateUnionFamily() 261 cbt::GcRule::Union( in CreateNestedFamily() 531 cbt::TableAdmin admin( in RunAll() 532 cbt::CreateDefaultAdminClient(project_id, cbt::ClientOptions{}), in RunAll() [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/wiredtiger/src/cursor/ |
H A D | cur_file.c | 25 WT_CURSOR_BTREE *cbt; in __curfile_compare() local 57 WT_CURSOR_BTREE *cbt; in __curfile_equals() local 89 WT_CURSOR_BTREE *cbt; in __curfile_next() local 115 WT_CURSOR_BTREE *cbt; in __wt_curfile_next_random() local 140 WT_CURSOR_BTREE *cbt; in __curfile_prev() local 165 WT_CURSOR_BTREE *cbt; in __curfile_reset() local 190 WT_CURSOR_BTREE *cbt; in __curfile_search() local 221 WT_CURSOR_BTREE *cbt; in __curfile_search_near() local 535 cbt->dhandle = cbt->btree->dhandle; in __curfile_cache() 655 cbt->btree = btree; in __curfile_create() [all …]
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/wiredtiger/src/include/ |
H A D | cursor.i | 17 cbt->iface.recno = cbt->recno = v; in __cursor_set_recno() 133 cbt->ins = NULL; in __cursor_pos_clear() 134 cbt->ins_head = NULL; in __cursor_pos_clear() 196 if (cbt->ref == NULL) in __cursor_reset() 215 cbt->ref = NULL; in __cursor_reset() 386 page = cbt->ref->page; in __cursor_row_slot_return() 391 kb = &cbt->iface.key; in __cursor_row_slot_return() 423 cbt->rip_saved != NULL && cbt->rip_saved == rip - 1) { in __cursor_row_slot_return() 436 session, cbt->row_key, cbt->row_key->size + kpack->size)); in __cursor_row_slot_return() 437 memcpy((uint8_t *)cbt->row_key->data + cbt->row_key->size, in __cursor_row_slot_return() [all …]
|