rpmdb/rpmdb.h

Go to the documentation of this file.

#ifndef H_RPMDB
#define H_RPMDB
/*@-bounds@*/

#include <assert.h>
#include <mire.h>

#include <rpmtypes.h>
#include <rpmtag.h>     /* XXX Header typedef */

#if defined(_RPMDB_INTERNAL)
#if defined(WITH_DB)
#include <db.h>
#else
#include "db_emu.h"
#endif
#endif

#if defined(_RPMDB_INTERNAL)
#define DBT_INIT /*@-fullinitblock@*/ {0} /*@-fullinitblock@*/  /* -Wno-missing-field-initializers */
#endif

/*@-exportlocal@*/
/*@unchecked@*/
extern int _rpmdb_debug;
/*@unchecked@*/
extern int _rpmmi_debug;
/*@=exportlocal@*/

#ifdef  NOTYET

typedef /*@abstract@*/ /*@refcounted@*/ struct rpmdb_s * rpmdb;

typedef /*@abstract@*/ /*@refcounted@*/ struct rpmmi_s * rpmmi;
#endif

typedef /*@abstract@*/ struct _dbiIndexItem * dbiIndexItem;

typedef /*@abstract@*/ struct _dbiIndexSet * dbiIndexSet;

typedef /*@abstract@*/ struct _dbiIndex * dbiIndex;

#if defined(_RPMDB_INTERNAL)
#include <rpmio.h>
#include <rpmbf.h>
#include <rpmsw.h>

#if !defined(SWIG)      /* XXX inline dbiFoo() need */

struct _dbiIndexItem {
    uint32_t hdrNum;                    
    uint32_t tagNum;                    
};

struct _dbiIndexSet {
/*@owned@*/
    struct _dbiIndexItem * recs;        
    unsigned int count;                 
};

struct _dbiVec {
    const char * dbv_version;           
    int dbv_major;                      
    int dbv_minor;                      
    int dbv_patch;                      
    int (*open) (rpmdb rpmdb, rpmTag tag, /*@out@*/ dbiIndex * dbip)
        /*@globals fileSystem @*/
        /*@modifies *dbip, fileSystem @*/;

