Lines Matching refs:dbp
45 __db_init_wrapper(dbp) in __db_init_wrapper() argument
46 DB *dbp; in __db_init_wrapper()
48 dbp->close = __db_close;
49 dbp->cursor = __db_cursor;
50 dbp->del = NULL; /* !!! Must be set by access method. */
51 dbp->fd = __db_fd;
52 dbp->get = __db_get;
53 dbp->join = __db_join;
54 dbp->put = __db_put;
55 dbp->stat = NULL; /* !!! Must be set by access method. */
56 dbp->sync = __db_sync;
66 __db_cursor(dbp, txn, dbcp, flags) in __db_cursor() argument
67 DB *dbp; in __db_cursor()
77 DB_PANIC_CHECK(dbp);
80 DB_THREAD_LOCK(dbp);
81 if ((dbc = TAILQ_FIRST(&dbp->free_queue)) != NULL)
82 TAILQ_REMOVE(&dbp->free_queue, dbc, links);
84 DB_THREAD_UNLOCK(dbp);
89 dbc->dbp = dbp;
93 if (F_ISSET(dbp, DB_AM_LOCKING | DB_AM_CDB)) {
100 if (!F_ISSET(dbp, DB_AM_THREAD) &&
101 (adbc = TAILQ_FIRST(&dbp->active_queue)) != NULL)
104 if ((ret = lock_id(dbp->dbenv->lk_info,
108 memcpy(dbc->lock.fileid, dbp->fileid, DB_FILE_ID_LEN);
109 if (F_ISSET(dbp, DB_AM_CDB)) {
118 switch (dbp->type) {
133 DB_THREAD_LOCK(dbp);
141 TAILQ_INSERT_TAIL(&dbp->active_queue, dbc, links);
142 DB_THREAD_UNLOCK(dbp);
148 if (F_ISSET(dbp, DB_AM_CDB)) {
152 if ((ret = lock_get(dbp->dbenv->lk_info, dbc->locker, 0,
178 DB *dbp; local
181 dbp = dbc->dbp;
183 DB_PANIC_CHECK(dbp);
194 DB_THREAD_LOCK(dbp);
195 TAILQ_REMOVE(&dbp->active_queue, dbc, links);
196 DB_THREAD_UNLOCK(dbp);
203 if (F_ISSET(dbc->dbp, DB_AM_CDB) && dbc->mylock != LOCK_INVALID) {
204 ret = lock_put(dbc->dbp->dbenv->lk_info, dbc->mylock);
220 if (F_ISSET(dbp, DB_AM_LOCKING) && dbc->lid == dbc->locker) {
224 if ((t_ret = lock_vec(dbp->dbenv->lk_info,
230 DB_THREAD_LOCK(dbp);
231 TAILQ_INSERT_TAIL(&dbp->free_queue, dbc, links);
232 DB_THREAD_UNLOCK(dbp);
245 __db_cprint(dbp) in __db_cprint() argument
246 DB *dbp; in __db_cprint()
255 DB_THREAD_LOCK(dbp);
256 for (dbc = TAILQ_FIRST(&dbp->active_queue);
260 (u_int)dbc, (u_int)dbc->dbp, (u_int)dbc->txn,
265 DB_THREAD_UNLOCK(dbp);
281 DB *dbp; local
284 dbp = dbc->dbp;
287 DB_THREAD_LOCK(dbp);
288 TAILQ_REMOVE(&dbp->free_queue, dbc, links);
289 DB_THREAD_UNLOCK(dbp);
309 __db_fd(dbp, fdp) in __db_fd() argument
310 DB *dbp; in __db_fd()
313 DB_PANIC_CHECK(dbp);
319 return (__mp_xxx_fd(dbp->mpf, fdp));
327 __db_get(dbp, txn, key, data, flags) in __db_get() argument
328 DB *dbp; in __db_get()
336 DB_PANIC_CHECK(dbp);
338 if ((ret = __db_getchk(dbp, key, data, flags)) != 0)
341 if ((ret = dbp->cursor(dbp, txn, &dbc, 0)) != 0)
360 __db_put(dbp, txn, key, data, flags) in __db_put() argument
361 DB *dbp; in __db_put()
370 DB_PANIC_CHECK(dbp);
372 if ((ret = __db_putchk(dbp, key, data,
373 flags, F_ISSET(dbp, DB_AM_RDONLY), F_ISSET(dbp, DB_AM_DUP))) != 0)
376 if ((ret = dbp->cursor(dbp, txn, &dbc, DB_WRITELOCK)) != 0)
410 __db_sync(dbp, flags) in __db_sync() argument
411 DB *dbp; in __db_sync()
416 DB_PANIC_CHECK(dbp);
418 if ((ret = __db_syncchk(dbp, flags)) != 0)
422 if (F_ISSET(dbp, DB_AM_INMEM | DB_AM_RDONLY))
426 if ((ret = memp_fsync(dbp->mpf)) == DB_INCOMPLETE)