Home
last modified time | relevance | path

Searched refs:cbt (Results 1 – 25 of 1017) sorted by relevance

12345678910>>...41

/dports/databases/mongodb36/mongodb-src-r3.6.23/src/third_party/wiredtiger/src/btree/
H A Dbt_curnext.c59 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 Dbt_curprev.c58 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 Dbt_cursor.c296 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 Dcol_srch.c27 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 Dcol_modify.c36 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 Dbt_ret.c24 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 Dbt_random.c26 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 Drow_srch.c54 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 Dcircuitstats.c567 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 Dcircuitstats.h28 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 Dcircuitstats.c567 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 Dcircuitstats.h28 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 Ddata_filter_snippets.cc37 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 Dread_snippets.cc48 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 Ddata_snippets.cc35 [](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 Ddata_async_snippets.cc31 [](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 Dtable_admin_snippets.cc28 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 Dbigtable_hello_world.cc41 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 Ddata_filter_snippets.cc37 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 Dread_snippets.cc48 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 Ddata_snippets.cc34 [](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 Ddata_async_snippets.cc31 [](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 Dtable_admin_snippets.cc28 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 Dcur_file.c25 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 Dcursor.i17 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 …]

12345678910>>...41