    int (*close) (/*@only@*/ dbiIndex dbi, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/;

    int (*sync) (dbiIndex dbi, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies fileSystem @*/;

    int (*associate) (dbiIndex dbi, dbiIndex dbisecondary,
                int (*callback) (DB *, const DBT *, const DBT *, DBT *),
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/;

    int (*associate_foreign) (dbiIndex dbi, dbiIndex dbisecondary,
                int (*callback) (DB *, const DBT *, DBT *, const DBT *, int *),
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/;

    int (*join) (dbiIndex dbi, DBC ** curslist, /*@out@*/ DBC ** dbcp,
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcp, fileSystem @*/;

    int (*exists) (dbiIndex dbi, DBT * key, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/;

    int (*seqno) (dbiIndex dbi, /*@null@*/ int64_t * seqnop, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *seqnop, fileSystem @*/;

    int (*copen) (dbiIndex dbi, /*@null@*/ DB_TXN * txnid,
                        /*@out@*/ DBC ** dbcp, unsigned int dbiflags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *txnid, *dbcp, fileSystem @*/;

    int (*cclose) (dbiIndex dbi, /*@only@*/ DBC * dbcursor, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcursor, fileSystem @*/;

    int (*cdup) (dbiIndex dbi, DBC * dbcursor, /*@out@*/ DBC ** dbcp,
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcp, fileSystem @*/;

    int (*cdel) (dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                        unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, fileSystem @*/;

    int (*cget) (dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                        unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, *key, *data, fileSystem @*/;

    int (*cpget) (dbiIndex dbi, /*@null@*/ DBC * dbcursor,
                DBT * key, DBT * pkey, DBT * data, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, *key, *pkey, *data, fileSystem @*/;

    int (*cput) (dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                        unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, fileSystem @*/;

    int (*ccount) (dbiIndex dbi, DBC * dbcursor,
                        /*@out@*/ unsigned int * countp,
                        unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, fileSystem @*/;

    int (*byteswapped) (dbiIndex dbi)
        /*@globals fileSystem @*/
        /*@modifies fileSystem @*/;

    int (*stat) (dbiIndex dbi, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/;
};

struct _dbiIndex {
    struct rpmioItem_s _item;   
/*@relnull@*/
    const char * dbi_root;      
/*@null@*/
    const char * dbi_home;      
/*@relnull@*/
    const char * dbi_file;      
/*@relnull@*/
    const char * dbi_subfile;
/*@null@*/
    const char * dbi_tmpdir;    
    int dbi_ecflags;            
    int dbi_cflags;             
    int dbi_oeflags;            
    int dbi_eflags;             
    int dbi_oflags;             
    int dbi_tflags;             
    int dbi_type;               
    unsigned dbi_mode;          
    int dbi_perms;              
    long dbi_shmkey;            
    int dbi_api;                
    int dbi_use_dbenv;          
    int dbi_no_fsync;           
    int dbi_no_dbsync;          
    int dbi_lockdbfd;           
    int dbi_temporary;          
    int dbi_debug;

    rpmbf dbi_bf;

/*@null@*/
    char * dbi_host;
    unsigned long dbi_cl_timeout;
    unsigned long dbi_sv_timeout;

        /* dbenv parameters */
    int dbi_lorder;
/*@unused@*/
    /* XXX db-4.3.14 adds dbenv as 1st arg. */
    void (*db_errcall) (void * dbenv, const char *db_errpfx, char *buffer)
        /*@globals fileSystem @*/
        /*@modifies fileSystem @*/;
/*@unused@*/ /*@shared@*/
    FILE *      dbi_errfile;
    const char * dbi_errpfx;
    int dbi_region_init;
    unsigned int dbi_thread_count;

        /* locking sub-system parameters */
        /* logging sub-system parameters */
        /* mpool sub-system parameters */
        /* mutex sub-system parameters */
        /* replication sub-system parameters */

        /* sequences sub-system parameters */
    const char * dbi_seq_id;
    unsigned int dbi_seq_cachesize;
    unsigned int dbi_seq_flags;
    int64_t dbi_seq_initial;
    int64_t dbi_seq_min;
    int64_t dbi_seq_max;

        /* transaction sub-system parameters */
#if 0
    int (*dbi_tx_recover) (DB_ENV *dbenv, DBT *log_rec,
                                DB_LSN *lsnp, int redo, void *info)
        /*@globals fileSystem @*/
        /*@modifies fileSystem @*/;
#endif
        /* dbinfo parameters */
    int dbi_pagesize;           
    int dbi_heapsize;           
/*@unused@*/ /*@null@*/
    void * (*dbi_malloc) (size_t nbytes)
        /*@*/;
        /* hash access parameters */
    unsigned int dbi_h_ffactor; 
    unsigned int (*dbi_h_hash_fcn) (DB *, const void *bytes,
                                unsigned int length)
        /*@*/;
    unsigned int dbi_h_nelem;   
    unsigned int dbi_h_flags;   
    int (*dbi_h_dup_compare_fcn) (DB *, const DBT *, const DBT *)
        /*@*/;
        /* btree access parameters */
    int dbi_bt_flags;
    int dbi_bt_minkey;
    int (*dbi_bt_compare_fcn) (DB *, const DBT *, const DBT *)
        /*@*/;
    int (*dbi_bt_dup_compare_fcn) (DB *, const DBT *, const DBT *)
        /*@*/;
    size_t (*dbi_bt_prefix_fcn) (DB *, const DBT *, const DBT *)
        /*@*/;
        /* recno access parameters */
    int dbi_re_flags;
    int dbi_re_delim;
    unsigned int dbi_re_len;
    int dbi_re_pad;
    const char * dbi_re_source;
        /* queue access parameters */
    unsigned int dbi_q_extentsize;

/*@null@*/
    const char * dbi_primary;   
/*@null@*/
    const char * dbi_foreign;

/*@refcounted@*/
    rpmdb dbi_rpmdb;            
    rpmTag dbi_rpmtag;          
    size_t dbi_jlen;            
/*@only@*/ /*@relnull@*/
    DB_SEQUENCE * dbi_seq;      
/*@only@*/ /*@relnull@*/
    DB * dbi_db;                
/*@only@*/ /*@null@*/
    DB_TXN * dbi_txnid;         
/*@only@*/ /*@null@*/
    void * dbi_stats;           
/*@observer@*/
    const struct _dbiVec * dbi_vec;     
};
#endif  /* !defined(SWIG) */

struct rpmdb_s {
    struct rpmioItem_s _item;   
/*@owned@*/ /*@relnull@*/
    const char * db_root;       
/*@owned@*/
    const char * db_home;       
    int         db_flags;
    int         db_mode;        
    int         db_perms;       
    int         db_api;         
/*@owned@*/
    const char * db_errpfx;     
    int         db_remove_env;  
    uint32_t    db_maxkey;      
    int         db_chrootDone;  
    void (*db_errcall) (const char * db_errpfx, char * buffer)
        /*@*/;
/*@shared@*/
    FILE *      db_errfile;     
/*@only@*/
    void * (*db_malloc) (size_t nbytes)
        /*@*/;
/*@only@*/
    void * (*db_realloc) (/*@only@*//*@null@*/ void * ptr, size_t nbytes)
        /*@*/;
    void (*db_free) (/*@only@*/ void * ptr)
        /*@modifies *ptr @*/;

    int (*db_export) (rpmdb db, Header h, int adding);

/*@refcounted@*/
    Header db_h;                
    rpmdb       db_next;        
    int         db_opens;       
    void *      db_dbenv;       
    void *      db_txn;         
    DB_LOGC *   db_logc;        
    DB_MPOOLFILE *db_mpf;       
    tagStore_t  db_tags;        
    size_t      db_ndbi;        
/*@only@*/ /*@null@*/
    dbiIndex * _dbi;            
    struct rpmop_s db_getops;   
    struct rpmop_s db_putops;   
    struct rpmop_s db_delops;   
#if defined(__LCLINT__)
/*@refs@*/
    int nrefs;                  
#endif
};
#endif  /* defined(_RPMDB_INTERNAL) */

#ifdef __cplusplus
extern "C" {
#endif

#if defined(_RPMDB_INTERNAL)
/*@-exportlocal@*/
#if defined(WITH_DB) || defined(WITH_SQLITE)

/*@unused@*/ /*@only@*/ /*@null@*/
dbiIndex db3New(rpmdb rpmdb, rpmTag tag)
        /*@globals rpmGlobalMacroContext, h_errno, internalState @*/
        /*@modifies rpmGlobalMacroContext, internalState @*/;

/*@null@*/
dbiIndex db3Free(/*@only@*/ /*@null@*/ dbiIndex dbi)
        /*@globals fileSystem, internalState @*/
        /*@modifies dbi, fileSystem, internalState @*/;
#define db3Free(_dbi)   \
    ((dbiIndex)rpmioFreePoolItem((rpmioItem)(_dbi), __FUNCTION__, __FILE__, __LINE__))

/*@-redecl@*/
/*@exposed@*/
extern const char * prDbiOpenFlags(int dbflags, int print_dbenv_flags)
        /*@*/;
/*@=redecl@*/
#endif

/*@only@*/ /*@null@*/ dbiIndex dbiOpen(/*@null@*/ rpmdb db, rpmTag tag,
                unsigned int flags)
        /*@globals rpmGlobalMacroContext, errno, h_errno, internalState @*/
        /*@modifies db, rpmGlobalMacroContext, errno, internalState @*/;

void * dbiStatsAccumulator(dbiIndex dbi, int opx)
        /*@*/;

#if !defined(SWIG)
/*@-globuse -mustmod @*/ /* FIX: vector annotations */
/*@unused@*/ static inline
int dbiCopen(dbiIndex dbi, /*@null@*/ DB_TXN * txnid,
                /*@out@*/ DBC ** dbcp, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcp, fileSystem @*/
{
    return (*dbi->dbi_vec->copen) (dbi, txnid, dbcp, flags);
}

/*@unused@*/ static inline
int dbiCclose(dbiIndex dbi, /*@only@*/ DBC * dbcursor, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcursor, fileSystem @*/
{
    return (*dbi->dbi_vec->cclose) (dbi, dbcursor, flags);
}

/*@unused@*/ static inline
int dbiCdup(dbiIndex dbi, DBC * dbcursor, /*@out@*/ DBC ** dbcp,
                unsigned int flags)
        /*@modifies dbi, *dbcp @*/
{
    return (*dbi->dbi_vec->cdup) (dbi, dbcursor, dbcp, flags);
}

/*@unused@*/ static inline
int dbiDel(dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                unsigned int flags)
        /*@globals fileSystem, internalState @*/
        /*@modifies dbi, *dbcursor, fileSystem, internalState @*/
{
    rpmop sw = (rpmop)dbiStatsAccumulator(dbi, 16);     /* RPMTS_OP_DBDEL */
    int rc;
    assert(key->data != NULL && key->size > 0);
    (void) rpmswEnter(sw, 0);
    rc = (dbi->dbi_vec->cdel) (dbi, dbcursor, key, data, flags);
    (void) rpmswExit(sw, data->size);
    return rc;
}

/*@unused@*/ static inline
int dbiGet(dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                unsigned int flags)
        /*@globals fileSystem, internalState @*/
        /*@modifies dbi, *dbcursor, *key, *data, fileSystem, internalState @*/
{
    rpmop sw = (rpmop)dbiStatsAccumulator(dbi, 14);     /* RPMTS_OP_DBGET */
    int rc;
    (void) rpmswEnter(sw, 0);
    rc = (dbi->dbi_vec->cget) (dbi, dbcursor, key, data, flags);
    (void) rpmswExit(sw, data->size);
    return rc;
}

/*@unused@*/ static inline
int dbiPget(dbiIndex dbi, /*@null@*/ DBC * dbcursor,
                DBT * key, DBT * pkey, DBT * data, unsigned int flags)
        /*@globals fileSystem, internalState @*/
        /*@modifies dbi, *dbcursor, *key, *pkey, *data, fileSystem, internalState @*/
{
    rpmop sw = (rpmop)dbiStatsAccumulator(dbi, 14);     /* RPMTS_OP_DBGET */
    int rc;
    (void) rpmswEnter(sw, 0);
    rc = (dbi->dbi_vec->cpget) (dbi, dbcursor, key, pkey, data, flags);
    (void) rpmswExit(sw, data->size);
    return rc;
}

/*@unused@*/ static inline
int dbiPut(dbiIndex dbi, /*@null@*/ DBC * dbcursor, DBT * key, DBT * data,
                unsigned int flags)
        /*@globals fileSystem, internalState @*/
        /*@modifies dbi, *dbcursor, *key, fileSystem, internalState @*/
{
    rpmop sw = (rpmop)dbiStatsAccumulator(dbi, 15);     /* RPMTS_OP_DBPUT */
    int rc;
    assert(key->data != NULL && key->size > 0 && data->data != NULL && data->size > 0);
    (void) rpmswEnter(sw, 0);
    rc = (dbi->dbi_vec->cput) (dbi, dbcursor, key, data, flags);
    (void) rpmswExit(sw, data->size);
    return rc;
}

/*@unused@*/ static inline
int dbiCount(dbiIndex dbi, DBC * dbcursor, /*@out@*/ unsigned int * countp,
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies *dbcursor, fileSystem @*/
{
    return (*dbi->dbi_vec->ccount) (dbi, dbcursor, countp, flags);
}

/*@unused@*/ static inline
int dbiClose(/*@only@*/ dbiIndex dbi, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/
{
    return (*dbi->dbi_vec->close) (dbi, flags);
}

/*@unused@*/ static inline
int dbiSync (dbiIndex dbi, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies fileSystem @*/
{
    return (*dbi->dbi_vec->sync) (dbi, flags);
}

/*@unused@*/ static inline
int dbiExists(dbiIndex dbi, /*@out@*/ DBT * key, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/
{
    return (*dbi->dbi_vec->exists) (dbi, key, flags);
}

/*@unused@*/ static inline
int dbiSeqno(dbiIndex dbi, /*@null@*/ int64_t * seqnop, unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *seqnop, fileSystem @*/
{
    return (*dbi->dbi_vec->seqno) (dbi, seqnop, flags);
}

/*@unused@*/ static inline
int dbiAssociate(dbiIndex dbi, dbiIndex dbisecondary,
                int (*callback) (DB *, const DBT *, const DBT *, DBT *),
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, fileSystem @*/
{
    return (*dbi->dbi_vec->associate) (dbi, dbisecondary, callback, flags);
}

/*@unused@*/ static inline
int dbiJoin(dbiIndex dbi, DBC ** curslist, /*@out@*/ DBC ** dbcp,
                unsigned int flags)
        /*@globals fileSystem @*/
        /*@modifies dbi, *dbcp, fileSystem @*/
{
    return (*dbi->dbi_vec->join) (dbi, curslist, dbcp, flags);
}

/*@unused@*/ static inline
int dbiByteSwapped(dbiIndex dbi)
        /*@modifies dbi @*/
{
    return (*dbi->dbi_vec->byteswapped) (dbi);
}

/*@unused@*/ static inline
int dbiStat(dbiIndex dbi, unsigned int flags)
        /*@modifies dbi @*/
{
    return (*dbi->dbi_vec->stat) (dbi, flags);
}

/*@unused@*/ static inline /*@null@*/
DB_TXN * dbiTxnid(dbiIndex dbi)
        /*@*/
{
    rpmdb rpmdb = (dbi ? dbi->dbi_rpmdb : NULL);
    DB_TXN * _txn = (DB_TXN*)(rpmdb ? rpmdb->db_txn : NULL);
    return _txn;
}

#if defined(_RPMDB_INTERNAL)

#if !defined(__LCLINT__)
/*@unused@*/ static inline
int rpmlkId(rpmdb rpmdb, uint32_t *_idp)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x080)
        ? dbenv->lock_id(dbenv, _idp) : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p) id 0x%x rc %d\n", "dbenv->lock_id", dbenv, _idp, *_idp, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlkIdFree(rpmdb rpmdb, uint32_t _id)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x080)
        ? dbenv->lock_id_free(dbenv, _id) : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%u) rc %d\n", "dbenv->lock_id_free", dbenv, (unsigned)_id, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlkGet(rpmdb rpmdb, DBT * _object, uint32_t _lockmode, void * _lock)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    uint32_t _locker = 0x12344321;
    uint32_t _flags = 0;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x080)
        ? dbenv->lock_get(dbenv, _locker, _flags, _object, (db_lockmode_t)_lockmode, (DB_LOCK*)_lock)
        : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,0x%x,0x%x,%p,0x%x,%p) rc %d\n", "dbenv->lock_get", dbenv, _locker, _flags, _object, _lockmode, _lock, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlkPut(rpmdb rpmdb, void * _lock)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x080)
        ? dbenv->lock_put(dbenv, (DB_LOCK*)_lock)
        : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p) rc %d\n", "dbenv->lock_put", dbenv, _lock, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcOpen(rpmdb rpmdb)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    DB_LOGC * _logc = NULL;
    uint32_t _flags = 0;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x100)
        ? dbenv->log_cursor(dbenv, &_logc, _flags) : ENOTSUP;
    rpmdb->db_logc = (!rc ? _logc : NULL);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,0x%x) logc %p rc %d\n", "dbenv->log_cursor", dbenv, &_logc, _flags, _logc, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcGet(rpmdb rpmdb, DB_LSN * _lsn, DBT * data, uint32_t flags)
{
    DB_LOGC * _logc = rpmdb->db_logc;
    int rc = (_logc ? _logc->get(_logc, _lsn, data, flags) : ENOTSUP);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,%p,0x%x) rc %d\n", "logc->get", _logc, _lsn, data, flags, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcClose(rpmdb rpmdb)
{
    DB_LOGC * _logc = rpmdb->db_logc;
    uint32_t _flags = 0;
    int rc = (_logc ? _logc->close(_logc, _flags) : ENOTSUP);
    rpmdb->db_logc = NULL;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p) rc %d\n", "logc->close", _logc, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcFile(rpmdb rpmdb, const DB_LSN * _lsn, char * name, size_t len)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = dbenv->log_file(dbenv, _lsn, name, len);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,%p[%u]) \"%s\" rc %d\n", "dbenv->log_file", dbenv, _lsn, name, (unsigned)len, name, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcFlush(rpmdb rpmdb, const DB_LSN * _lsn)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = dbenv->log_flush(dbenv, _lsn);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p) rc %d\n", "dbenv->log_flush", dbenv, _lsn, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcPrintf(rpmdb rpmdb, const char * fmt, void *_A1, void *_A2, void *_A3, void *_A4, void *_A5)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    DB_TXN * _txnid = (DB_TXN*)rpmdb->db_txn;
    int rc = dbenv->log_printf(dbenv, _txnid, fmt, _A1, _A2, _A3, _A4, _A5);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,\"%s\", ...) rc %d\n", "dbenv->log_printf", dbenv, _txnid, fmt, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmlgcPut(rpmdb rpmdb, DB_LSN * _lsn, const DBT * data, uint32_t flags)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int rc = dbenv->log_put(dbenv, _lsn, data, flags);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,%p,0x%x) rc %d\n", "dbenv->log_put", dbenv, _lsn, data, flags, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfSyncAll(rpmdb rpmdb)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    DB_LSN * _lsn = NULL;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x100)
        ? dbenv->memp_sync(dbenv, _lsn) : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p) rc %d\n", "dbenv->memp_sync", dbenv, _lsn, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfTrickle(rpmdb rpmdb)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    int _percent = 20;
    int _nwrote = 0;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x100)
        ? dbenv->memp_trickle(dbenv, _percent, &_nwrote) : ENOTSUP;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%d) nwrote %d rc %d\n", "dbenv->memp_trickle", dbenv, _percent, _nwrote, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfClose(rpmdb rpmdb)
{
    DB_MPOOLFILE * mpf = rpmdb->db_mpf;
    uint32_t _flags = 0;
    int rc = (mpf ? mpf->close(mpf, _flags) : ENOTSUP);
    rpmdb->db_mpf = NULL;
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p) rc %d\n", "mpf->close", mpf, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfGet(rpmdb rpmdb, uint32_t * _pgnop, uint32_t _flags, void ** _pagep)
{
    DB_MPOOLFILE * mpf = rpmdb->db_mpf;
    DB_TXN * _txnid = (DB_TXN*)rpmdb->db_txn;
    int rc = mpf->get(mpf, _pgnop, _txnid, _flags, _pagep);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,%p,0x%x,%p) rc %d\n", "mpf->get", mpf, _pgnop, _txnid, _flags, _pagep, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfOpen(rpmdb rpmdb, /*@null@*/ const char * fn, uint32_t flags)
{
    DB_ENV * dbenv = (DB_ENV*)rpmdb->db_dbenv;
    DB_MPOOLFILE * mpf = NULL;
    int _perms = rpmdb->_dbi[0]->dbi_perms;
    size_t _pagesize = BUFSIZ;
    uint32_t _fcreate_flags = 0;
    int rc = (rpmdb->_dbi[0]->dbi_eflags & 0x100)
        ? dbenv->memp_fcreate(dbenv, &mpf, _fcreate_flags) : ENOTSUP;

if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,&mpf,0x%x) mpf %p rc %d\n", "dbenv->memp_fcreate", dbenv, _fcreate_flags, mpf, rc);
    if (rc) goto exit;
    rc = mpf->open(mpf, fn, flags, _perms, _pagesize);
    rpmdb->db_mpf = (!rc ? mpf : NULL);         /* FIXME: mpf memleak */
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%s,0x%x) rc %d\n", "mpf->open", mpf, fn, flags, rc);

exit:
    return rc;
}

/*@unused@*/ static inline
int rpmmpfPut(rpmdb rpmdb, void * _page, uint32_t flags)
{
    DB_MPOOLFILE * mpf = rpmdb->db_mpf;
    uint32_t _priority = DB_PRIORITY_DEFAULT;
    int rc = mpf->put(mpf, _page, (DB_CACHE_PRIORITY)_priority, flags);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p,%p,0x%x,0x%x) rc %d\n", "mpf->put", mpf, _page, _priority, flags, rc);
    return rc;
}

/*@unused@*/ static inline
int rpmmpfSync(rpmdb rpmdb)
{
    DB_MPOOLFILE * mpf = rpmdb->db_mpf;
    int rc = (mpf ? mpf->sync(mpf) : ENOTSUP);
if (_rpmdb_debug)
fprintf(stderr, "<-- %s(%p) rc %d\n", "mpf->close", mpf, rc);
    return rc;
}
#endif  /* __LCLINT__ */

#endif  /* _RPMDB_INTERNAL */
/*@=globuse =mustmod @*/
#endif  /* !defined(SWIG) */

/*@=exportlocal@*/

/*@null@*/
dbiIndexSet dbiFreeIndexSet(/*@only@*/ /*@null@*/ dbiIndexSet set)
        /*@modifies set @*/;

unsigned int dbiIndexSetCount(dbiIndexSet set)
        /*@*/;

uint32_t dbiIndexRecordOffset(dbiIndexSet set, unsigned int recno)
        /*@*/;

uint32_t dbiIndexRecordFileNumber(dbiIndexSet set, unsigned int recno)
        /*@*/;
#endif  /* defined(_RPMDB_INTERNAL) */

/*@unused@*/ /*@null@*/
rpmdb rpmdbUnlink (/*@killref@*/ /*@only@*/ rpmdb db, const char * msg)
        /*@modifies db @*/;
#define rpmdbUnlink(_db, _msg)  \
        ((rpmdb)rpmioUnlinkPoolItem((rpmioItem)(_db), _msg, __FILE__, __LINE__))

/*@unused@*/ /*@newref@*/
rpmdb rpmdbLink (rpmdb db, const char * msg)
        /*@modifies db @*/;
#define rpmdbLink(_db, _msg)    \
        ((void *)rpmioLinkPoolItem((rpmioItem)(_db), _msg, __FILE__, __LINE__))

/*@only@*/ /*@null@*/
rpmdb rpmdbNew(/*@kept@*/ /*@null@*/ const char * root,
                /*@kept@*/ /*@null@*/ const char * home,
                int mode, mode_t perms, int flags)
        /*@globals fileSystem, internalState @*/
        /*@modifies fileSystem, internalState @*/;

int rpmdbOpen(/*@null@*/ const char * prefix, /*@null@*/ /*@out@*/ rpmdb * dbp,
                int mode, mode_t perms)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies *dbp, rpmGlobalMacroContext, fileSystem, internalState @*/;

int rpmdbBlockDBI(/*@null@*/ rpmdb db, int tag)
        /*@modifies db @*/;

int rpmdbCloseDBI(/*@null@*/ rpmdb db, int tag)
        /*@globals fileSystem @*/
        /*@modifies db, fileSystem @*/;

int rpmdbClose (/*@killref@*/ /*@only@*/ /*@null@*/ rpmdb db)
        /*@globals fileSystem @*/
        /*@modifies db, fileSystem @*/;

/*@-exportlocal@*/
int rpmdbOpenAll (/*@null@*/ rpmdb db)
        /*@globals rpmGlobalMacroContext, h_errno, internalState @*/
        /*@modifies db, rpmGlobalMacroContext, internalState @*/;
/*@=exportlocal@*/

int rpmdbCount(/*@null@*/ rpmdb db, rpmTag tag,
                const void * keyp, size_t keylen)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, rpmGlobalMacroContext, fileSystem, internalState @*/;

int rpmdbCountPackages(/*@null@*/ rpmdb db, const char * N)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, rpmGlobalMacroContext, fileSystem, internalState @*/;

uint32_t rpmmiInstance(/*@null@*/ rpmmi mi)
        /*@*/;

uint32_t rpmmiBNTag(/*@null@*/ rpmmi mi)
        /*@*/;

unsigned int rpmmiCount(/*@null@*/ rpmmi mi)
        /*@*/;

int rpmmiGrow(/*@null@*/ rpmmi mi,
                /*@null@*/ const uint32_t * hdrNums, int nHdrNums)
        /*@modifies mi @*/;

int rpmmiGrowBasename(rpmmi mi, const char * bn)
        /*@modifies mi @*/;

int rpmmiSort(/*@null@*/ rpmmi mi)
        /*@modifies mi @*/;

int rpmmiPrune(/*@null@*/ rpmmi mi,
                /*@null@*/ uint32_t * hdrNums, int nHdrNums, int sorted)
        /*@modifies mi, hdrNums @*/;

int rpmmiAddPattern(/*@null@*/ rpmmi mi, rpmTag tag,
                rpmMireMode mode, /*@null@*/ const char * pattern)
        /*@globals rpmGlobalMacroContext, h_errno, internalState @*/
        /*@modifies mi, mode, rpmGlobalMacroContext, internalState @*/;

int rpmmiSetRewrite(/*@null@*/ rpmmi mi, int rewrite)
        /*@modifies mi @*/;

int rpmmiSetModified(/*@null@*/ rpmmi mi, int modified)
        /*@modifies mi @*/;

/*@only@*/ /*@null@*/
rpmmi rpmmiInit(/*@null@*/ rpmdb db, rpmTag tag,
                        /*@null@*/ const void * keyp, size_t keylen)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, rpmGlobalMacroContext, fileSystem, internalState @*/;

/*@null@*/
Header rpmmiNext(/*@null@*/ rpmmi mi)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies mi, rpmGlobalMacroContext, fileSystem, internalState @*/;

/*@mayexit@*/
int rpmdbCheckTerminate(int terminate)
        /*@globals fileSystem, internalState @*/
        /*@modifies fileSystem, internalState @*/;

/*@mayexit@*/
int rpmdbCheckSignals(void)
        /*@globals fileSystem, internalState @*/
        /*@modifies fileSystem, internalState @*/;

/*@null@*/
rpmmi rpmmiUnlink(/*@only@*/ /*@null@*/rpmmi mi)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies mi, rpmGlobalMacroContext, fileSystem, internalState @*/;
#define rpmmiUnlink(_mi)  \
    ((rpmmi)rpmioUnlinkPoolItem((rpmioItem)(_mi), __FUNCTION__, __FILE__, __LINE__))

/*@null@*/
rpmmi rpmmiLink(/*@only@*/ /*@null@*/rpmmi mi)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies mi, rpmGlobalMacroContext, fileSystem, internalState @*/;
#define rpmmiLink(_mi)  \
    ((rpmmi)rpmioLinkPoolItem((rpmioItem)(_mi), __FUNCTION__, __FILE__, __LINE__))

/*@null@*/
rpmmi rpmmiFree(/*@only@*/ /*@null@*/rpmmi mi)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies mi, rpmGlobalMacroContext, fileSystem, internalState @*/;
#define rpmmiFree(_mi)  \
    ((rpmmi)rpmioFreePoolItem((rpmioItem)(_mi), __FUNCTION__, __FILE__, __LINE__))

int rpmdbMireApply(rpmdb db, rpmTag tag, rpmMireMode mode, const char * pat,
                const char *** argvp)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, *argvp,
                rpmGlobalMacroContext, fileSystem, internalState @*/;

int rpmdbAdd(/*@null@*/ rpmdb db, int iid, Header h, /*@null@*/ rpmts ts)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, h, ts,
                rpmGlobalMacroContext, fileSystem, internalState @*/;

int rpmdbRemove(/*@null@*/ rpmdb db, /*@unused@*/ int rid, uint32_t hdrNum,
                /*@null@*/ rpmts ts)
        /*@globals rpmGlobalMacroContext, h_errno, fileSystem, internalState @*/
        /*@modifies db, ts,
                rpmGlobalMacroContext, fileSystem, internalState @*/;

/*@unused@*/
int rpm_mergesort(void *base, size_t nmemb, size_t size,
                int (*cmp) (const void *, const void *))
        /*@globals errno @*/
        /*@modifies base, errno @*/;

#ifdef __cplusplus
}
#endif

/*@=bounds@*/
#endif  /* H_RPMDB */