#ifndef _DB_QAM_H_
#define _DB_QAM_H_
#if defined(__cplusplus)
extern "C" {
#endif
typedef struct _qamdata {
u_int8_t flags;
#define QAM_VALID 0x01
#define QAM_SET 0x02
u_int8_t data[1];
} QAMDATA;
struct __queue; typedef struct __queue QUEUE;
struct __qcursor; typedef struct __qcursor QUEUE_CURSOR;
struct __qcursor {
__DBC_INTERNAL
db_recno_t recno;
u_int32_t flags;
};
typedef struct __mpfarray {
u_int32_t n_extent;
u_int32_t low_extent;
u_int32_t hi_extent;
struct __qmpf {
int pinref;
DB_MPOOLFILE *mpf;
} *mpfarray;
} MPFARRAY;
struct __queue {
db_pgno_t q_meta;
db_pgno_t q_root;
int re_pad;
u_int32_t re_len;
u_int32_t rec_page;
u_int32_t page_ext;
MPFARRAY array1, array2;
DBT pgcookie;
DB_PGINFO pginfo;
char *path;
char *name;
char *dir;
int mode;
};
#define QUEUE_EXTENT "%s%c__dbq.%s.%d"
#define QUEUE_EXTENT_HEAD "__dbq.%s."
#define QUEUE_EXTENT_PREFIX "__dbq."
typedef struct __qam_filelist {
DB_MPOOLFILE *mpf;
u_int32_t id;
} QUEUE_FILELIST;
#define CALC_QAM_RECNO_PER_PAGE(dbp) \
(((dbp)->pgsize - QPAGE_SZ(dbp)) / \
(u_int32_t)DB_ALIGN((uintmax_t)SSZA(QAMDATA, data) + \
((QUEUE *)(dbp)->q_internal)->re_len, sizeof(u_int32_t)))
#define QAM_RECNO_PER_PAGE(dbp) (((QUEUE*)(dbp)->q_internal)->rec_page)
#define QAM_RECNO_PAGE(dbp, recno) \
(((QUEUE *)(dbp)->q_internal)->q_root \
+ (((recno) - 1) / QAM_RECNO_PER_PAGE(dbp)))
#define QAM_PAGE_EXTENT(dbp, pgno) \
(((pgno) - 1) / ((QUEUE *)(dbp)->q_internal)->page_ext)
#define QAM_RECNO_EXTENT(dbp, recno) \
QAM_PAGE_EXTENT(dbp, QAM_RECNO_PAGE(dbp, recno))
#define QAM_RECNO_INDEX(dbp, pgno, recno) \
(((recno) - 1) - (QAM_RECNO_PER_PAGE(dbp) \
* (pgno - ((QUEUE *)(dbp)->q_internal)->q_root)))
#define QAM_GET_RECORD(dbp, page, index) \
((QAMDATA *)((u_int8_t *)(page) + (QPAGE_SZ(dbp) + \
(DB_ALIGN((uintmax_t)SSZA(QAMDATA, data) + \
((QUEUE *)(dbp)->q_internal)->re_len, sizeof(u_int32_t)) * index))))
#define QAM_AFTER_CURRENT(meta, recno) \
((recno) >= (meta)->cur_recno && \
((meta)->first_recno <= (meta)->cur_recno || \
((recno) < (meta)->first_recno && \
(recno) - (meta)->cur_recno < (meta)->first_recno - (recno))))
#define QAM_BEFORE_FIRST(meta, recno) \
((recno) < (meta)->first_recno && \
((meta)->first_recno <= (meta)->cur_recno || \
((recno) > (meta)->cur_recno && \
(recno) - (meta)->cur_recno > (meta)->first_recno - (recno))))
#define QAM_NOT_VALID(meta, recno) \
(recno == RECNO_OOB || \
QAM_BEFORE_FIRST(meta, recno) || QAM_AFTER_CURRENT(meta, recno))
#define QAM_SETFIRST 0x01
#define QAM_SETCUR 0x02
#define QAM_TRUNCATE 0x04
typedef enum {
QAM_PROBE_GET,
QAM_PROBE_PUT,
QAM_PROBE_DIRTY,
QAM_PROBE_MPF
} qam_probe_mode;
typedef enum {
QAM_NAME_DISCARD,
QAM_NAME_RENAME,
QAM_NAME_REMOVE
} qam_name_op;
#define __qam_fget(dbc, pgnoaddr, flags, addrp) \
__qam_fprobe(dbc, *pgnoaddr, \
addrp, QAM_PROBE_GET, DB_PRIORITY_UNCHANGED, flags)
#define __qam_fput(dbc, pgno, addrp, priority) \
__qam_fprobe(dbc, pgno, addrp, QAM_PROBE_PUT, priority, 0)
#define __qam_dirty(dbc, pgno, pagep, priority) \
__qam_fprobe(dbc, pgno, pagep, QAM_PROBE_DIRTY, priority, 0)
#if defined(__cplusplus)
}
#endif
#include "dbinc_auto/qam_auto.h"
#include "dbinc_auto/qam_ext.h"
#endif