Lines Matching refs:dbp
59 #define CD_SET(dbp, cp) { \
60 if (F_ISSET(dbp, DB_RE_RENUMBER)) \
63 #define CD_CLR(dbp, cp) { \
64 if (F_ISSET(dbp, DB_RE_RENUMBER)) \
67 #define CD_ISSET(dbp, cp) \
68 (F_ISSET(dbp, DB_RE_RENUMBER) && F_ISSET(cp, C_DELETED))
77 __ram_open(dbp, dbinfo)
78 DB *dbp;
89 dbp->internal = t;
90 __bam_setovflsize(dbp);
121 __ram_source(dbp, rp, dbinfo->re_source)) != 0)
127 F_ISSET(dbp, DB_RE_DELIMITER) ? dbinfo->re_delim : '\n';
128 rp->re_pad = F_ISSET(dbp, DB_RE_PAD) ? dbinfo->re_pad : ' ';
130 if (F_ISSET(dbp, DB_RE_FIXEDLEN)) {
132 __db_err(dbp->dbenv,
142 dbp->am_close = __ram_close;
143 dbp->del = __ram_delete;
144 dbp->put = __ram_put;
145 dbp->stat = __bam_stat;
146 dbp->sync = __ram_sync;
149 if ((ret = __bam_read_root(dbp)) != 0)
153 __bam_setovflsize(dbp);
158 if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
196 __ram_delete(dbp, txn, key, flags)
197 DB *dbp;
207 DB_PANIC_CHECK(dbp);
210 if ((ret = __db_delchk(dbp,
211 key, flags, F_ISSET(dbp, DB_AM_RDONLY))) != 0)
215 if ((ret = dbp->cursor(dbp, txn, &dbc, DB_WRITELOCK)) != 0)
248 DB *dbp;
254 dbp = dbc->dbp;
256 t = dbp->internal;
264 if (F_ISSET(dbp, DB_AM_CDB)) {
270 (ret = lock_get(dbp->dbenv->lk_info, dbc->locker,
304 if (F_ISSET(dbp, DB_RE_RENUMBER)) {
309 __ram_ca(dbp, cp->recno, CA_DELETE);
342 if (F_ISSET(dbp, DB_AM_CDB) && F_ISSET(dbc, DBC_RMW))
343 (void)__lock_downgrade(dbp->dbenv->lk_info, dbc->mylock,
353 __ram_put(dbp, txn, key, data, flags)
354 DB *dbp;
363 DB_PANIC_CHECK(dbp);
366 if ((ret = __db_putchk(dbp,
367 key, data, flags, F_ISSET(dbp, DB_AM_RDONLY), 0)) != 0)
371 if ((ret = dbp->cursor(dbp, txn, &dbc, DB_WRITELOCK)) != 0)
405 __ram_sync(dbp, flags)
406 DB *dbp;
419 if ((ret = __db_sync(dbp, flags)) != 0)
423 if ((ret = dbp->cursor(dbp, NULL, &dbc, 0)) != 0)
445 __ram_close(dbp)
446 DB *dbp;
450 rp = ((BTREE *)dbp->internal)->recno;
466 ((BTREE *)dbp->internal)->recno = NULL;
469 return (__bam_close(dbp));
484 DB *dbp;
487 dbp = dbc->dbp;
490 DB_PANIC_CHECK(dbp);
493 if ((ret = __db_cdelchk(dbp, flags,
494 F_ISSET(dbp, DB_AM_RDONLY), cp->recno != RECNO_OOB)) != 0)
503 if (F_ISSET(dbp, DB_AM_CDB))
535 DB *dbp;
540 dbp = dbc->dbp;
543 DB_PANIC_CHECK(dbp);
546 if ((ret = __db_cgetchk(dbc->dbp,
553 if (!F_ISSET(dbp, DB_AM_CDB)) {
582 if (CD_ISSET(dbp, cp))
626 &dbc->rkey.data, &dbc->rkey.ulen, dbp->db_malloc)) != 0)
659 if ((ret = __db_ret(dbp,
664 CD_CLR(dbp, cp);
692 DB *dbp;
696 dbp = dbc->dbp;
699 DB_PANIC_CHECK(dbp);
701 if ((ret = __db_cputchk(dbc->dbp, key, data, flags,
702 F_ISSET(dbc->dbp, DB_AM_RDONLY), cp->recno != RECNO_OOB)) != 0)
713 if (F_ISSET(dbp, DB_AM_CDB)) {
718 (ret = lock_get(dbp->dbenv->lk_info, dbc->locker,
757 __ram_ca(dbp, cp->recno, CA_IAFTER);
764 __ram_ca(dbp, cp->recno, CA_IBEFORE);
772 CD_CLR(dbp, cp);
774 err: if (F_ISSET(dbp, DB_AM_CDB) && F_ISSET(dbc, DBC_RMW))
775 (void)__lock_downgrade(dbp->dbenv->lk_info, dbc->mylock,
791 __ram_ca(dbp, recno, op)
792 DB *dbp;
802 DB_THREAD_LOCK(dbp);
803 for (dbc = TAILQ_FIRST(&dbp->active_queue);
811 CD_SET(dbp, cp);
823 DB_THREAD_UNLOCK(dbp);
839 DB *dbp;
842 dbp = dbc->dbp;
846 __db_err(dbp->dbenv, "illegal record number of 0");
856 return (dbp->type == DB_RECNO ?
871 DB *dbp;
876 dbp = dbc->dbp;
877 t = dbp->internal;
910 if (F_ISSET(dbp, DB_RE_FIXEDLEN)) {
937 __ram_source(dbp, rp, fname)
938 DB *dbp;
951 if ((ret = __db_appname(dbp->dbenv,
955 oflags = F_ISSET(dbp, DB_AM_RDONLY) ? DB_RDONLY : 0;
958 __db_err(dbp->dbenv, "%s: %s", rp->re_source, strerror(ret));
972 __db_err(dbp->dbenv, "%s: %s", rp->re_source, strerror(ret));
986 rp->re_irec = F_ISSET(dbp, DB_RE_FIXEDLEN) ? __ram_fmap : __ram_vmap;
998 DB *dbp;
1006 dbp = dbc->dbp;
1007 rp = ((BTREE *)dbp->internal)->recno;
1062 __db_err(dbp->dbenv, "%s: %s", rp->re_source, strerror(ret));
1068 * number and the dbp->get() function, instead of a cursor, so we find
1081 if (F_ISSET(dbp, DB_RE_FIXEDLEN)) {
1088 switch (ret = dbp->get(dbp, NULL, &key, &data, 0)) {
1099 if (F_ISSET(dbp, DB_RE_FIXEDLEN)) {
1113 if (!F_ISSET(dbp, DB_RE_FIXEDLEN)) {
1142 DB *dbp;
1153 dbp = dbc->dbp;
1154 rp = ((BTREE *)(dbp->internal))->recno;
1221 rp = ((BTREE *)(dbc->dbp->internal))->recno;
1273 DB *dbp;
1278 dbp = dbc->dbp;