Lines Matching refs:sdbp
591 __db_associate(dbp, ip, txn, sdbp, callback, flags)
592 DB *dbp, *sdbp;
620 if ((ret = __db_cursor(sdbp, ip, txn, &sdbc, 0)) != 0)
651 sdbp->s_callback = callback;
652 sdbp->s_primary = dbp;
654 sdbp->stored_get = sdbp->get;
655 sdbp->get = __db_secondary_get;
657 sdbp->stored_close = sdbp->close;
658 sdbp->close = __db_secondary_close_pp;
660 F_SET(sdbp, DB_AM_SECONDARY);
663 FLD_SET(sdbp->s_assoc_flags, DB_ASSOC_IMMUTABLE_KEY);
673 DB_ASSERT(env, sdbp->s_refcnt == 0);
674 sdbp->s_refcnt = 1;
675 LIST_INSERT_HEAD(&dbp->s_secondaries, sdbp, s_links);
692 if ((ret = __db_cursor(sdbp, ip, txn, &sdbc,
693 CDB_LOCKING(sdbp->env) ? DB_WRITECURSOR : 0)) != 0)
705 if ((ret = callback(sdbp, &key, &data, &skey)) != 0) {
712 __db_check_skeyset(sdbp, &skey);
720 SWAP_IF_NEEDED(sdbp, &key);
727 SWAP_IF_NEEDED(sdbp, &key);
755 __db_secondary_get(sdbp, txn, skey, data, flags)
756 DB *sdbp;
761 DB_ASSERT(sdbp->env, F_ISSET(sdbp, DB_AM_SECONDARY));
762 return (__db_pget_pp(sdbp, txn, skey, NULL, data, flags));
774 __db_secondary_close(sdbp, flags)
775 DB *sdbp;
783 primary = sdbp->s_primary;
796 DB_ASSERT(env, sdbp->s_refcnt != 0);
797 if (--sdbp->s_refcnt == 0) {
798 LIST_REMOVE(sdbp, s_links);
805 * sdbp->close is this function; call the real one explicitly if
808 return (doclose ? __db_close(sdbp, NULL, flags) : 0);
821 DB *dbp, *sdbp;
829 sdbp = NULL;
872 if ((ret = __db_s_first(dbp, &sdbp)) != 0)
874 for (; sdbp != NULL && ret == 0; ret = __db_s_next(&sdbp, dbc->txn)) {
876 if ((ret = sdbp->s_callback(sdbp, key, data, &skey)) != 0) {
890 if (sdbp->s_foreign != NULL) {
891 if ((ret = __db_cursor_int(sdbp->s_foreign,
892 dbc->thread_info, dbc->txn, sdbp->s_foreign->type,
905 if ((ret = __db_cursor_int(sdbp, dbc->thread_info, dbc->txn,
906 sdbp->type, PGNO_INVALID, 0, dbc->locker, &sdbc)) != 0) {
922 if (!F_ISSET(sdbp, DB_AM_DUP)) {
928 cmp = __bam_defcmp(sdbp, &oldpkey, key);
958 if (sdbp != NULL &&
959 (t_ret = __db_s_done(sdbp, dbc->txn)) != 0 && ret == 0)