Lines Matching refs:dbc
90 __ham_item(dbc, mode) in __ham_item() argument
91 DBC *dbc; in __ham_item()
99 dbp = dbc->dbp;
100 hcp = (HASH_CURSOR *)dbc->internal;
107 if ((ret = __ham_get_cpage(dbc, mode)) != 0)
146 } else if ((ret = __ham_next_cpage(dbc,
164 if ((ret = __ham_next_cpage(dbc, next_pgno, 0, 0)) != 0)
176 __ham_item_reset(dbc) in __ham_item_reset() argument
177 DBC *dbc; in __ham_item_reset()
184 dbp = dbc->dbp;
185 hcp = (HASH_CURSOR *)dbc->internal;
206 if (hcp->lock && hcp->dbc->txn == NULL)
207 (void)lock_put(hcp->dbc->dbp->dbenv->lk_info, hcp->lock);
235 __ham_item_done(dbc, dirty) in __ham_item_done() argument
236 DBC *dbc; in __ham_item_done()
243 dbp = dbc->dbp;
244 hcp = (HASH_CURSOR *)dbc->internal;
272 __ham_item_last(dbc, mode) in __ham_item_last() argument
273 DBC *dbc; in __ham_item_last()
279 hcp = (HASH_CURSOR *)dbc->internal;
280 if ((ret = __ham_item_reset(dbc)) != 0)
285 return (__ham_item_prev(dbc, mode));
292 __ham_item_first(dbc, mode) in __ham_item_first() argument
293 DBC *dbc; in __ham_item_first()
299 hcp = (HASH_CURSOR *)dbc->internal;
300 if ((ret = __ham_item_reset(dbc)) != 0)
304 return (__ham_item_next(dbc, mode));
316 __ham_item_prev(dbc, mode) in __ham_item_prev() argument
317 DBC *dbc; in __ham_item_prev()
325 dbp = dbc->dbp;
326 hcp = (HASH_CURSOR *)dbc->internal;
347 if ((ret = __ham_get_cpage(dbc, mode)) != 0)
359 return (__ham_item(dbc, mode));
363 return (__ham_item(dbc, mode));
364 } else if ((ret = __ham_get_cpage(dbc, mode)) != 0)
379 } else if ((ret = __ham_next_cpage(dbc,
384 return (__ham_item(dbc, mode));
401 if ((ret = __ham_get_cpage(dbc, mode)) != 0)
409 __ham_next_cpage(dbc, hcp->pgno, 0, 0)) != 0)
426 if ((ret = __ham_next_cpage(dbc, next_pgno, 0, 0)) != 0)
441 return (__ham_item(dbc, mode));
450 __ham_item_next(dbc, mode) in __ham_item_next() argument
451 DBC *dbc; in __ham_item_next()
456 hcp = (HASH_CURSOR *)dbc->internal;
510 return (__ham_item(dbc, mode));
600 __ham_del_pair(dbc, reclaim_page) in __ham_del_pair() argument
601 DBC *dbc; in __ham_del_pair()
614 dbp = dbc->dbp;
615 hcp = (HASH_CURSOR *)dbc->internal;
636 ret = __db_doff(dbc, pgno, __ham_del_page);
645 ret = __db_doff(dbc, pgno, __ham_del_page);
651 ret = __db_ddup(dbc, pgno, __ham_del_page);
668 if (DB_LOGGING(dbc)) {
677 dbc->txn, &new_lsn, 0, DELPAIR,
726 if (DB_LOGGING(dbc)) {
730 dbc->txn, &new_lsn, 0, dbp->log_fileid, PGNO(p),
763 (ret = __ham_del_page(dbc, n_pagep)) != 0)
789 if (DB_LOGGING(dbc)) {
791 dbc->txn, &new_lsn, 0, DELOVFL,
811 ret = __ham_del_page(dbc, p);
851 __ham_replpair(dbc, dbt, make_dup) in __ham_replpair() argument
852 DBC *dbc; in __ham_replpair()
876 dbp = dbc->dbp;
877 hcp = (HASH_CURSOR *)dbc->internal;
919 &tmp, &dbc->rkey.data, &dbc->rkey.size)) != 0)
923 ret = __ham_del_pair(dbc, 0);
925 ret = __ham_add_el(dbc, &tmp, dbt, H_KEYDATA);
933 H_DATAINDEX(hcp->bndx), &tdata, &dbc->rdata.data,
934 &dbc->rdata.size)) != 0)
938 if ((ret = __ham_del_pair(dbc, 0)) != 0) {
964 ret = __ham_add_el(dbc, &tmp, &tdata, type);
983 if (DB_LOGGING(dbc)) {
987 dbc->txn, &new_lsn, 0, dbp->log_fileid, PGNO(hcp->pagep),
1061 __ham_split_page(dbc, obucket, nbucket) in __ham_split_page() argument
1062 DBC *dbc; in __ham_split_page()
1077 dbp = dbc->dbp;
1078 hcp = (HASH_CURSOR *)dbc->internal;
1092 if (DB_LOGGING(dbc)) {
1096 dbc->txn, &new_lsn, 0, dbp->log_fileid, SPLITOLD,
1104 if (DB_LOGGING(dbc))
1135 if (DB_LOGGING(dbc)) {
1139 dbenv->lg_info, dbc->txn,
1147 __ham_add_ovflpage(dbc, *pp, 1, pp)) != 0)
1159 __ham_del_page(dbc, temp_pagep)) != 0)
1168 if (temp_pagep != NULL && DB_LOGGING(dbc)) {
1172 dbc->txn, &new_lsn, 0, dbp->log_fileid,
1188 (ret = __ham_del_page(dbc, temp_pagep)) != 0)
1194 if (DB_LOGGING(dbc)) {
1198 dbc->txn, &new_lsn, 0, dbp->log_fileid,
1206 dbc->txn, &new_lsn, 0, dbp->log_fileid,
1237 __ham_add_el(dbc, key, val, type) in __ham_add_el() argument
1238 DBC *dbc; in __ham_add_el()
1253 dbp = dbc->dbp;
1254 hcp = (HASH_CURSOR *)dbc->internal;
1285 __ham_next_cpage(dbc, next_pgno, 0, 0)) != 0)
1294 if ((ret = __ham_add_ovflpage(dbc,
1310 if ((ret = __db_poff(dbc,
1328 if ((ret = __db_poff(dbc,
1341 if (DB_LOGGING(dbc)) {
1349 dbc->txn, &new_lsn, 0, rectype,
1426 __ham_add_ovflpage(dbc, pagep, release, pp) in __ham_add_ovflpage() argument
1427 DBC *dbc; in __ham_add_ovflpage()
1438 dbp = dbc->dbp;
1439 hcp = (HASH_CURSOR *)dbc->internal;
1441 if ((ret = __ham_overflow_page(dbc, P_HASH, &new_pagep)) != 0)
1444 if (DB_LOGGING(dbc)) {
1446 dbc->txn, &new_lsn, 0, PUTOVFL,
1493 __ham_del_page(dbc, pagep) in __ham_del_page() argument
1494 DBC *dbc; in __ham_del_page()
1502 dbp = dbc->dbp;
1503 hcp = (HASH_CURSOR *)dbc->internal;
1519 if (DB_LOGGING(dbc)) {
1521 dbc->txn, &new_lsn, 0, DELPGNO,
1603 __ham_overflow_page(dbc, type, pp) in __ham_overflow_page() argument
1604 DBC *dbc; in __ham_overflow_page()
1617 dbp = dbc->dbp;
1618 hcp = (HASH_CURSOR *)dbc->internal;
1654 if (DB_LOGGING(dbc)) {
1656 dbc->txn, &new_lsn, 0, ALLOCPGNO,
1676 if (DB_LOGGING(dbc))
1708 __ham_init_ovflpages(dbc) in __ham_init_ovflpages() argument
1709 DBC *dbc; in __ham_init_ovflpages()
1718 dbp = dbc->dbp;
1719 hcp = (HASH_CURSOR *)dbc->internal;
1727 if (DB_LOGGING(dbc)) {
1729 dbc->txn, &new_lsn, 0, dbp->log_fileid, new_pgno,
1753 __ham_get_cpage(dbc, mode) in __ham_get_cpage() argument
1754 DBC *dbc; in __ham_get_cpage()
1761 dbp = dbc->dbp;
1762 hcp = (HASH_CURSOR *)dbc->internal;
1777 if (dbc->txn == NULL &&
1784 if (hcp->lock == 0 && (ret = __ham_lock_bucket(dbc, mode)) != 0)
1815 __ham_next_cpage(dbc, pgno, dirty, flags) in __ham_next_cpage() argument
1816 DBC *dbc; in __ham_next_cpage()
1826 dbp = dbc->dbp;
1827 hcp = (HASH_CURSOR *)dbc->internal;
1856 __ham_lock_bucket(dbc, mode) in __ham_lock_bucket() argument
1857 DBC *dbc; in __ham_lock_bucket()
1863 hcp = (HASH_CURSOR *)dbc->internal;
1864 dbc->lock.pgno = (db_pgno_t)(hcp->bucket);
1865 if (dbc->txn == NULL)
1866 ret = lock_get(dbc->dbp->dbenv->lk_info, dbc->locker, 0,
1867 &dbc->lock_dbt, mode, &hcp->lock);
1869 ret = lock_tget(dbc->dbp->dbenv->lk_info, dbc->txn, 0,
1870 &dbc->lock_dbt, mode, &hcp->lock);