Lines Matching defs:dbc

82 	DBC *dbc;
158 if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
162 if ((ret = __ram_update(dbc,
167 if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
203 DBC *dbc;
215 if ((ret = dbp->cursor(dbp, txn, &dbc, DB_WRITELOCK)) != 0)
218 DEBUG_LWRITE(dbc, txn, "ram_delete", key, NULL, flags);
221 if ((ret = __ram_getno(dbc, key, &recno, 0)) != 0)
225 cp = dbc->internal;
227 ret = __ram_i_delete(dbc);
230 err: if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
242 __ram_i_delete(dbc)
243 DBC *dbc;
254 dbp = dbc->dbp;
255 cp = dbc->internal;
266 if (!F_ISSET(dbc, DBC_RMW | DBC_WRITER))
269 if (F_ISSET(dbc, DBC_RMW) &&
270 (ret = lock_get(dbp->dbenv->lk_info, dbc->locker,
271 DB_LOCK_UPGRADE, &dbc->lock_dbt, DB_LOCK_WRITE,
272 &dbc->mylock)) != 0)
277 if ((ret = __bam_rsearch(dbc, &cp->recno, S_DELETE, 1, &exact)) != 0)
306 if ((ret = __bam_ditem(dbc, h, indx)) != 0)
308 __bam_adjust(dbc, -1);
317 ret = __bam_dpages(dbc);
321 if ((ret = __bam_ditem(dbc, h, indx)) != 0)
332 if ((ret = __db_pitem(dbc,
339 __bam_stkrel(dbc, 0);
342 if (F_ISSET(dbp, DB_AM_CDB) && F_ISSET(dbc, DBC_RMW))
343 (void)__lock_downgrade(dbp->dbenv->lk_info, dbc->mylock,
359 DBC *dbc;
371 if ((ret = dbp->cursor(dbp, txn, &dbc, DB_WRITELOCK)) != 0)
374 DEBUG_LWRITE(dbc, txn, "ram_put", key, data, flags);
382 __ram_update(dbc, DB_MAX_RECORDS, 0) :
383 __ram_getno(dbc, key, &recno, 1);
387 ret = __ram_add(dbc, &recno, data, flags, 0);
390 if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
409 DBC *dbc;
423 if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
426 DEBUG_LWRITE(dbc, NULL, "ram_sync", NULL, NULL, flags);
429 ret = __ram_writeback(dbc);
432 if ((t_ret = dbc->c_close(dbc)) != 0 && ret == 0)
479 __ram_c_del(dbc, flags)
480 DBC *dbc;
487 dbp = dbc->dbp;
488 cp = dbc->internal;
497 DEBUG_LWRITE(dbc, dbc->txn, "ram_c_del", NULL, NULL, flags);
504 if (!F_ISSET(dbc, DBC_RMW | DBC_WRITER))
519 return (__ram_i_delete(dbc));
529 __ram_c_get(dbc, key, data, flags)
530 DBC *dbc;
540 dbp = dbc->dbp;
541 cp = dbc->internal;
546 if ((ret = __db_cgetchk(dbc->dbp,
555 F_SET(dbc, DBC_RMW);
560 DEBUG_LREAD(dbc, dbc->txn, "ram_c_get",
606 if (((ret = __ram_update(dbc,
609 if ((ret = __bam_nrecs(dbc, &cp->recno)) != 0)
618 if ((ret = __ram_getno(dbc, key, &cp->recno, 0)) != 0)
626 &dbc->rkey.data, &dbc->rkey.ulen, dbp->db_malloc)) != 0)
630 if ((ret = __bam_rsearch(dbc, &cp->recno,
631 F_ISSET(dbc, DBC_RMW) ? S_FIND_WR : S_FIND, 1, &exact)) != 0)
651 (void)__bam_stkrel(dbc, 0);
660 h, indx, data, &dbc->rdata.data, &dbc->rdata.ulen)) != 0)
667 (void)__bam_stkrel(dbc, 0);
671 F_CLR(dbc, DBC_RMW);
686 __ram_c_put(dbc, key, data, flags)
687 DBC *dbc;
696 dbp = dbc->dbp;
697 cp = dbc->internal;
701 if ((ret = __db_cputchk(dbc->dbp, key, data, flags,
702 F_ISSET(dbc->dbp, DB_AM_RDONLY), cp->recno != RECNO_OOB)) != 0)
705 DEBUG_LWRITE(dbc, dbc->txn, "ram_c_put", NULL, data, flags);
714 if (!F_ISSET(dbc, DBC_RMW | DBC_WRITER))
717 if (F_ISSET(dbc, DBC_RMW) &&
718 (ret = lock_get(dbp->dbenv->lk_info, dbc->locker,
719 DB_LOCK_UPGRADE, &dbc->lock_dbt, DB_LOCK_WRITE,
720 &dbc->mylock)) != 0)
735 if ((ret = __bam_split(dbc, arg)) != 0)
739 if ((ret = __bam_rsearch(dbc, &cp->recno, S_INSERT, 1, &exact)) != 0)
745 if ((ret = __bam_iitem(dbc, &cp->csp->page,
747 if ((ret = __bam_stkrel(dbc, 0)) != 0)
751 if ((ret = __bam_stkrel(dbc, 0)) != 0)
774 err: if (F_ISSET(dbp, DB_AM_CDB) && F_ISSET(dbc, DBC_RMW))
775 (void)__lock_downgrade(dbp->dbenv->lk_info, dbc->mylock,
797 DBC *dbc;
803 for (dbc = TAILQ_FIRST(&dbp->active_queue);
804 dbc != NULL; dbc = TAILQ_NEXT(dbc, links)) {
805 cp = dbc->internal;
833 __ram_getno(dbc, key, rep, can_create)
834 DBC *dbc;
842 dbp = dbc->dbp;
857 __ram_update(dbc, recno, can_create) : 0);
865 __ram_update(dbc, recno, can_create)
866 DBC *dbc;
876 dbp = dbc->dbp;
891 if ((ret = __bam_nrecs(dbc, &nrecs)) != 0)
894 if ((ret = rp->re_irec(dbc, recno)) != 0)
896 if ((ret = __bam_nrecs(dbc, &nrecs)) != 0)
907 dbc->rdata.dlen = 0;
908 dbc->rdata.doff = 0;
909 dbc->rdata.flags = 0;
911 if (dbc->rdata.ulen < rp->re_len) {
913 __os_realloc(&dbc->rdata.data, rp->re_len)) != 0) {
914 dbc->rdata.ulen = 0;
915 dbc->rdata.data = NULL;
918 dbc->rdata.ulen = rp->re_len;
920 dbc->rdata.size = rp->re_len;
921 memset(dbc->rdata.data, rp->re_pad, rp->re_len);
923 dbc->rdata.size = 0;
926 if ((ret = __ram_add(dbc,
927 &nrecs, &dbc->rdata, 0, BI_DELETED)) != 0)
995 __ram_writeback(dbc)
996 DBC *dbc;
1006 dbp = dbc->dbp;
1038 __ram_update(dbc, DB_MAX_RECORDS, 0)) != 0 && ret != DB_NOTFOUND)
1138 __ram_fmap(dbc, top)
1139 DBC *dbc;
1150 if ((ret = __bam_nrecs(dbc, &recno)) != 0)
1153 dbp = dbc->dbp;
1156 if (dbc->rdata.ulen < rp->re_len) {
1157 if ((ret = __os_realloc(&dbc->rdata.data, rp->re_len)) != 0) {
1158 dbc->rdata.ulen = 0;
1159 dbc->rdata.data = NULL;
1162 dbc->rdata.ulen = rp->re_len;
1166 data.data = dbc->rdata.data;
1177 for (p = dbc->rdata.data;
1197 if ((ret = __ram_add(dbc, &recno, &data, 0, 0)) != 0)
1211 __ram_vmap(dbc, top)
1212 DBC *dbc;
1221 rp = ((BTREE *)(dbc->dbp->internal))->recno;
1223 if ((ret = __bam_nrecs(dbc, &recno)) != 0)
1250 if ((ret = __ram_add(dbc, &recno, &data, 0, 0)) != 0)
1265 __ram_add(dbc, recnop, data, flags, bi_flags)
1266 DBC *dbc;
1278 dbp = dbc->dbp;
1279 cp = dbc->internal;
1282 if ((ret = __bam_rsearch(dbc, recnop,
1318 switch (ret = __bam_iitem(dbc,
1339 (void)__bam_stkrel(dbc, 0);
1342 if ((ret = __bam_split(dbc, recnop)) != 0)
1353 __bam_stkrel(dbc, 0);