开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
db.h
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：74k
源码类别：

MySQL数据库

开发平台：

Visual C++

db.h：源码内容
  1. /*
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1996-2002
  5.  * Sleepycat Software.  All rights reserved.
  6.  *
  7.  * $Id: db.in,v 11.323 2002/09/03 17:27:16 bostic Exp $
  8.  *
  9.  * db.h include file layout:
  10.  * General.
  11.  * Database Environment.
  12.  * Locking subsystem.
  13.  * Logging subsystem.
  14.  * Shared buffer cache (mpool) subsystem.
  15.  * Transaction subsystem.
  16.  * Access methods.
  17.  * Access method cursors.
  18.  * Dbm/Ndbm, Hsearch historic interfaces.
  19.  */
  21. #ifndef _DB_H_
  22. #define _DB_H_
  24. #ifndef __NO_SYSTEM_INCLUDES
  25. #include <sys/types.h>
  27. #include <stdio.h>
  28. #endif
  30. #if defined(__cplusplus)
  31. extern "C" {
  32. #endif
  34. /*
  35.  * XXX
  36.  * Handle function prototypes and the keyword "const".  This steps on name
  37.  * space that DB doesn't control, but all of the other solutions are worse.
  38.  *
  39.  * XXX
  40.  * While Microsoft's compiler is ANSI C compliant, it doesn't have _STDC_
  41.  * defined by default, you specify a command line flag or #pragma to turn
  42.  * it on.  Don't do that, however, because some of Microsoft's own header
  43.  * files won't compile.
  44.  */
  45. #undef __P
  46. #if defined(__STDC__) || defined(__cplusplus) || defined(_MSC_VER)
  47. #define __P(protos) protos /* ANSI C prototypes */
  48. #else
  49. #define const
  50. #define __P(protos) () /* K&R C preprocessor */
  51. #endif
  53. /*
  54.  * Berkeley DB version information.
  55.  */
  56. #define DB_VERSION_MAJOR 4
  57. #define DB_VERSION_MINOR 1
  58. #define DB_VERSION_PATCH 24
  59. #define DB_VERSION_STRING "Sleepycat Software: Berkeley DB 4.1.24: (November 30, 2005)"
  61. /*
  62.  * !!!
  63.  * Berkeley DB uses specifically sized types.  If they're not provided by
  64.  * the system, typedef them here.
  65.  *
  66.  * We protect them against multiple inclusion using __BIT_TYPES_DEFINED__,
  67.  * as does BIND and Kerberos, since we don't know for sure what #include
  68.  * files the user is using.
  69.  *
  70.  * !!!
  71.  * We also provide the standard u_int, u_long etc., if they're not provided
  72.  * by the system.
  73.  */
  74. #ifndef __BIT_TYPES_DEFINED__
  75. #define __BIT_TYPES_DEFINED__
  81. #endif
  89. /* Basic types that are exported or quasi-exported. */
  90. typedef u_int32_t db_pgno_t; /* Page number type. */
  91. typedef u_int16_t db_indx_t; /* Page offset type. */
  92. #define DB_MAX_PAGES 0xffffffff /* >= # of pages in a file */
  94. typedef u_int32_t db_recno_t; /* Record number type. */
  95. #define DB_MAX_RECORDS 0xffffffff /* >= # of records in a tree */
  97. typedef u_int32_t db_timeout_t; /* Type of a timeout. */
  99. /*
  100.  * Region offsets are currently limited to 32-bits.  I expect that's going
  101.  * to have to be fixed in the not-too-distant future, since we won't want to
  102.  * split 100Gb memory pools into that many different regions.
  103.  */
  104. typedef u_int32_t roff_t;
  106. /*
  107.  * Forward structure declarations, so we can declare pointers and
  108.  * applications can get type checking.
  109.  */
  110. struct __db; typedef struct __db DB;
  111. struct __db_bt_stat; typedef struct __db_bt_stat DB_BTREE_STAT;
  112. struct __db_cipher; typedef struct __db_cipher DB_CIPHER;
  113. struct __db_dbt; typedef struct __db_dbt DBT;
  114. struct __db_env; typedef struct __db_env DB_ENV;
  115. struct __db_h_stat; typedef struct __db_h_stat DB_HASH_STAT;
  116. struct __db_ilock; typedef struct __db_ilock DB_LOCK_ILOCK;
  117. struct __db_lock_stat; typedef struct __db_lock_stat DB_LOCK_STAT;
  118. struct __db_lock_u; typedef struct __db_lock_u DB_LOCK;
  119. struct __db_lockreq; typedef struct __db_lockreq DB_LOCKREQ;
  120. struct __db_log_cursor; typedef struct __db_log_cursor DB_LOGC;
  121. struct __db_log_stat; typedef struct __db_log_stat DB_LOG_STAT;
  122. struct __db_lsn; typedef struct __db_lsn DB_LSN;
  123. struct __db_mpool; typedef struct __db_mpool DB_MPOOL;
  124. struct __db_mpool_fstat;typedef struct __db_mpool_fstat DB_MPOOL_FSTAT;
  125. struct __db_mpool_stat; typedef struct __db_mpool_stat DB_MPOOL_STAT;
  126. struct __db_mpoolfile; typedef struct __db_mpoolfile DB_MPOOLFILE;
  127. struct __db_preplist; typedef struct __db_preplist DB_PREPLIST;
  128. struct __db_qam_stat; typedef struct __db_qam_stat DB_QUEUE_STAT;
  129. struct __db_rep; typedef struct __db_rep DB_REP;
  130. struct __db_rep_stat; typedef struct __db_rep_stat DB_REP_STAT;
  131. struct __db_txn; typedef struct __db_txn DB_TXN;
  132. struct __db_txn_active; typedef struct __db_txn_active DB_TXN_ACTIVE;
  133. struct __db_txn_stat; typedef struct __db_txn_stat DB_TXN_STAT;
  134. struct __db_txnmgr; typedef struct __db_txnmgr DB_TXNMGR;
  135. struct __dbc; typedef struct __dbc DBC;
  136. struct __dbc_internal; typedef struct __dbc_internal DBC_INTERNAL;
  137. struct __fh_t; typedef struct __fh_t DB_FH;
  138. struct __fname; typedef struct __fname FNAME;
  139. struct __key_range; typedef struct __key_range DB_KEY_RANGE;
  140. struct __mpoolfile; typedef struct __mpoolfile MPOOLFILE;
  141. struct __mutex_t; typedef struct __mutex_t DB_MUTEX;
  143. /* Key/data structure -- a Data-Base Thang. */
  144. struct __db_dbt {
  145. /*
  146.  * data/size must be fields 1 and 2 for DB 1.85 compatibility.
  147.  */
  148. void  *data; /* Key/data */
  149. u_int32_t size; /* key/data length */
  151. u_int32_t ulen; /* RO: length of user buffer. */
  152. u_int32_t dlen; /* RO: get/put record length. */
  153. u_int32_t doff; /* RO: get/put record offset. */
  155. void *app_private; /* Application-private handle. */
  157. #define DB_DBT_APPMALLOC 0x001 /* Callback allocated memory. */
  158. #define DB_DBT_ISSET 0x002 /* Lower level calls set value. */
  159. #define DB_DBT_MALLOC 0x004 /* Return in malloc'd memory. */
  160. #define DB_DBT_PARTIAL 0x008 /* Partial put/get. */
  161. #define DB_DBT_REALLOC 0x010 /* Return in realloc'd memory. */
  162. #define DB_DBT_USERMEM 0x020 /* Return in user's memory. */
  163. #define DB_DBT_DUPOK 0x040 /* Insert if duplicate. */
  164. u_int32_t flags;
  165. };
  167. /*
  168.  * Common flags --
  169.  * Interfaces which use any of these common flags should never have
  170.  * interface specific flags in this range.
  171.  */
  172. #define DB_CREATE       0x000001 /* Create file as necessary. */
  173. #define DB_CXX_NO_EXCEPTIONS  0x000002 /* C++: return error values. */
  174. #define DB_FORCE       0x000004 /* Force (anything). */
  175. #define DB_NOMMAP       0x000008 /* Don't mmap underlying file. */
  176. #define DB_RDONLY       0x000010 /* Read-only (O_RDONLY). */
  177. #define DB_RECOVER       0x000020 /* Run normal recovery. */
  178. #define DB_THREAD       0x000040 /* Applications are threaded. */
  179. #define DB_TRUNCATE       0x000080 /* Discard existing DB (O_TRUNC). */
  180. #define DB_TXN_NOSYNC       0x000100 /* Do not sync log on commit. */
  181. #define DB_USE_ENVIRON       0x000200 /* Use the environment. */
  182. #define DB_USE_ENVIRON_ROOT   0x000400 /* Use the environment if root. */
  184. /*
  185.  * Common flags --
  186.  * Interfaces which use any of these common flags should never have
  187.  * interface specific flags in this range.
  188.  *
  189.  * DB_AUTO_COMMIT:
  190.  * DB_ENV->set_flags, DB->associate, DB->del, DB->put, DB->open,
  191.  * DB->remove, DB->rename, DB->truncate
  192.  * DB_DIRTY_READ:
  193.  * DB->cursor, DB->get, DB->join, DB->open, DBcursor->c_get,
  194.  * DB_ENV->txn_begin
  195.  *
  196.  *    Shared flags up to 0x000400 */
  197. #define DB_AUTO_COMMIT     0x00800000 /* Implied transaction. */
  198. #define DB_DIRTY_READ     0x01000000 /* Dirty Read. */
  200. /*
  201.  * Flags private to db_env_create.
  202.  */
  203. #define DB_CLIENT       0x000001 /* Open for a client environment. */
  205. /*
  206.  * Flags private to db_create.
  207.  */
  208. #define DB_XA_CREATE       0x000001 /* Open in an XA environment. */
  210. /*
  211.  * Flags private to DB_ENV->open.
  212.  *    Shared flags up to 0x000400 */
  213. #define DB_INIT_CDB       0x000800 /* Concurrent Access Methods. */
  214. #define DB_INIT_LOCK       0x001000 /* Initialize locking. */
  215. #define DB_INIT_LOG       0x002000 /* Initialize logging. */
  216. #define DB_INIT_MPOOL       0x004000 /* Initialize mpool. */
  217. #define DB_INIT_TXN       0x008000 /* Initialize transactions. */
  218. #define DB_JOINENV       0x010000 /* Initialize all subsystems present. */
  219. #define DB_LOCKDOWN       0x020000 /* Lock memory into physical core. */
  220. #define DB_PRIVATE       0x040000 /* DB_ENV is process local. */
  221. #define DB_RECOVER_FATAL      0x080000 /* Run catastrophic recovery. */
  222. #define DB_SYSTEM_MEM       0x100000 /* Use system-backed memory. */
  224. /*
  225.  * Flags private to DB->open.
  226.  *    Shared flags up to 0x000400 */
  227. #define DB_EXCL       0x000800 /* Exclusive open (O_EXCL). */
  228. #define DB_FCNTL_LOCKING      0x001000 /* UNDOC: fcntl(2) locking. */
  229. #define DB_RDWRMASTER       0x002000 /* UNDOC: allow subdb master open R/W */
  230. #define DB_WRITEOPEN       0x004000 /* UNDOC: open with write lock. */
  232. /*
  233.  * Flags private to DB_ENV->txn_begin.
  234.  *    Shared flags up to 0x000400 */
  235. #define DB_TXN_NOWAIT       0x000800 /* Do not wait for locks in this TXN. */
  236. #define DB_TXN_SYNC       0x001000 /* Always sync log on commit. */
  238. /*
  239.  * Flags private to DB_ENV->set_encrypt.
  240.  */
  241. #define DB_ENCRYPT_AES       0x000001 /* AES, assumes SHA1 checksum */
  243. /*
  244.  * Flags private to DB_ENV->set_flags.
  245.  *    Shared flags up to 0x000400 */
  246. #define DB_CDB_ALLDB       0x000800 /* Set CDB locking per environment. */
  247. #define DB_DIRECT_DB       0x001000 /* Don't buffer databases in the OS. */
  248. #define DB_DIRECT_LOG       0x002000 /* Don't buffer log files in the OS. */
  249. #define DB_NOLOCKING       0x004000 /* Set locking/mutex behavior. */
  250. #define DB_NOPANIC       0x008000 /* Set panic state per DB_ENV. */
  251. #define DB_OVERWRITE       0x010000 /* Overwrite unlinked region files. */
  252. #define DB_PANIC_ENVIRONMENT  0x020000 /* Set panic state per environment. */
  253. #define DB_REGION_INIT       0x040000 /* Page-fault regions on open. */
  254. #define DB_TXN_WRITE_NOSYNC   0x080000 /* Write, don't sync, on txn commit. */
  255. #define DB_YIELDCPU       0x100000 /* Yield the CPU (a lot). */
  257. /*
  258.  * Flags private to DB->set_feedback's callback.
  259.  */
  260. #define DB_UPGRADE       0x000001 /* Upgrading. */
  261. #define DB_VERIFY       0x000002 /* Verifying. */
  263. /*
  264.  * Flags private to DB_MPOOLFILE->open.
  265.  *    Shared flags up to 0x000400 */
  266. #define DB_DIRECT       0x000800 /* Don't buffer the file in the OS. */
  267. #define DB_EXTENT       0x001000 /* UNDOC: dealing with an extent. */
  268. #define DB_ODDFILESIZE       0x002000 /* Truncate file to N * pgsize. */
  270. /*
  271.  * Flags private to DB->set_flags.
  272.  */
  273. #define DB_CHKSUM_SHA1       0x000001 /* Use SHA1 checksumming */
  274. #define DB_DUP       0x000002 /* Btree, Hash: duplicate keys. */
  275. #define DB_DUPSORT       0x000004 /* Btree, Hash: duplicate keys. */
  276. #define DB_ENCRYPT       0x000008 /* Btree, Hash: duplicate keys. */
  277. #define DB_RECNUM       0x000010 /* Btree: record numbers. */
  278. #define DB_RENUMBER       0x000020 /* Recno: renumber on insert/delete. */
  279. #define DB_REVSPLITOFF       0x000040 /* Btree: turn off reverse splits. */
  280. #define DB_SNAPSHOT       0x000080 /* Recno: snapshot the input. */
  282. /*
  283.  * Flags private to the DB->stat methods.
  284.  */
  285. #define DB_STAT_CLEAR       0x000001 /* Clear stat after returning values. */
  287. /*
  288.  * Flags private to DB->join.
  289.  */
  290. #define DB_JOIN_NOSORT       0x000001 /* Don't try to optimize join. */
  292. /*
  293.  * Flags private to DB->verify.
  294.  */
  295. #define DB_AGGRESSIVE       0x000001 /* Salvage whatever could be data.*/
  296. #define DB_NOORDERCHK       0x000002 /* Skip sort order/hashing check. */
  297. #define DB_ORDERCHKONLY       0x000004 /* Only perform the order check. */
  298. #define DB_PR_PAGE       0x000008 /* Show page contents (-da). */
  299. #define DB_PR_RECOVERYTEST    0x000010 /* Recovery test (-dr). */
  300. #define DB_PRINTABLE       0x000020 /* Use printable format for salvage. */
  301. #define DB_SALVAGE       0x000040 /* Salvage what looks like data. */
  302. /*
  303.  * !!!
  304.  * These must not go over 0x8000, or they will collide with the flags
  305.  * used by __bam_vrfy_subtree.
  306.  */
  308. /*
  309.  * Flags private to DB->set_rep_transport's send callback.
  310.  */
  311. #define DB_REP_PERMANENT 0x0001 /* Important--app. may want to flush. */
  313. /*******************************************************
  314.  * Locking.
  315.  *******************************************************/
  316. #define DB_LOCKVERSION 1
  318. #define DB_FILE_ID_LEN 20 /* Unique file ID length. */
  320. /*
  321.  * Deadlock detector modes; used in the DB_ENV structure to configure the
  322.  * locking subsystem.
  323.  */
  324. #define DB_LOCK_NORUN 0
  325. #define DB_LOCK_DEFAULT 1 /* Default policy. */
  326. #define DB_LOCK_EXPIRE 2 /* Only expire locks, no detection. */
  327. #define DB_LOCK_MAXLOCKS 3 /* Abort txn with maximum # of locks. */
  328. #define DB_LOCK_MINLOCKS 4 /* Abort txn with minimum # of locks. */
  329. #define DB_LOCK_MINWRITE 5 /* Abort txn with minimum writelocks. */
  330. #define DB_LOCK_OLDEST 6 /* Abort oldest transaction. */
  331. #define DB_LOCK_RANDOM 7 /* Abort random transaction. */
  332. #define DB_LOCK_YOUNGEST 8 /* Abort youngest transaction. */
  334. /* Flag values for lock_vec(), lock_get(). */
  335. #define DB_LOCK_FREE_LOCKER 0x001 /* Internal: Free locker as well. */
  336. #define DB_LOCK_NOWAIT 0x002 /* Don't wait on unavailable lock. */
  337. #define DB_LOCK_RECORD 0x004 /* Internal: record lock. */
  338. #define DB_LOCK_REMOVE 0x008 /* Internal: flag object removed. */
  339. #define DB_LOCK_SET_TIMEOUT 0x010 /* Internal: set lock timeout. */
  340. #define DB_LOCK_SWITCH 0x020 /* Internal: switch existing lock. */
  341. #define DB_LOCK_UPGRADE 0x040 /* Internal: upgrade existing lock. */
  343. /*
  344.  * Simple R/W lock modes and for multi-granularity intention locking.
  345.  *
  346.  * !!!
  347.  * These values are NOT random, as they are used as an index into the lock
  348.  * conflicts arrays, i.e., DB_LOCK_IWRITE must be == 3, and DB_LOCK_IREAD
  349.  * must be == 4.
  350.  */
  351. typedef enum {
  352. DB_LOCK_NG=0, /* Not granted. */
  353. DB_LOCK_READ=1, /* Shared/read. */
  354. DB_LOCK_WRITE=2, /* Exclusive/write. */
  355. DB_LOCK_WAIT=3, /* Wait for event */
  356. DB_LOCK_IWRITE=4, /* Intent exclusive/write. */
  357. DB_LOCK_IREAD=5, /* Intent to share/read. */
  358. DB_LOCK_IWR=6, /* Intent to read and write. */
  359. DB_LOCK_DIRTY=7, /* Dirty Read. */
  360. DB_LOCK_WWRITE=8 /* Was Written. */
  361. } db_lockmode_t;
  363. /*
  364.  * Request types.
  365.  */
  366. typedef enum {
  367. DB_LOCK_DUMP=0, /* Display held locks. */
  368. DB_LOCK_GET=1, /* Get the lock. */
  369. DB_LOCK_GET_TIMEOUT=2, /* Get lock with a timeout. */
  370. DB_LOCK_INHERIT=3, /* Pass locks to parent. */
  371. DB_LOCK_PUT=4, /* Release the lock. */
  372. DB_LOCK_PUT_ALL=5, /* Release locker's locks. */
  373. DB_LOCK_PUT_OBJ=6, /* Release locker's locks on obj. */
  374. DB_LOCK_PUT_READ=7, /* Release locker's read locks. */
  375. DB_LOCK_TIMEOUT=8, /* Force a txn to timeout. */
  376. DB_LOCK_TRADE=9, /* Trade locker ids on a lock. */
  377. DB_LOCK_UPGRADE_WRITE=10 /* Upgrade writes for dirty reads. */
  378. } db_lockop_t;
  380. /*
  381.  * Status of a lock.
  382.  */
  383. typedef enum  {
  384. DB_LSTAT_ABORTED=1, /* Lock belongs to an aborted txn. */
  385. DB_LSTAT_ERR=2, /* Lock is bad. */
  386. DB_LSTAT_EXPIRED=3, /* Lock has expired. */
  387. DB_LSTAT_FREE=4, /* Lock is unallocated. */
  388. DB_LSTAT_HELD=5, /* Lock is currently held. */
  389. DB_LSTAT_NOTEXIST=6, /* Object on which lock was waiting
  390.  * was removed */
  391. DB_LSTAT_PENDING=7, /* Lock was waiting and has been
  392.  * promoted; waiting for the owner
  393.  * to run and upgrade it to held. */
  394. DB_LSTAT_WAITING=8 /* Lock is on the wait queue. */
  395. }db_status_t;
  397. /* Lock statistics structure. */
  398. struct __db_lock_stat {
  399. u_int32_t st_id; /* Last allocated locker ID. */
  400. u_int32_t st_cur_maxid; /* Current maximum unused ID. */
  401. u_int32_t st_maxlocks; /* Maximum number of locks in table. */
  402. u_int32_t st_maxlockers; /* Maximum num of lockers in table. */
  403. u_int32_t st_maxobjects; /* Maximum num of objects in table. */
  404. u_int32_t st_nmodes; /* Number of lock modes. */
  405. u_int32_t st_nlocks; /* Current number of locks. */
  406. u_int32_t st_maxnlocks; /* Maximum number of locks so far. */
  407. u_int32_t st_nlockers; /* Current number of lockers. */
  408. u_int32_t st_maxnlockers; /* Maximum number of lockers so far. */
  409. u_int32_t st_nobjects; /* Current number of objects. */
  410. u_int32_t st_maxnobjects; /* Maximum number of objects so far. */
  411. u_int32_t st_nconflicts; /* Number of lock conflicts. */
  412. u_int32_t st_nrequests; /* Number of lock gets. */
  413. u_int32_t st_nreleases; /* Number of lock puts. */
  414. u_int32_t st_nnowaits; /* Number of requests that would have
  415.    waited, but NOWAIT was set. */
  416. u_int32_t st_ndeadlocks; /* Number of lock deadlocks. */
  417. db_timeout_t st_locktimeout; /* Lock timeout. */
  418. u_int32_t st_nlocktimeouts; /* Number of lock timeouts. */
  419. db_timeout_t st_txntimeout; /* Transaction timeout. */
  420. u_int32_t st_ntxntimeouts; /* Number of transaction timeouts. */
  421. u_int32_t st_region_wait; /* Region lock granted after wait. */
  422. u_int32_t st_region_nowait; /* Region lock granted without wait. */
  423. u_int32_t st_regsize; /* Region size. */
  424. };
  426. /*
  427.  * DB_LOCK_ILOCK --
  428.  * Internal DB access method lock.
  429.  */
  430. struct __db_ilock {
  431. db_pgno_t pgno; /* Page being locked. */
  432. u_int8_t fileid[DB_FILE_ID_LEN];/* File id. */
  433. #define DB_HANDLE_LOCK 1
  434. #define DB_RECORD_LOCK 2
  435. #define DB_PAGE_LOCK 3
  436. #define DB_TXN_LOCK 4
  437. u_int32_t type; /* Type of lock. */
  438. };
  440. /*
  441.  * DB_LOCK --
  442.  * The structure is allocated by the caller and filled in during a
  443.  * lock_get request (or a lock_vec/DB_LOCK_GET).
  444.  */
  445. struct __db_lock_u {
  446. size_t off; /* Offset of the lock in the region */
  447. u_int32_t ndx; /* Index of the object referenced by
  448.  * this lock; used for locking. */
  449. u_int32_t gen; /* Generation number of this lock. */
  450. db_lockmode_t mode; /* mode of this lock. */
  451. };
  453. /* Lock request structure. */
  454. struct __db_lockreq {
  455. db_lockop_t  op; /* Operation. */
  456. db_lockmode_t  mode; /* Requested mode. */
  457. db_timeout_t  timeout; /* Time to expire lock. */
  458. DBT *obj; /* Object being locked. */
  459. DB_LOCK  lock; /* Lock returned. */
  460. };
  462. /*******************************************************
  463.  * Logging.
  464.  *******************************************************/
  465. #define DB_LOGVERSION 7 /* Current log version. */
  466. #define DB_LOGOLDVER 7 /* Oldest log version supported. */
  467. #define DB_LOGMAGIC 0x040988
  469. /* Flag values for log_archive(). */
  470. #define DB_ARCH_ABS 0x001 /* Absolute pathnames. */
  471. #define DB_ARCH_DATA 0x002 /* Data files. */
  472. #define DB_ARCH_LOG 0x004 /* Log files. */
  474. /*
  475.  * A DB_LSN has two parts, a fileid which identifies a specific file, and an
  476.  * offset within that file.  The fileid is an unsigned 4-byte quantity that
  477.  * uniquely identifies a file within the log directory -- currently a simple
  478.  * counter inside the log.  The offset is also an unsigned 4-byte value.  The
  479.  * log manager guarantees the offset is never more than 4 bytes by switching
  480.  * to a new log file before the maximum length imposed by an unsigned 4-byte
  481.  * offset is reached.
  482.  */
  483. struct __db_lsn {
  484. u_int32_t file; /* File ID. */
  485. u_int32_t offset; /* File offset. */
  486. };
  488. /*
  489.  * DB_LOGC --
  490.  * Log cursor.
  491.  */
  492. struct __db_log_cursor {
  493. DB_ENV  *dbenv; /* Enclosing dbenv. */
  495. DB_FH  *c_fh; /* File handle. */
  496. DB_LSN   c_lsn; /* Cursor: LSN */
  497. u_int32_t c_len; /* Cursor: record length */
  498. u_int32_t c_prev; /* Cursor: previous record's offset */
  500. DBT   c_dbt; /* Return DBT. */
  502. #define DB_LOGC_BUF_SIZE (32 * 1024)
  503. u_int8_t *bp; /* Allocated read buffer. */
  504. u_int32_t bp_size; /* Read buffer length in bytes. */
  505. u_int32_t bp_rlen; /* Read buffer valid data length. */
  506. DB_LSN   bp_lsn; /* Read buffer first byte LSN. */
  508. u_int32_t bp_maxrec; /* Max record length in the log file. */
  510. /* Methods. */
  511. int (*close) __P((DB_LOGC *, u_int32_t));
  512. int (*get) __P((DB_LOGC *, DB_LSN *, DBT *, u_int32_t));
  514. #define DB_LOG_DISK 0x01 /* Log record came from disk. */
  515. #define DB_LOG_LOCKED 0x02 /* Log region already locked */
  516. #define DB_LOG_SILENT_ERR 0x04 /* Turn-off error messages. */
  517. u_int32_t flags;
  518. };
  520. /* Log statistics structure. */
  521. struct __db_log_stat {
  522. u_int32_t st_magic; /* Log file magic number. */
  523. u_int32_t st_version; /* Log file version number. */
  524. int st_mode; /* Log file mode. */
  525. u_int32_t st_lg_bsize; /* Log buffer size. */
  526. u_int32_t st_lg_size; /* Log file size. */
  527. u_int32_t st_w_bytes; /* Bytes to log. */
  528. u_int32_t st_w_mbytes; /* Megabytes to log. */
  529. u_int32_t st_wc_bytes; /* Bytes to log since checkpoint. */
  530. u_int32_t st_wc_mbytes; /* Megabytes to log since checkpoint. */
  531. u_int32_t st_wcount; /* Total writes to the log. */
  532. u_int32_t st_wcount_fill; /* Overflow writes to the log. */
  533. u_int32_t st_scount; /* Total syncs to the log. */
  534. u_int32_t st_region_wait; /* Region lock granted after wait. */
  535. u_int32_t st_region_nowait; /* Region lock granted without wait. */
  536. u_int32_t st_cur_file; /* Current log file number. */
  537. u_int32_t st_cur_offset; /* Current log file offset. */
  538. u_int32_t st_disk_file; /* Known on disk log file number. */
  539. u_int32_t st_disk_offset; /* Known on disk log file offset. */
  540. u_int32_t st_regsize; /* Region size. */
  541. u_int32_t st_maxcommitperflush; /* Max number of commits in a flush. */
  542. u_int32_t st_mincommitperflush; /* Min number of commits in a flush. */
  543. };
  545. /*******************************************************
  546.  * Shared buffer cache (mpool).
  547.  *******************************************************/
  548. /* Flag values for DB_MPOOLFILE->get. */
  549. #define DB_MPOOL_CREATE 0x001 /* Create a page. */
  550. #define DB_MPOOL_LAST 0x002 /* Return the last page. */
  551. #define DB_MPOOL_NEW 0x004 /* Create a new page. */
  553. /* Flag values for DB_MPOOLFILE->put, DB_MPOOLFILE->set. */
  554. #define DB_MPOOL_CLEAN 0x001 /* Page is not modified. */
  555. #define DB_MPOOL_DIRTY 0x002 /* Page is modified. */
  556. #define DB_MPOOL_DISCARD 0x004 /* Don't cache the page. */
  558. /* Priority values for DB_MPOOLFILE->set_priority. */
  559. typedef enum {
  560. DB_PRIORITY_VERY_LOW=1,
  561. DB_PRIORITY_LOW=2,
  562. DB_PRIORITY_DEFAULT=3,
  563. DB_PRIORITY_HIGH=4,
  564. DB_PRIORITY_VERY_HIGH=5
  565. } DB_CACHE_PRIORITY;
  567. /* Per-process DB_MPOOLFILE information. */
  568. struct __db_mpoolfile {
  569. /* These fields need to be protected for multi-threaded support. */
  570. DB_MUTEX *mutexp; /* Structure thread lock. */
  572. DB_FH   *fhp; /* Underlying file handle. */
  574. u_int32_t  ref; /* Reference count. */
  576. /*
  577.  * !!!
  578.  * The pinref and q fields are protected by the region lock, not the
  579.  * DB_MPOOLFILE structure mutex.  We don't use the structure mutex
  580.  * because then I/O (which holds the structure lock held because of
  581.  * the race between the seek and write of the file descriptor) would
  582.  * block any other put/get calls using this DB_MPOOLFILE structure.
  583.  */
  584. u_int32_t pinref; /* Pinned block reference count. */
  586. /*
  587.  * !!!
  588.  * Explicit representations of structures from queue.h.
  589.  * TAILQ_ENTRY(__db_mpoolfile) q;
  590.  */
  591. struct {
  592. struct __db_mpoolfile *tqe_next;
  593. struct __db_mpoolfile **tqe_prev;
  594. } q; /* Linked list of DB_MPOOLFILE's. */
  596. /*
  597.  * These fields are not thread-protected because they are initialized
  598.  * when the file is opened and never modified.
  599.  */
  600. int   ftype; /* File type. */
  601. DBT  *pgcookie; /* Byte-string passed to pgin/pgout. */
  602. u_int8_t *fileid; /* Unique file ID. */
  603. int32_t   lsn_offset; /* LSN offset in page. */
  604. u_int32_t clear_len; /* Cleared length on created pages. */
  606. DB_MPOOL  *dbmp; /* Overlying DB_MPOOL. */
  607. MPOOLFILE *mfp; /* Underlying MPOOLFILE. */
  609. void   *addr; /* Address of mmap'd region. */
  610. size_t    len; /* Length of mmap'd region. */
  612. /* Methods. */
  613. int  (*close) __P((DB_MPOOLFILE *, u_int32_t));
  614. int  (*get) __P((DB_MPOOLFILE *, db_pgno_t *, u_int32_t, void *));
  615. void (*get_fileid) __P((DB_MPOOLFILE *, u_int8_t *));
  616. void (*last_pgno) __P((DB_MPOOLFILE *, db_pgno_t *));
  617. int  (*open)__P((DB_MPOOLFILE *, const char *, u_int32_t, int, size_t));
  618. int  (*put) __P((DB_MPOOLFILE *, void *, u_int32_t));
  619. void (*refcnt) __P((DB_MPOOLFILE *, db_pgno_t *));
  620. int  (*set) __P((DB_MPOOLFILE *, void *, u_int32_t));
  621. int  (*set_clear_len) __P((DB_MPOOLFILE *, u_int32_t));
  622. int  (*set_fileid) __P((DB_MPOOLFILE *, u_int8_t *));
  623. int  (*set_ftype) __P((DB_MPOOLFILE *, int));
  624. int  (*set_lsn_offset) __P((DB_MPOOLFILE *, int32_t));
  625. int  (*set_pgcookie) __P((DB_MPOOLFILE *, DBT *));
  626. int  (*set_priority) __P((DB_MPOOLFILE *, DB_CACHE_PRIORITY));
  627. void (*set_unlink) __P((DB_MPOOLFILE *, int));
  628. int  (*sync) __P((DB_MPOOLFILE *));
  630. /*
  631.  * MP_OPEN_CALLED and MP_READONLY do not need to be thread protected
  632.  * because they are initialized when the file is opened, and never
  633.  * modified.
  634.  *
  635.  * MP_FLUSH, MP_UPGRADE and MP_UPGRADE_FAIL are thread protected
  636.  * becase they are potentially read by multiple threads of control.
  637.  */
  638. #define MP_FLUSH 0x001 /* Was opened to flush a buffer. */
  639. #define MP_OPEN_CALLED 0x002 /* File opened. */
  640. #define MP_READONLY 0x004 /* File is readonly. */
  641. #define MP_UPGRADE 0x008 /* File descriptor is readwrite. */
  642. #define MP_UPGRADE_FAIL 0x010 /* Upgrade wasn't possible. */
  643. u_int32_t  flags;
  644. };
  646. /*
  647.  * Mpool statistics structure.
  648.  */
  649. struct __db_mpool_stat {
  650. u_int32_t st_gbytes; /* Total cache size: GB. */
  651. u_int32_t st_bytes; /* Total cache size: B. */
  652. u_int32_t st_ncache; /* Number of caches. */
  653. u_int32_t st_regsize; /* Cache size. */
  654. u_int32_t st_map; /* Pages from mapped files. */
  655. u_int32_t st_cache_hit; /* Pages found in the cache. */
  656. u_int32_t st_cache_miss; /* Pages not found in the cache. */
  657. u_int32_t st_page_create; /* Pages created in the cache. */
  658. u_int32_t st_page_in; /* Pages read in. */
  659. u_int32_t st_page_out; /* Pages written out. */
  660. u_int32_t st_ro_evict; /* Clean pages forced from the cache. */
  661. u_int32_t st_rw_evict; /* Dirty pages forced from the cache. */
  662. u_int32_t st_page_trickle; /* Pages written by memp_trickle. */
  663. u_int32_t st_pages; /* Total number of pages. */
  664. u_int32_t st_page_clean; /* Clean pages. */
  665. u_int32_t st_page_dirty; /* Dirty pages. */
  666. u_int32_t st_hash_buckets; /* Number of hash buckets. */
  667. u_int32_t st_hash_searches; /* Total hash chain searches. */
  668. u_int32_t st_hash_longest; /* Longest hash chain searched. */
  669. u_int32_t st_hash_examined; /* Total hash entries searched. */
  670. u_int32_t st_hash_nowait; /* Hash lock granted with nowait. */
  671. u_int32_t st_hash_wait; /* Hash lock granted after wait. */
  672. u_int32_t st_hash_max_wait; /* Max hash lock granted after wait. */
  673. u_int32_t st_region_nowait; /* Region lock granted with nowait. */
  674. u_int32_t st_region_wait; /* Region lock granted after wait. */
  675. u_int32_t st_alloc; /* Number of page allocations. */
  676. u_int32_t st_alloc_buckets; /* Buckets checked during allocation. */
  677. u_int32_t st_alloc_max_buckets; /* Max checked during allocation. */
  678. u_int32_t st_alloc_pages; /* Pages checked during allocation. */
  679. u_int32_t st_alloc_max_pages; /* Max checked during allocation. */
  680. };
  682. /* Mpool file statistics structure. */
  683. struct __db_mpool_fstat {
  684. char *file_name; /* File name. */
  685. size_t st_pagesize; /* Page size. */
  686. u_int32_t st_map; /* Pages from mapped files. */
  687. u_int32_t st_cache_hit; /* Pages found in the cache. */
  688. u_int32_t st_cache_miss; /* Pages not found in the cache. */
  689. u_int32_t st_page_create; /* Pages created in the cache. */
  690. u_int32_t st_page_in; /* Pages read in. */
  691. u_int32_t st_page_out; /* Pages written out. */
  692. };
  694. /*******************************************************
  695.  * Transactions and recovery.
  696.  *******************************************************/
  697. #define DB_TXNVERSION 1
  699. typedef enum {
  700. DB_TXN_ABORT=0, /* Public. */
  701. DB_TXN_APPLY=1, /* Public. */
  702. DB_TXN_BACKWARD_ALLOC=2, /* Internal. */
  703. DB_TXN_BACKWARD_ROLL=3, /* Public. */
  704. DB_TXN_FORWARD_ROLL=4, /* Public. */
  705. DB_TXN_GETPGNOS=5, /* Internal. */
  706. DB_TXN_OPENFILES=6, /* Internal. */
  707. DB_TXN_POPENFILES=7, /* Internal. */
  708. DB_TXN_PRINT=8 /* Public. */
  709. } db_recops;
  711. /*
  712.  * BACKWARD_ALLOC is used during the forward pass to pick up any aborted
  713.  * allocations for files that were created during the forward pass.
  714.  * The main difference between _ALLOC and _ROLL is that the entry for
  715.  * the file not exist during the rollforward pass.
  716.  */
  717. #define DB_UNDO(op) ((op) == DB_TXN_ABORT ||
  718. (op) == DB_TXN_BACKWARD_ROLL || (op) == DB_TXN_BACKWARD_ALLOC)
  719. #define DB_REDO(op) ((op) == DB_TXN_FORWARD_ROLL || (op) == DB_TXN_APPLY)
  721. struct __db_txn {
  722. DB_TXNMGR *mgrp; /* Pointer to transaction manager. */
  723. DB_TXN *parent; /* Pointer to transaction's parent. */
  724. DB_LSN last_lsn; /* Lsn of last log write. */
  725. u_int32_t txnid; /* Unique transaction id. */
  726. roff_t off; /* Detail structure within region. */
  727. db_timeout_t lock_timeout; /* Timeout for locks for this txn. */
  728. db_timeout_t expire; /* Time this txn expires. */
  729. void *txn_list; /* Undo information for parent. */
  731. /*
  732.  * !!!
  733.  * Explicit representations of structures from queue.h.
  734.  * TAILQ_ENTRY(__db_txn) links;
  735.  */
  736. struct {
  737. struct __db_txn *tqe_next;
  738. struct __db_txn **tqe_prev;
  739. } links; /* Links transactions off manager. */
  741. /*
  742.  * !!!
  743.  * Explicit representations of structures from queue.h.
  744.  * TAILQ_HEAD(__events, __txn_event) events;
  745.  */
  746. struct {
  747. struct __txn_event *tqh_first;
  748. struct __txn_event **tqh_last;
  749. } events;
  751. /*
  752.  * !!!
  753.  * Explicit representations of structures from queue.h.
  754.  * TAILQ_HEAD(__kids, __db_txn) kids;
  755.  */
  756. struct __kids {
  757. struct __db_txn *tqh_first;
  758. struct __db_txn **tqh_last;
  759. } kids;
  761. /*
  762.  * !!!
  763.  * Explicit representations of structures from queue.h.
  764.  * TAILQ_ENTRY(__db_txn) klinks;
  765.  */
  766. struct {
  767. struct __db_txn *tqe_next;
  768. struct __db_txn **tqe_prev;
  769. } klinks;
  771. /* API-private structure: used by C++ */
  772. void *api_internal;
  774. u_int32_t cursors; /* Number of cursors open for txn */
  776. /* Methods. */
  777. int   (*abort) __P((DB_TXN *));
  778. int   (*commit) __P((DB_TXN *, u_int32_t));
  779. int   (*discard) __P((DB_TXN *, u_int32_t));
  780. u_int32_t (*id) __P((DB_TXN *));
  781. int   (*prepare) __P((DB_TXN *, u_int8_t *));
  782. int   (*set_timeout) __P((DB_TXN *, db_timeout_t, u_int32_t));
  784. #define TXN_CHILDCOMMIT 0x01 /* Transaction that has committed. */
  785. #define TXN_COMPENSATE 0x02 /* Compensating transaction. */
  786. #define TXN_DIRTY_READ 0x04 /* Transaction does dirty reads. */
  787. #define TXN_LOCKTIMEOUT 0x08 /* Transaction has a lock timeout. */
  788. #define TXN_MALLOC 0x10 /* Structure allocated by TXN system. */
  789. #define TXN_NOSYNC 0x20 /* Do not sync on prepare and commit. */
  790. #define TXN_NOWAIT 0x40 /* Do not wait on locks. */
  791. #define TXN_SYNC 0x80 /* Sync on prepare and commit. */
  792. u_int32_t flags;
  793. };
  795. /* Transaction statistics structure. */
  796. struct __db_txn_active {
  797. u_int32_t txnid; /* Transaction ID */
  798. u_int32_t parentid; /* Transaction ID of parent */
  799. DB_LSN lsn; /* LSN when transaction began */
  800. };
  802. struct __db_txn_stat {
  803. DB_LSN   st_last_ckp; /* lsn of the last checkpoint */
  804. time_t   st_time_ckp; /* time of last checkpoint */
  805. u_int32_t st_last_txnid; /* last transaction id given out */
  806. u_int32_t st_maxtxns; /* maximum txns possible */
  807. u_int32_t st_naborts; /* number of aborted transactions */
  808. u_int32_t st_nbegins; /* number of begun transactions */
  809. u_int32_t st_ncommits; /* number of committed transactions */
  810. u_int32_t st_nactive; /* number of active transactions */
  811. u_int32_t st_nrestores; /* number of restored transactions
  812.    after recovery. */
  813. u_int32_t st_maxnactive; /* maximum active transactions */
  814. DB_TXN_ACTIVE *st_txnarray; /* array of active transactions */
  815. u_int32_t st_region_wait; /* Region lock granted after wait. */
  816. u_int32_t st_region_nowait; /* Region lock granted without wait. */
  817. u_int32_t st_regsize; /* Region size. */
  818. };
  820. /*
  821.  * Structure used for two phase commit interface.  Berkeley DB support for two
  822.  * phase commit is compatible with the X/open XA interface.  The xa #define
  823.  * XIDDATASIZE defines the size of a global transaction ID.  We have our own
  824.  * version here which must have the same value.
  825.  */
  826. #define DB_XIDDATASIZE 128
  827. struct __db_preplist {
  828. DB_TXN *txn;
  829. u_int8_t gid[DB_XIDDATASIZE];
  830. };
  832. /*******************************************************
  833.  * Replication.
  834.  *******************************************************/
  835. /* Special, out-of-band environment IDs. */
  836. #define DB_EID_BROADCAST -1
  837. #define DB_EID_INVALID -2
  839. /* rep_start flags values */
  840. #define DB_REP_CLIENT 0x001
  841. #define DB_REP_LOGSONLY 0x002
  842. #define DB_REP_MASTER 0x004
  844. /* Replication statistics. */
  845. struct __db_rep_stat {
  846. /* !!!
  847.  * Many replication statistics fields cannot be protected by a mutex
  848.  * without an unacceptable performance penalty, since most message
  849.  * processing is done without the need to hold a region-wide lock.
  850.  * Fields whose comments end with a '+' may be updated without holding
  851.  * the replication or log mutexes (as appropriate), and thus may be
  852.  * off somewhat (or, on unreasonable architectures under unlucky
  853.  * circumstances, garbaged).
  854.  */
  855. u_int32_t st_status; /* Current replication status. */
  856. DB_LSN st_next_lsn; /* Next LSN to use or expect. */
  857. DB_LSN st_waiting_lsn; /* LSN we're awaiting, if any. */
  859. u_int32_t st_dupmasters; /* # of times a duplicate master
  860.    condition was detected.+ */
  861. int st_env_id; /* Current environment ID. */
  862. int st_env_priority; /* Current environment priority. */
  863. u_int32_t st_gen; /* Current generation number. */
  864. u_int32_t st_log_duplicated; /* Log records received multiply.+ */
  865. u_int32_t st_log_queued; /* Log records currently queued.+ */
  866. u_int32_t st_log_queued_max; /* Max. log records queued at once.+ */
  867. u_int32_t st_log_queued_total; /* Total # of log recs. ever queued.+ */
  868. u_int32_t st_log_records; /* Log records received and put.+ */
  869. u_int32_t st_log_requested; /* Log recs. missed and requested.+ */
  870. int st_master; /* Env. ID of the current master. */
  871. u_int32_t st_master_changes; /* # of times we've switched masters. */
  872. u_int32_t st_msgs_badgen; /* Messages with a bad generation #.+ */
  873. u_int32_t st_msgs_processed; /* Messages received and processed.+ */
  874. u_int32_t st_msgs_recover; /* Messages ignored because this site
  875.    was a client in recovery.+ */
  876. u_int32_t st_msgs_send_failures;/* # of failed message sends.+ */
  877. u_int32_t st_msgs_sent; /* # of successful message sends.+ */
  878. u_int32_t st_newsites; /* # of NEWSITE msgs. received.+ */
  879. int st_nsites; /* Current number of sites we will
  880.    assume during elections. */
  881. u_int32_t st_nthrottles; /* # of times we were throttled. */
  882. u_int32_t st_outdated; /* # of times we detected and returned
  883.    an OUTDATED condition.+ */
  884. u_int32_t st_txns_applied; /* # of transactions applied.+ */
  886. /* Elections generally. */
  887. u_int32_t st_elections; /* # of elections held.+ */
  888. u_int32_t st_elections_won; /* # of elections won by this site.+ */
  890. /* Statistics about an in-progress election. */
  891. int st_election_cur_winner; /* Current front-runner. */
  892. u_int32_t st_election_gen; /* Election generation number. */
  893. DB_LSN st_election_lsn; /* Max. LSN of current winner. */
  894. int st_election_nsites; /* # of "registered voters". */
  895. int st_election_priority; /* Current election priority. */
  896. int st_election_status; /* Current election status. */
  897. int st_election_tiebreaker; /* Election tiebreaker value. */
  898. int st_election_votes; /* Votes received in this round. */
  899. };
  901. /*******************************************************
  902.  * Access methods.
  903.  *******************************************************/
  904. typedef enum {
  905. DB_BTREE=1,
  906. DB_HASH=2,
  907. DB_RECNO=3,
  908. DB_QUEUE=4,
  909. DB_UNKNOWN=5 /* Figure it out on open. */
  910. } DBTYPE;
  912. #define DB_RENAMEMAGIC 0x030800 /* File has been renamed. */
  914. #define DB_BTREEVERSION 9 /* Current btree version. */
  915. #define DB_BTREEOLDVER 8 /* Oldest btree version supported. */
  916. #define DB_BTREEMAGIC 0x053162
  918. #define DB_HASHVERSION 8 /* Current hash version. */
  919. #define DB_HASHOLDVER 7 /* Oldest hash version supported. */
  920. #define DB_HASHMAGIC 0x061561
  922. #define DB_QAMVERSION 4 /* Current queue version. */
  923. #define DB_QAMOLDVER 3 /* Oldest queue version supported. */
  924. #define DB_QAMMAGIC 0x042253
  926. /*
  927.  * DB access method and cursor operation values.  Each value is an operation
  928.  * code to which additional bit flags are added.
  929.  */
  930. #define DB_AFTER  1 /* c_put() */
  931. #define DB_APPEND  2 /* put() */
  932. #define DB_BEFORE  3 /* c_put() */
  933. #define DB_CACHED_COUNTS  4 /* stat() */
  934. #define DB_COMMIT  5 /* log_put() (internal) */
  935. #define DB_CONSUME  6 /* get() */
  936. #define DB_CONSUME_WAIT  7 /* get() */
  937. #define DB_CURRENT  8 /* c_get(), c_put(), DB_LOGC->get() */
  938. #define DB_FAST_STAT  9 /* stat() */
  939. #define DB_FIRST 10 /* c_get(), DB_LOGC->get() */
  940. #define DB_GET_BOTH 11 /* get(), c_get() */
  941. #define DB_GET_BOTHC 12 /* c_get() (internal) */
  942. #define DB_GET_BOTH_RANGE 13 /* get(), c_get() */
  943. #define DB_GET_RECNO 14 /* c_get() */
  944. #define DB_JOIN_ITEM 15 /* c_get(); do not do primary lookup */
  945. #define DB_KEYFIRST 16 /* c_put() */
  946. #define DB_KEYLAST 17 /* c_put() */
  947. #define DB_LAST 18 /* c_get(), DB_LOGC->get() */
  948. #define DB_NEXT 19 /* c_get(), DB_LOGC->get() */
  949. #define DB_NEXT_DUP 20 /* c_get() */
  950. #define DB_NEXT_NODUP 21 /* c_get() */
  951. #define DB_NODUPDATA 22 /* put(), c_put() */
  952. #define DB_NOOVERWRITE 23 /* put() */
  953. #define DB_NOSYNC 24 /* close() */
  954. #define DB_POSITION 25 /* c_dup() */
  955. #define DB_POSITIONI 26 /* c_dup() (internal) */
  956. #define DB_PREV 27 /* c_get(), DB_LOGC->get() */
  957. #define DB_PREV_NODUP 28 /* c_get(), DB_LOGC->get() */
  958. #define DB_RECORDCOUNT 29 /* stat() */
  959. #define DB_SET 30 /* c_get(), DB_LOGC->get() */
  960. #define DB_SET_LOCK_TIMEOUT 31 /* set_timout() */
  961. #define DB_SET_RANGE 32 /* c_get() */
  962. #define DB_SET_RECNO 33 /* get(), c_get() */
  963. #define DB_SET_TXN_NOW 34 /* set_timout() (internal) */
  964. #define DB_SET_TXN_TIMEOUT 35 /* set_timout() */
  965. #define DB_UPDATE_SECONDARY 36 /* c_get(), c_del() (internal) */
  966. #define DB_WRITECURSOR 37 /* cursor() */
  967. #define DB_WRITELOCK 38 /* cursor() (internal) */
  969. /* This has to change when the max opcode hits 255. */
  970. #define DB_OPFLAGS_MASK 0x000000ff /* Mask for operations flags. */
  971. /* DB_DIRTY_READ 0x01000000    Dirty Read. */
  972. #define DB_FLUSH 0x02000000 /* Flush data to disk. */
  973. #define DB_MULTIPLE 0x04000000 /* Return multiple data values. */
  974. #define DB_MULTIPLE_KEY 0x08000000 /* Return multiple data/key pairs. */
  975. #define DB_NOCOPY 0x10000000 /* Don't copy data */
  976. #define DB_PERMANENT 0x20000000 /* Flag record with REP_PERMANENT. */
  977. #define DB_RMW 0x40000000 /* Acquire write flag immediately. */
  978. #define DB_WRNOSYNC 0x80000000 /* Private: write, don't sync log_put */
  980. /*
  981.  * DB (user visible) error return codes.
  982.  *
  983.  * !!!
  984.  * For source compatibility with DB 2.X deadlock return (EAGAIN), use the
  985.  * following:
  986.  * #include <errno.h>
  987.  * #define DB_LOCK_DEADLOCK EAGAIN
  988.  *
  989.  * !!!
  990.  * We don't want our error returns to conflict with other packages where
  991.  * possible, so pick a base error value that's hopefully not common.  We
  992.  * document that we own the error name space from -30,800 to -30,999.
  993.  */
  994. /* DB (public) error return codes. */
  995. #define DB_DONOTINDEX (-30999)/* "Null" return from 2ndary callbk. */
  996. #define DB_KEYEMPTY (-30998)/* Key/data deleted or never created. */
  997. #define DB_KEYEXIST (-30997)/* The key/data pair already exists. */
  998. #define DB_LOCK_DEADLOCK (-30996)/* Deadlock. */
  999. #define DB_LOCK_NOTGRANTED (-30995)/* Lock unavailable. */
  1000. #define DB_NOSERVER (-30994)/* Server panic return. */
  1001. #define DB_NOSERVER_HOME (-30993)/* Bad home sent to server. */
  1002. #define DB_NOSERVER_ID (-30992)/* Bad ID sent to server. */
  1003. #define DB_NOTFOUND (-30991)/* Key/data pair not found (EOF). */
  1004. #define DB_OLD_VERSION (-30990)/* Out-of-date version. */
  1005. #define DB_PAGE_NOTFOUND (-30989)/* Requested page not found. */
  1006. #define DB_REP_DUPMASTER (-30988)/* There are two masters. */
  1007. #define DB_REP_HOLDELECTION (-30987)/* Time to hold an election. */
  1008. #define DB_REP_NEWMASTER (-30986)/* We have learned of a new master. */
  1009. #define DB_REP_NEWSITE (-30985)/* New site entered system. */
  1010. #define DB_REP_OUTDATED (-30984)/* Site is too far behind master. */
  1011. #define DB_REP_UNAVAIL (-30983)/* Site cannot currently be reached. */
  1012. #define DB_RUNRECOVERY (-30982)/* Panic return. */
  1013. #define DB_SECONDARY_BAD (-30981)/* Secondary index corrupt. */
  1014. #define DB_VERIFY_BAD (-30980)/* Verify failed; bad format. */
  1016. /* DB (private) error return codes. */
  1017. #define DB_ALREADY_ABORTED (-30899)
  1018. #define DB_DELETED (-30898)/* Recovery file marked deleted. */
  1019. #define DB_JAVA_CALLBACK (-30897)/* Exception during a java callback. */
  1020. #define DB_LOCK_NOTEXIST (-30896)/* Object to lock is gone. */
  1021. #define DB_NEEDSPLIT (-30895)/* Page needs to be split. */
  1022. #define DB_SURPRISE_KID (-30894)/* Child commit where parent
  1023.    didn't know it was a parent. */
  1024. #define DB_SWAPBYTES (-30893)/* Database needs byte swapping. */
  1025. #define DB_TIMEOUT (-30892)/* Timed out waiting for election. */
  1026. #define DB_TXN_CKP (-30891)/* Encountered ckp record in log. */
  1027. #define DB_VERIFY_FATAL (-30890)/* DB->verify cannot proceed. */
  1029. /* Database handle. */
  1030. struct __db {
  1031. /*******************************************************
  1032.  * Public: owned by the application.
  1033.  *******************************************************/
  1034. u_int32_t pgsize; /* Database logical page size. */
  1036. /* Callbacks. */
  1037. int (*db_append_recno) __P((DB *, DBT *, db_recno_t));
  1038. void (*db_feedback) __P((DB *, int, int));
  1039. int (*dup_compare) __P((DB *, const DBT *, const DBT *));
  1041. void *app_private; /* Application-private handle. */
  1043. /*******************************************************
  1044.  * Private: owned by DB.
  1045.  *******************************************************/
  1046. DB_ENV *dbenv; /* Backing environment. */
  1048. DBTYPE  type; /* DB access method type. */
  1050. DB_MPOOLFILE *mpf; /* Backing buffer pool. */
  1051. DB_CACHE_PRIORITY priority; /* Priority in the buffer pool. */
  1053. DB_MUTEX *mutexp; /* Synchronization for free threading */
  1055. u_int8_t fileid[DB_FILE_ID_LEN];/* File's unique ID for locking. */
  1057. u_int32_t adj_fileid; /* File's unique ID for curs. adj. */
  1059. #define DB_LOGFILEID_INVALID -1
  1060. FNAME *log_filename; /* File's naming info for logging. */
  1062. db_pgno_t meta_pgno; /* Meta page number */
  1063. u_int32_t lid; /* Locker id for handle locking. */
  1064. u_int32_t cur_lid; /* Current handle lock holder. */
  1065. u_int32_t associate_lid; /* Locker id for DB->associate call. */
  1066. DB_LOCK handle_lock; /* Lock held on this handle. */
  1068. long  cl_id; /* RPC: remote client id. */
  1070. /*
  1071.  * Returned data memory for DB->get() and friends.
  1072.  */
  1073. DBT  my_rskey; /* Secondary key. */
  1074. DBT  my_rkey; /* [Primary] key. */
  1075. DBT  my_rdata; /* Data. */
  1077. /*
  1078.  * !!!
  1079.  * Some applications use DB but implement their own locking outside of
  1080.  * DB.  If they're using fcntl(2) locking on the underlying database
  1081.  * file, and we open and close a file descriptor for that file, we will
  1082.  * discard their locks.  The DB_FCNTL_LOCKING flag to DB->open is an
  1083.  * undocumented interface to support this usage which leaves any file
  1084.  * descriptors we open until DB->close.  This will only work with the
  1085.  * DB->open interface and simple caches, e.g., creating a transaction
  1086.  * thread may open/close file descriptors this flag doesn't protect.
  1087.  * Locking with fcntl(2) on a file that you don't own is a very, very
  1088.  * unsafe thing to do.  'Nuff said.
  1089.  */
  1090. DB_FH *saved_open_fhp; /* Saved file handle. */
  1092. /*
  1093.  * Linked list of DBP's, linked from the DB_ENV, used to keep track
  1094.  * of all open db handles for cursor adjustment.
  1095.  *
  1096.  * !!!
  1097.  * Explicit representations of structures from queue.h.
  1098.  * LIST_ENTRY(__db) dblistlinks;
  1099.  */
  1100. struct {
  1101. struct __db *le_next;
  1102. struct __db **le_prev;
  1103. } dblistlinks;
  1105. /*
  1106.  * Cursor queues.
  1107.  *
  1108.  * !!!
  1109.  * Explicit representations of structures from queue.h.
  1110.  * TAILQ_HEAD(__cq_fq, __dbc) free_queue;
  1111.  * TAILQ_HEAD(__cq_aq, __dbc) active_queue;
  1112.  * TAILQ_HEAD(__cq_jq, __dbc) join_queue;
  1113.  */
  1114. struct __cq_fq {
  1115. struct __dbc *tqh_first;
  1116. struct __dbc **tqh_last;
  1117. } free_queue;
  1118. struct __cq_aq {
  1119. struct __dbc *tqh_first;
  1120. struct __dbc **tqh_last;
  1121. } active_queue;
  1122. struct __cq_jq {
  1123. struct __dbc *tqh_first;
  1124. struct __dbc **tqh_last;
  1125. } join_queue;
  1127. /*
  1128.  * Secondary index support.
  1129.  *
  1130.  * Linked list of secondary indices -- set in the primary.
  1131.  *
  1132.  * !!!
  1133.  * Explicit representations of structures from queue.h.
  1134.  * LIST_HEAD(s_secondaries, __db);
  1135.  */
  1136. struct {
  1137. struct __db *lh_first;
  1138. } s_secondaries;
  1140. /*
  1141.  * List entries for secondaries, and reference count of how
  1142.  * many threads are updating this secondary (see __db_c_put).
  1143.  *
  1144.  * !!!
  1145.  * Note that these are synchronized by the primary's mutex, but
  1146.  * filled in in the secondaries.
  1147.  *
  1148.  * !!!
  1149.  * Explicit representations of structures from queue.h.
  1150.  * LIST_ENTRY(__db) s_links;
  1151.  */
  1152. struct {
  1153. struct __db *le_next;
  1154. struct __db **le_prev;
  1155. } s_links;
  1156. u_int32_t s_refcnt;
  1158. /* Secondary callback and free functions -- set in the secondary. */
  1159. int (*s_callback) __P((DB *, const DBT *, const DBT *, DBT *));
  1161. /* Reference to primary -- set in the secondary. */
  1162. DB *s_primary;
  1164. /* API-private structure: used by DB 1.85, C++, Java, Perl and Tcl */
  1165. void *api_internal;
  1167. /* Subsystem-private structure. */
  1168. void *bt_internal; /* Btree/Recno access method. */
  1169. void *h_internal; /* Hash access method. */
  1170. void *q_internal; /* Queue access method. */
  1171. void *xa_internal; /* XA. */
  1173. /* Methods. */
  1174. int  (*associate) __P((DB *, DB_TXN *, DB *, int (*)(DB *, const DBT *,
  1175. const DBT *, DBT *), u_int32_t));
  1176. int  (*close) __P((DB *, u_int32_t));
  1177. int  (*cursor) __P((DB *, DB_TXN *, DBC **, u_int32_t));
  1178. int  (*del) __P((DB *, DB_TXN *, DBT *, u_int32_t));
  1179. void (*err) __P((DB *, int, const char *, ...));
  1180. void (*errx) __P((DB *, const char *, ...));
  1181. int  (*fd) __P((DB *, int *));
  1182. int  (*get) __P((DB *, DB_TXN *, DBT *, DBT *, u_int32_t));
  1183. int  (*pget) __P((DB *, DB_TXN *, DBT *, DBT *, DBT *, u_int32_t));
  1184. int  (*get_byteswapped) __P((DB *, int *));
  1185. int  (*get_type) __P((DB *, DBTYPE *));
  1186. int  (*join) __P((DB *, DBC **, DBC **, u_int32_t));
  1187. int  (*key_range) __P((DB *,
  1188. DB_TXN *, DBT *, DB_KEY_RANGE *, u_int32_t));
  1189. int  (*open) __P((DB *, DB_TXN *,
  1190. const char *, const char *, DBTYPE, u_int32_t, int));
  1191. int  (*put) __P((DB *, DB_TXN *, DBT *, DBT *, u_int32_t));
  1192. int  (*remove) __P((DB *, const char *, const char *, u_int32_t));
  1193. int  (*rename) __P((DB *,
  1194.     const char *, const char *, const char *, u_int32_t));
  1195. int  (*truncate) __P((DB *, DB_TXN *, u_int32_t *, u_int32_t));
  1196. int  (*set_append_recno) __P((DB *, int (*)(DB *, DBT *, db_recno_t)));
  1197. int  (*set_alloc) __P((DB *, void *(*)(size_t),
  1198. void *(*)(void *, size_t), void (*)(void *)));
  1199. int  (*set_cachesize) __P((DB *, u_int32_t, u_int32_t, int));
  1200. int  (*set_cache_priority) __P((DB *, DB_CACHE_PRIORITY));
  1201. int  (*set_dup_compare) __P((DB *,
  1202.     int (*)(DB *, const DBT *, const DBT *)));
  1203. int  (*set_encrypt) __P((DB *, const char *, u_int32_t));
  1204. void (*set_errcall) __P((DB *, void (*)(const char *, char *)));
  1205. void (*set_errfile) __P((DB *, FILE *));
  1206. void (*set_errpfx) __P((DB *, const char *));
  1207. int  (*set_feedback) __P((DB *, void (*)(DB *, int, int)));
  1208. int  (*set_flags) __P((DB *, u_int32_t));
  1209. int  (*set_lorder) __P((DB *, int));
  1210. int  (*set_pagesize) __P((DB *, u_int32_t));
  1211. int  (*set_paniccall) __P((DB *, void (*)(DB_ENV *, int)));
  1212. int  (*stat) __P((DB *, void *, u_int32_t));
  1213. int  (*sync) __P((DB *, u_int32_t));
  1214. int  (*upgrade) __P((DB *, const char *, u_int32_t));
  1215. int  (*verify) __P((DB *,
  1216.     const char *, const char *, FILE *, u_int32_t));
  1218. int  (*set_bt_compare) __P((DB *,
  1219.     int (*)(DB *, const DBT *, const DBT *)));
  1220. int  (*set_bt_maxkey) __P((DB *, u_int32_t));
  1221. int  (*set_bt_minkey) __P((DB *, u_int32_t));
  1222. int  (*set_bt_prefix) __P((DB *,
  1223.     size_t (*)(DB *, const DBT *, const DBT *)));
  1225. int  (*set_h_ffactor) __P((DB *, u_int32_t));
  1226. int  (*set_h_hash) __P((DB *,
  1227.     u_int32_t (*)(DB *, const void *, u_int32_t)));
  1228. int  (*set_h_nelem) __P((DB *, u_int32_t));
  1230. int  (*set_re_delim) __P((DB *, int));
  1231. int  (*set_re_len) __P((DB *, u_int32_t));
  1232. int  (*set_re_pad) __P((DB *, int));
  1233. int  (*set_re_source) __P((DB *, const char *));
  1234. int  (*set_q_extentsize) __P((DB *, u_int32_t));
  1236. int  (*db_am_remove) __P((DB *,
  1237.     DB_TXN *, const char *, const char *, DB_LSN *));
  1238. int  (*db_am_rename) __P((DB *, DB_TXN *,
  1239.     const char *, const char *, const char *));
  1241. /*
  1242.  * Never called; these are a place to save function pointers
  1243.  * so that we can undo an associate.
  1244.  */
  1245. int  (*stored_get) __P((DB *, DB_TXN *, DBT *, DBT *, u_int32_t));
  1246. int  (*stored_close) __P((DB *, u_int32_t));
  1248. #define DB_OK_BTREE 0x01
  1249. #define DB_OK_HASH 0x02
  1250. #define DB_OK_QUEUE 0x04
  1251. #define DB_OK_RECNO 0x08
  1252. u_int32_t am_ok; /* Legal AM choices. */
  1254. #define DB_AM_CHKSUM 0x00000001 /* Checksumming. */
  1255. #define DB_AM_CL_WRITER 0x00000002 /* Allow writes in client replica. */
  1256. #define DB_AM_COMPENSATE 0x00000004 /* Created by compensating txn. */
  1257. #define DB_AM_CREATED 0x00000008 /* Database was created upon open. */
  1258. #define DB_AM_CREATED_MSTR 0x00000010 /* Encompassing file was created. */
  1259. #define DB_AM_DBM_ERROR 0x00000020 /* Error in DBM/NDBM database. */
  1260. #define DB_AM_DELIMITER 0x00000040 /* Variable length delimiter set. */
  1261. #define DB_AM_DIRTY 0x00000080 /* Support Dirty Reads. */
  1262. #define DB_AM_DISCARD 0x00000100 /* Discard any cached pages. */
  1263. #define DB_AM_DUP 0x00000200 /* DB_DUP. */
  1264. #define DB_AM_DUPSORT 0x00000400 /* DB_DUPSORT. */
  1265. #define DB_AM_ENCRYPT 0x00000800 /* Encryption. */
  1266. #define DB_AM_FIXEDLEN 0x00001000 /* Fixed-length records. */
  1267. #define DB_AM_INMEM 0x00002000 /* In-memory; no sync on close. */
  1268. #define DB_AM_IN_RENAME 0x00004000 /* File is being renamed. */
  1269. #define DB_AM_OPEN_CALLED 0x00008000 /* DB->open called. */
  1270. #define DB_AM_PAD 0x00010000 /* Fixed-length record pad. */
  1271. #define DB_AM_PGDEF 0x00020000 /* Page size was defaulted. */
  1272. #define DB_AM_RDONLY 0x00040000 /* Database is readonly. */
  1273. #define DB_AM_RECNUM 0x00080000 /* DB_RECNUM. */
  1274. #define DB_AM_RECOVER 0x00100000 /* DB opened by recovery routine. */
  1275. #define DB_AM_RENUMBER 0x00200000 /* DB_RENUMBER. */
  1276. #define DB_AM_REVSPLITOFF 0x00400000 /* DB_REVSPLITOFF. */
  1277. #define DB_AM_SECONDARY 0x00800000 /* Database is a secondary index. */
  1278. #define DB_AM_SNAPSHOT 0x01000000 /* DB_SNAPSHOT. */
  1279. #define DB_AM_SUBDB 0x02000000 /* Subdatabases supported. */
  1280. #define DB_AM_SWAP 0x04000000 /* Pages need to be byte-swapped. */
  1281. #define DB_AM_TXN 0x08000000 /* Opened in a transaction. */
  1282. #define DB_AM_VERIFYING 0x10000000 /* DB handle is in the verifier. */
  1283. u_int32_t flags;
  1284. };
  1286. /*
  1287.  * Macros for bulk get.  Note that wherever we use a DBT *, we explicitly
  1288.  * cast it; this allows the same macros to work with C++ Dbt *'s, as Dbt
  1289.  * is a subclass of struct DBT in C++.
  1290.  */
  1291. #define DB_MULTIPLE_INIT(pointer, dbt)
  1292. (pointer = (u_int8_t *)((DBT *)(dbt))->data +
  1293.     ((DBT *)(dbt))->ulen - sizeof(u_int32_t))
  1294. #define DB_MULTIPLE_NEXT(pointer, dbt, retdata, retdlen)
  1295. do {
  1296. if (*((u_int32_t *)(pointer)) == (u_int32_t)-1) {
  1297. retdata = NULL;
  1298. pointer = NULL;
  1299. break;
  1300. }
  1301. retdata = (u_int8_t *)
  1302.     ((DBT *)(dbt))->data + *(u_int32_t *)(pointer);
  1303. (pointer) = (u_int32_t *)(pointer) - 1;
  1304. retdlen = *(u_int32_t *)(pointer);
  1305. (pointer) = (u_int32_t *)(pointer) - 1;
  1306. if (retdlen == 0 &&
  1307.     retdata == (u_int8_t *)((DBT *)(dbt))->data)
  1308. retdata = NULL;
  1309. } while (0)
  1310. #define DB_MULTIPLE_KEY_NEXT(pointer, dbt, retkey, retklen, retdata, retdlen) 
  1311. do {
  1312. if (*((u_int32_t *)(pointer)) == (u_int32_t)-1) {
  1313. retdata = NULL;
  1314. retkey = NULL;
  1315. pointer = NULL;
  1316. break;
  1317. }
  1318. retkey = (u_int8_t *)
  1319.     ((DBT *)(dbt))->data + *(u_int32_t *)(pointer);
  1320. (pointer) = (u_int32_t *)(pointer) - 1;
  1321. retklen = *(u_int32_t *)(pointer);
  1322. (pointer) = (u_int32_t *)(pointer) - 1;
  1323. retdata = (u_int8_t *)
  1324.     ((DBT *)(dbt))->data + *(u_int32_t *)(pointer);
  1325. (pointer) = (u_int32_t *)(pointer) - 1;
  1326. retdlen = *(u_int32_t *)(pointer);
  1327. (pointer) = (u_int32_t *)(pointer) - 1;
  1328. } while (0)
  1330. #define DB_MULTIPLE_RECNO_NEXT(pointer, dbt, recno, retdata, retdlen)   
  1331. do {
  1332. if (*((u_int32_t *)(pointer)) == (u_int32_t)0) {
  1333. recno = 0;
  1334. retdata = NULL;
  1335. pointer = NULL;
  1336. break;
  1337. }
  1338. recno = *(u_int32_t *)(pointer);
  1339. (pointer) = (u_int32_t *)(pointer) - 1;
  1340. retdata = (u_int8_t *)
  1341.     ((DBT *)(dbt))->data + *(u_int32_t *)(pointer);
  1342. (pointer) = (u_int32_t *)(pointer) - 1;
  1343. retdlen = *(u_int32_t *)(pointer);
  1344. (pointer) = (u_int32_t *)(pointer) - 1;
  1345. } while (0)
  1347. /*******************************************************
  1348.  * Access method cursors.
  1349.  *******************************************************/
  1350. struct __dbc {
  1351. DB *dbp; /* Related DB access method. */
  1352. DB_TXN  *txn; /* Associated transaction. */
  1354. /*
  1355.  * Active/free cursor queues.
  1356.  *
  1357.  * !!!
  1358.  * Explicit representations of structures from queue.h.
  1359.  * TAILQ_ENTRY(__dbc) links;
  1360.  */
  1361. struct {
  1362. DBC *tqe_next;
  1363. DBC **tqe_prev;
  1364. } links;
  1366. /*
  1367.  * The DBT *'s below are used by the cursor routines to return
  1368.  * data to the user when DBT flags indicate that DB should manage
  1369.  * the returned memory.  They point at a DBT containing the buffer
  1370.  * and length that will be used, and "belonging" to the handle that
  1371.  * should "own" this memory.  This may be a "my_*" field of this
  1372.  * cursor--the default--or it may be the corresponding field of
  1373.  * another cursor, a DB handle, a join cursor, etc.  In general, it
  1374.  * will be whatever handle the user originally used for the current
  1375.  * DB interface call.
  1376.  */
  1377. DBT  *rskey; /* Returned secondary key. */
  1378. DBT  *rkey; /* Returned [primary] key. */
  1379. DBT  *rdata; /* Returned data. */
  1381. DBT   my_rskey; /* Space for returned secondary key. */
  1382. DBT   my_rkey; /* Space for returned [primary] key. */
  1383. DBT   my_rdata; /* Space for returned data. */
  1385. u_int32_t lid; /* Default process' locker id. */
  1386. u_int32_t locker; /* Locker for this operation. */
  1387. DBT   lock_dbt; /* DBT referencing lock. */
  1388. DB_LOCK_ILOCK lock; /* Object to be locked. */
  1389. DB_LOCK   mylock; /* Lock held on this cursor. */
  1391. long   cl_id; /* Remote client id. */
  1393. DBTYPE   dbtype; /* Cursor type. */
  1395. DBC_INTERNAL *internal; /* Access method private. */
  1397. int (*c_close) __P((DBC *)); /* Methods: public. */
  1398. int (*c_count) __P((DBC *, db_recno_t *, u_int32_t));
  1399. int (*c_del) __P((DBC *, u_int32_t));
  1400. int (*c_dup) __P((DBC *, DBC **, u_int32_t));
  1401. int (*c_get) __P((DBC *, DBT *, DBT *, u_int32_t));
  1402. int (*c_pget) __P((DBC *, DBT *, DBT *, DBT *, u_int32_t));
  1403. int (*c_put) __P((DBC *, DBT *, DBT *, u_int32_t));
  1405. /* Methods: private. */
  1406. int (*c_am_bulk) __P((DBC *, DBT *, u_int32_t));
  1407. int (*c_am_close) __P((DBC *, db_pgno_t, int *));
  1408. int (*c_am_del) __P((DBC *));
  1409. int (*c_am_destroy) __P((DBC *));
  1410. int (*c_am_get) __P((DBC *, DBT *, DBT *, u_int32_t, db_pgno_t *));
  1411. int (*c_am_put) __P((DBC *, DBT *, DBT *, u_int32_t, db_pgno_t *));
  1412. int (*c_am_writelock) __P((DBC *));
  1414. /* Private: for secondary indices. */
  1415. int (*c_real_get) __P((DBC *, DBT *, DBT *, u_int32_t));
  1417. #define DBC_ACTIVE  0x0001 /* Cursor in use. */
  1418. #define DBC_COMPENSATE  0x0002 /* Cursor compensating, don't lock. */
  1419. #define DBC_DIRTY_READ  0x0004 /* Cursor supports dirty reads. */
  1420. #define DBC_OPD  0x0008 /* Cursor references off-page dups. */
  1421. #define DBC_RECOVER  0x0010 /* Recovery cursor; don't log/lock. */
  1422. #define DBC_RMW  0x0020 /* Acquire write flag in read op. */
  1423. #define DBC_TRANSIENT  0x0040 /* Cursor is transient. */
  1424. #define DBC_WRITECURSOR  0x0080 /* Cursor may be used to write (CDB). */
  1425. #define DBC_WRITEDUP  0x0100 /* idup'ed DBC_WRITECURSOR (CDB). */
  1426. #define DBC_WRITER  0x0200 /* Cursor immediately writing (CDB). */
  1427. #define DBC_MULTIPLE  0x0400 /* Return Multiple data. */
  1428. #define DBC_MULTIPLE_KEY 0x0800 /* Return Multiple keys and data. */
  1429. #define DBC_OWN_LID  0x1000 /* Free lock id on destroy. */
  1430. u_int32_t flags;
  1431. };
  1433. /* Key range statistics structure */
  1434. struct __key_range {
  1435. double less;
  1436. double equal;
  1437. double greater;
  1438. };
  1440. /* Btree/Recno statistics structure. */
  1441. struct __db_bt_stat {
  1442. u_int32_t bt_magic; /* Magic number. */
  1443. u_int32_t bt_version; /* Version number. */
  1444. u_int32_t bt_metaflags; /* Metadata flags. */
  1445. u_int32_t bt_nkeys; /* Number of unique keys. */
  1446. u_int32_t bt_ndata; /* Number of data items. */
  1447. u_int32_t bt_pagesize; /* Page size. */
  1448. u_int32_t bt_maxkey; /* Maxkey value. */
  1449. u_int32_t bt_minkey; /* Minkey value. */
  1450. u_int32_t bt_re_len; /* Fixed-length record length. */
  1451. u_int32_t bt_re_pad; /* Fixed-length record pad. */
  1452. u_int32_t bt_levels; /* Tree levels. */
  1453. u_int32_t bt_int_pg; /* Internal pages. */
  1454. u_int32_t bt_leaf_pg; /* Leaf pages. */
  1455. u_int32_t bt_dup_pg; /* Duplicate pages. */
  1456. u_int32_t bt_over_pg; /* Overflow pages. */
  1457. u_int32_t bt_free; /* Pages on the free list. */
  1458. u_int32_t bt_int_pgfree; /* Bytes free in internal pages. */
  1459. u_int32_t bt_leaf_pgfree; /* Bytes free in leaf pages. */
  1460. u_int32_t bt_dup_pgfree; /* Bytes free in duplicate pages. */
  1461. u_int32_t bt_over_pgfree; /* Bytes free in overflow pages. */
  1462. };
  1464. /* Hash statistics structure. */
  1465. struct __db_h_stat {
  1466. u_int32_t hash_magic; /* Magic number. */
  1467. u_int32_t hash_version; /* Version number. */
  1468. u_int32_t hash_metaflags; /* Metadata flags. */
  1469. u_int32_t hash_nkeys; /* Number of unique keys. */
  1470. u_int32_t hash_ndata; /* Number of data items. */
  1471. u_int32_t hash_pagesize; /* Page size. */
  1472. u_int32_t hash_ffactor; /* Fill factor specified at create. */
  1473. u_int32_t hash_buckets; /* Number of hash buckets. */
  1474. u_int32_t hash_free; /* Pages on the free list. */
  1475. u_int32_t hash_bfree; /* Bytes free on bucket pages. */
  1476. u_int32_t hash_bigpages; /* Number of big key/data pages. */
  1477. u_int32_t hash_big_bfree; /* Bytes free on big item pages. */
  1478. u_int32_t hash_overflows; /* Number of overflow pages. */
  1479. u_int32_t hash_ovfl_free; /* Bytes free on ovfl pages. */
  1480. u_int32_t hash_dup; /* Number of dup pages. */
  1481. u_int32_t hash_dup_free; /* Bytes free on duplicate pages. */
  1482. };
  1484. /* Queue statistics structure. */
  1485. struct __db_qam_stat {
  1486. u_int32_t qs_magic; /* Magic number. */
  1487. u_int32_t qs_version; /* Version number. */
  1488. u_int32_t qs_metaflags; /* Metadata flags. */
  1489. u_int32_t qs_nkeys; /* Number of unique keys. */
  1490. u_int32_t qs_ndata; /* Number of data items. */
  1491. u_int32_t qs_pagesize; /* Page size. */
  1492. u_int32_t qs_extentsize; /* Pages per extent. */
  1493. u_int32_t qs_pages; /* Data pages. */
  1494. u_int32_t qs_re_len; /* Fixed-length record length. */
  1495. u_int32_t qs_re_pad; /* Fixed-length record pad. */
  1496. u_int32_t qs_pgfree; /* Bytes free in data pages. */
  1497. u_int32_t qs_first_recno; /* First not deleted record. */
  1498. u_int32_t qs_cur_recno; /* Next available record number. */
  1499. };
  1501. /*******************************************************
  1502.  * Environment.
  1503.  *******************************************************/
  1504. #define DB_REGION_MAGIC 0x120897 /* Environment magic number. */
  1506. typedef enum {
  1507. DB_NOTICE_LOGFILE_CHANGED
  1508. } db_notices;
  1510. /* Database Environment handle. */
  1511. struct __db_env {
  1512. /*******************************************************
  1513.  * Public: owned by the application.
  1514.  *******************************************************/
  1515. FILE *db_errfile; /* Error message file stream. */
  1516. const char *db_errpfx; /* Error message prefix. */
  1517. /* Callbacks. */
  1518. void (*db_errcall) __P((const char *, char *));
  1519. void (*db_feedback) __P((DB_ENV *, int, int));
  1520. void (*db_paniccall) __P((DB_ENV *, int));
  1521. void (*db_noticecall) __P((DB_ENV *, db_notices));
  1523. /* App-specified alloc functions. */
  1524. void *(*db_malloc) __P((size_t));
  1525. void *(*db_realloc) __P((void *, size_t));
  1526. void (*db_free) __P((void *));
  1528. /*
  1529.  * Currently, the verbose list is a bit field with room for 32
  1530.  * entries.  There's no reason that it needs to be limited, if
  1531.  * there are ever more than 32 entries, convert to a bit array.
  1532.  */
  1533. #define DB_VERB_CHKPOINT 0x0001 /* List checkpoints. */
  1534. #define DB_VERB_DEADLOCK 0x0002 /* Deadlock detection information. */
  1535. #define DB_VERB_RECOVERY 0x0004 /* Recovery information. */
  1536. #define DB_VERB_REPLICATION 0x0008 /* Replication information. */
  1537. #define DB_VERB_WAITSFOR 0x0010 /* Dump waits-for table. */
  1538. u_int32_t  verbose; /* Verbose output. */
  1540. void *app_private; /* Application-private handle. */
  1542. int (*app_dispatch) /* User-specified recovery dispatch. */
  1543.     __P((DB_ENV *, DBT *, DB_LSN *, db_recops));
  1545. /* Locking. */
  1546. u_int8_t *lk_conflicts; /* Two dimensional conflict matrix. */
  1547. u_int32_t  lk_modes; /* Number of lock modes in table. */
  1548. u_int32_t  lk_max; /* Maximum number of locks. */
  1549. u_int32_t  lk_max_lockers;/* Maximum number of lockers. */
  1550. u_int32_t  lk_max_objects;/* Maximum number of locked objects. */
  1551. u_int32_t  lk_detect; /* Deadlock detect on all conflicts. */
  1552. db_timeout_t  lk_timeout; /* Lock timeout period. */
  1554. /* Logging. */
  1555. u_int32_t  lg_bsize; /* Buffer size. */
  1556. u_int32_t  lg_size; /* Log file size. */
  1557. u_int32_t  lg_regionmax; /* Region size. */
  1559. /* Memory pool. */
  1560. u_int32_t  mp_gbytes; /* Cachesize: GB. */
  1561. u_int32_t  mp_bytes; /* Cachesize: Bytes. */
  1562. size_t  mp_size; /* DEPRECATED: Cachesize: bytes. */
  1563. int  mp_ncache; /* Number of cache regions. */
  1564. size_t  mp_mmapsize; /* Maximum file size for mmap. */
  1566. int  rep_eid; /* environment id. */
  1568. /* Transactions. */
  1569. u_int32_t  tx_max; /* Maximum number of transactions. */
  1570. time_t  tx_timestamp; /* Recover to specific timestamp. */
  1571. db_timeout_t  tx_timeout; /* Timeout for transactions. */
  1573. /*******************************************************
  1574.  * Private: owned by DB.
  1575.  *******************************************************/
  1576. int  panic_errval; /* Panic causing errno. */
  1578. /* User files, paths. */
  1579. char *db_home; /* Database home. */
  1580. char *db_log_dir; /* Database log file directory. */
  1581. char *db_tmp_dir; /* Database tmp file directory. */
  1583. char        **db_data_dir; /* Database data file directories. */
  1584. int  data_cnt; /* Database data file slots. */
  1585. int  data_next; /* Next Database data file slot. */
  1587. int  db_mode; /* Default open permissions. */
  1589. void *reginfo; /* REGINFO structure reference. */
  1590. DB_FH *lockfhp; /* fcntl(2) locking file handle. */
  1592. int       (**recover_dtab) /* Dispatch table for recover funcs. */
  1593.     __P((DB_ENV *, DBT *, DB_LSN *, db_recops, void *));
  1594. size_t  recover_dtab_size;
  1595. /* Slots in the dispatch table. */
  1597. void *cl_handle; /* RPC: remote client handle. */
  1598. long  cl_id; /* RPC: remote client env id. */
  1600. int  db_ref; /* DB reference count. */
  1602. long  shm_key; /* shmget(2) key. */
  1603. u_int32_t  tas_spins; /* test-and-set spins. */
  1605. /*
  1606.  * List of open DB handles for this DB_ENV, used for cursor
  1607.  * adjustment.  Must be protected for multi-threaded support.
  1608.  *
  1609.  * !!!
  1610.  * As this structure is allocated in per-process memory, the
  1611.  * mutex may need to be stored elsewhere on architectures unable
  1612.  * to support mutexes in heap memory, e.g. HP/UX 9.
  1613.  *
  1614.  * !!!
  1615.  * Explicit representation of structure in queue.h.
  1616.  * LIST_HEAD(dblist, __db);
  1617.  */
  1618. DB_MUTEX *dblist_mutexp; /* Mutex. */
  1619. struct {
  1620. struct __db *lh_first;
  1621. } dblist;
  1623. /*
  1624.  * XA support.
  1625.  *
  1626.  * !!!
  1627.  * Explicit representations of structures from queue.h.
  1628.  * TAILQ_ENTRY(__db_env) links;
  1629.  */
  1630. struct {
  1631. struct __db_env *tqe_next;
  1632. struct __db_env **tqe_prev;
  1633. } links;
  1634. int  xa_rmid; /* XA Resource Manager ID. */
  1635. DB_TXN *xa_txn; /* XA Current transaction. */
  1637. /* API-private structure. */
  1638. void *api1_internal; /* C++, Perl API private */
  1639. void *api2_internal; /* Java API private */
  1641. char *passwd; /* Cryptography support. */
  1642. size_t  passwd_len;
  1643. void *crypto_handle; /* Primary handle. */
  1644. DB_MUTEX *mt_mutexp; /* Mersenne Twister mutex. */
  1645. int  mti; /* Mersenne Twister index. */
  1646. u_long *mt; /* Mersenne Twister state vector. */
  1648. /* DB_ENV Methods. */
  1649. int  (*close) __P((DB_ENV *, u_int32_t));
  1650. int  (*dbremove) __P((DB_ENV *,
  1651.     DB_TXN *, const char *, const char *, u_int32_t));
  1652. int  (*dbrename) __P((DB_ENV *, DB_TXN *,
  1653.     const char *, const char *, const char *, u_int32_t));
  1654. void (*err) __P((const DB_ENV *, int, const char *, ...));
  1655. void (*errx) __P((const DB_ENV *, const char *, ...));
  1656. int  (*open) __P((DB_ENV *, const char *, u_int32_t, int));
  1657. int  (*remove) __P((DB_ENV *, const char *, u_int32_t));
  1658. int  (*set_data_dir) __P((DB_ENV *, const char *));
  1659. int  (*set_alloc) __P((DB_ENV *, void *(*)(size_t),
  1660. void *(*)(void *, size_t), void (*)(void *)));
  1661. int  (*set_app_dispatch) __P((DB_ENV *,
  1662. int (*)(DB_ENV *, DBT *, DB_LSN *, db_recops)));
  1663. int  (*set_encrypt) __P((DB_ENV *, const char *, u_int32_t));
  1664. void (*set_errcall) __P((DB_ENV *, void (*)(const char *, char *)));
  1665. void (*set_errfile) __P((DB_ENV *, FILE *));
  1666. void (*set_errpfx) __P((DB_ENV *, const char *));
  1667. int  (*set_feedback) __P((DB_ENV *, void (*)(DB_ENV *, int, int)));
  1668. int  (*set_flags) __P((DB_ENV *, u_int32_t, int));
  1669. void (*set_noticecall) __P((DB_ENV *, void (*)(DB_ENV *, db_notices)));
  1670. int  (*set_paniccall) __P((DB_ENV *, void (*)(DB_ENV *, int)));
  1671. int  (*set_rpc_server) __P((DB_ENV *,
  1672. void *, const char *, long, long, u_int32_t));
  1673. int  (*set_shm_key) __P((DB_ENV *, long));
  1674. int  (*set_tas_spins) __P((DB_ENV *, u_int32_t));
  1675. int  (*set_tmp_dir) __P((DB_ENV *, const char *));
  1676. int  (*set_verbose) __P((DB_ENV *, u_int32_t, int));
  1678. void *lg_handle; /* Log handle and methods. */
  1679. int  (*set_lg_bsize) __P((DB_ENV *, u_int32_t));
  1680. int  (*set_lg_dir) __P((DB_ENV *, const char *));
  1681. int  (*set_lg_max) __P((DB_ENV *, u_int32_t));
  1682. int  (*set_lg_regionmax) __P((DB_ENV *, u_int32_t));
  1683. int  (*log_archive) __P((DB_ENV *, char **[], u_int32_t));
  1684. int  (*log_cursor) __P((DB_ENV *, DB_LOGC **, u_int32_t));
  1685. int  (*log_file) __P((DB_ENV *, const DB_LSN *, char *, size_t));
  1686. int  (*log_flush) __P((DB_ENV *, const DB_LSN *));
  1687. int  (*log_put) __P((DB_ENV *, DB_LSN *, const DBT *, u_int32_t));
  1688. int  (*log_stat) __P((DB_ENV *, DB_LOG_STAT **, u_int32_t));
  1690. void *lk_handle; /* Lock handle and methods. */
  1691. int  (*set_lk_conflicts) __P((DB_ENV *, u_int8_t *, int));
  1692. int  (*set_lk_detect) __P((DB_ENV *, u_int32_t));
  1693. int  (*set_lk_max) __P((DB_ENV *, u_int32_t));
  1694. int  (*set_lk_max_locks) __P((DB_ENV *, u_int32_t));
  1695. int  (*set_lk_max_lockers) __P((DB_ENV *, u_int32_t));
  1696. int  (*set_lk_max_objects) __P((DB_ENV *, u_int32_t));
  1697. int  (*lock_detect) __P((DB_ENV *, u_int32_t, u_int32_t, int *));
  1698. int  (*lock_dump_region) __P((DB_ENV *, char *, FILE *));
  1699. int  (*lock_get) __P((DB_ENV *,
  1700. u_int32_t, u_int32_t, const DBT *, db_lockmode_t, DB_LOCK *));
  1701. int  (*lock_put) __P((DB_ENV *, DB_LOCK *));
  1702. int  (*lock_id) __P((DB_ENV *, u_int32_t *));
  1703. int  (*lock_id_free) __P((DB_ENV *, u_int32_t));
  1704. int  (*lock_id_set) __P((DB_ENV *, u_int32_t, u_int32_t));
  1705. int  (*lock_stat) __P((DB_ENV *, DB_LOCK_STAT **, u_int32_t));
  1706. int  (*lock_vec) __P((DB_ENV *,
  1707. u_int32_t, u_int32_t, DB_LOCKREQ *, int, DB_LOCKREQ **));
  1708. int  (*lock_downgrade) __P((DB_ENV *,
  1709. DB_LOCK *, db_lockmode_t, u_int32_t));
  1711. void *mp_handle; /* Mpool handle and methods. */
  1712. int  (*set_mp_mmapsize) __P((DB_ENV *, size_t));
  1713. int  (*set_cachesize) __P((DB_ENV *, u_int32_t, u_int32_t, int));
  1714. int  (*memp_dump_region) __P((DB_ENV *, char *, FILE *));
  1715. int  (*memp_fcreate) __P((DB_ENV *, DB_MPOOLFILE **, u_int32_t));
  1716. int  (*memp_nameop) __P((DB_ENV *,
  1717. u_int8_t *, const char *, const char *, const char *));
  1718. int  (*memp_register) __P((DB_ENV *, int,
  1719. int (*)(DB_ENV *, db_pgno_t, void *, DBT *),
  1720. int (*)(DB_ENV *, db_pgno_t, void *, DBT *)));
  1721. int  (*memp_stat) __P((DB_ENV *,
  1722. DB_MPOOL_STAT **, DB_MPOOL_FSTAT ***, u_int32_t));
  1723. int  (*memp_sync) __P((DB_ENV *, DB_LSN *));
  1724. int  (*memp_trickle) __P((DB_ENV *, int, int *));
  1726. void *rep_handle; /* Replication handle and methods. */
  1727. int  (*rep_elect) __P((DB_ENV *, int, int, u_int32_t, int *));
  1728. int  (*rep_flush) __P((DB_ENV *));
  1729. int  (*rep_process_message) __P((DB_ENV *, DBT *, DBT *, int *));
  1730. int  (*rep_start) __P((DB_ENV *, DBT *, u_int32_t));
  1731. int  (*rep_stat) __P((DB_ENV *, DB_REP_STAT **, u_int32_t));
  1732. int  (*set_rep_election) __P((DB_ENV *,
  1733. u_int32_t, u_int32_t, u_int32_t, u_int32_t));
  1734. int  (*set_rep_limit) __P((DB_ENV *, u_int32_t, u_int32_t));
  1735. int  (*set_rep_request) __P((DB_ENV *, u_int32_t, u_int32_t));
  1736. int  (*set_rep_timeout) __P((DB_ENV *, u_int32_t, u_int32_t));
  1737. int  (*set_rep_transport) __P((DB_ENV *, int,
  1738. int (*) (DB_ENV *, const DBT *, const DBT *, int, u_int32_t)));
  1740. void *tx_handle; /* Txn handle and methods. */
  1741. int  (*set_tx_max) __P((DB_ENV *, u_int32_t));
  1742. int  (*set_tx_timestamp) __P((DB_ENV *, time_t *));
  1743. int  (*txn_begin) __P((DB_ENV *, DB_TXN *, DB_TXN **, u_int32_t));
  1744. int  (*txn_checkpoint) __P((DB_ENV *, u_int32_t, u_int32_t, u_int32_t));
  1745. int  (*txn_id_set) __P((DB_ENV *, u_int32_t, u_int32_t));
  1746. int  (*txn_recover) __P((DB_ENV *,
  1747. DB_PREPLIST *, long, long *, u_int32_t));
  1748. int  (*txn_stat) __P((DB_ENV *, DB_TXN_STAT **, u_int32_t));
  1749. int  (*set_timeout) __P((DB_ENV *, db_timeout_t, u_int32_t));
  1751. #define DB_TEST_ELECTINIT  1 /* after __rep_elect_init */
  1752. #define DB_TEST_ELECTSEND  2 /* after REP_ELECT msgnit */
  1753. #define DB_TEST_ELECTVOTE1  3 /* after __rep_send_vote 1 */
  1754. #define DB_TEST_ELECTVOTE2  4 /* after __rep_wait */
  1755. #define DB_TEST_ELECTWAIT1  5 /* after REP_VOTE2 */
  1756. #define DB_TEST_ELECTWAIT2  6 /* after __rep_wait 2 */
  1757. #define DB_TEST_PREDESTROY  7 /* before destroy op */
  1758. #define DB_TEST_PREOPEN  8 /* before __os_open */
  1759. #define DB_TEST_POSTDESTROY  9 /* after destroy op */
  1760. #define DB_TEST_POSTLOG  10 /* after logging all pages */
  1761. #define DB_TEST_POSTLOGMETA  11 /* after logging meta in btree */
  1762. #define DB_TEST_POSTOPEN  12 /* after __os_open */
  1763. #define DB_TEST_POSTSYNC  13 /* after syncing the log */
  1764. #define DB_TEST_SUBDB_LOCKS  14 /* subdb locking tests */
  1765. int  test_abort; /* Abort value for testing. */
  1766. int  test_copy; /* Copy value for testing. */
  1768. #define DB_ENV_AUTO_COMMIT 0x0000001 /* DB_AUTO_COMMIT. */
  1769. #define DB_ENV_CDB 0x0000002 /* DB_INIT_CDB. */
  1770. #define DB_ENV_CDB_ALLDB 0x0000004 /* CDB environment wide locking. */
  1771. #define DB_ENV_CREATE 0x0000008 /* DB_CREATE set. */
  1772. #define DB_ENV_DBLOCAL 0x0000010 /* DB_ENV allocated for private DB. */
  1773. #define DB_ENV_DIRECT_DB 0x0000020 /* DB_DIRECT_DB set. */
  1774. #define DB_ENV_DIRECT_LOG 0x0000040 /* DB_DIRECT_LOG set. */
  1775. #define DB_ENV_FATAL 0x0000080 /* Doing fatal recovery in env. */
  1776. #define DB_ENV_LOCKDOWN 0x0000100 /* DB_LOCKDOWN set. */
  1777. #define DB_ENV_NOLOCKING 0x0000200 /* DB_NOLOCKING set. */
  1778. #define DB_ENV_NOMMAP 0x0000400 /* DB_NOMMAP set. */
  1779. #define DB_ENV_NOPANIC 0x0000800 /* Okay if panic set. */
  1780. #define DB_ENV_OPEN_CALLED 0x0001000 /* DB_ENV->open called. */
  1781. #define DB_ENV_OVERWRITE 0x0002000 /* DB_OVERWRITE set. */
  1782. #define DB_ENV_PRIVATE 0x0004000 /* DB_PRIVATE set. */
  1783. #define DB_ENV_REGION_INIT 0x0008000 /* DB_REGION_INIT set. */
  1784. #define DB_ENV_REP_CLIENT 0x0010000 /* Replication client. */
  1785. #define DB_ENV_REP_LOGSONLY 0x0020000 /* Log files only replication site. */
  1786. #define DB_ENV_REP_MASTER 0x0040000 /* Replication master. */
  1787. #define DB_ENV_RPCCLIENT 0x0080000 /* DB_CLIENT set. */
  1788. #define DB_ENV_RPCCLIENT_GIVEN 0x0100000 /* User-supplied RPC client struct */
  1789. #define DB_ENV_SYSTEM_MEM 0x0200000 /* DB_SYSTEM_MEM set. */
  1790. #define DB_ENV_THREAD 0x0400000 /* DB_THREAD set. */
  1791. #define DB_ENV_TXN_NOSYNC 0x0800000 /* DB_TXN_NOSYNC set. */
  1792. #define DB_ENV_TXN_WRITE_NOSYNC 0x1000000 /* DB_TXN_WRITE_NOSYNC set. */
  1793. #define DB_ENV_YIELDCPU 0x2000000 /* DB_YIELDCPU set. */
  1794. u_int32_t flags;
  1795. };
  1797. #ifndef DB_DBM_HSEARCH
  1798. #define DB_DBM_HSEARCH 0 /* No historic interfaces by default. */
  1799. #endif
  1800. #if DB_DBM_HSEARCH != 0
  1801. /*******************************************************
  1802.  * Dbm/Ndbm historic interfaces.
  1803.  *******************************************************/
  1804. typedef struct __db DBM;
  1806. #define DBM_INSERT 0 /* Flags to dbm_store(). */
  1807. #define DBM_REPLACE 1
  1809. /*
  1810.  * The DB support for ndbm(3) always appends this suffix to the
  1811.  * file name to avoid overwriting the user's original database.
  1812.  */
  1813. #define DBM_SUFFIX ".db"
  1815. #if defined(_XPG4_2)
  1816. typedef struct {
  1817. char *dptr;
  1818. size_t dsize;
  1819. } datum;
  1820. #else
  1821. typedef struct {
  1822. char *dptr;
  1823. int dsize;
  1824. } datum;
  1825. #endif
  1827. /*
  1828.  * Translate NDBM calls into DB calls so that DB doesn't step on the
  1829.  * application's name space.
  1830.  */
  1831. #define dbm_clearerr(a) __db_ndbm_clearerr(a)
  1832. #define dbm_close(a) __db_ndbm_close(a)
  1833. #define dbm_delete(a, b) __db_ndbm_delete(a, b)
  1834. #define dbm_dirfno(a) __db_ndbm_dirfno(a)
  1835. #define dbm_error(a) __db_ndbm_error(a)
  1836. #define dbm_fetch(a, b) __db_ndbm_fetch(a, b)
  1837. #define dbm_firstkey(a) __db_ndbm_firstkey(a)
  1838. #define dbm_nextkey(a) __db_ndbm_nextkey(a)
  1839. #define dbm_open(a, b, c) __db_ndbm_open(a, b, c)
  1840. #define dbm_pagfno(a) __db_ndbm_pagfno(a)
  1841. #define dbm_rdonly(a) __db_ndbm_rdonly(a)
  1842. #define dbm_store(a, b, c, d) 
  1843. __db_ndbm_store(a, b, c, d)
  1845. /*
  1846.  * Translate DBM calls into DB calls so that DB doesn't step on the
  1847.  * application's name space.
  1848.  *
  1849.  * The global variables dbrdonly, dirf and pagf were not retained when 4BSD
  1850.  * replaced the dbm interface with ndbm, and are not supported here.
  1851.  */
  1852. #define dbminit(a) __db_dbm_init(a)
  1853. #define dbmclose __db_dbm_close
  1854. #if !defined(__cplusplus)
  1855. #define delete(a) __db_dbm_delete(a)
  1856. #endif
  1857. #define fetch(a) __db_dbm_fetch(a)
  1858. #define firstkey __db_dbm_firstkey
  1859. #define nextkey(a) __db_dbm_nextkey(a)
  1860. #define store(a, b) __db_dbm_store(a, b)
  1862. /*******************************************************
  1863.  * Hsearch historic interface.
  1864.  *******************************************************/
  1865. typedef enum {
  1866. FIND, ENTER
  1867. } ACTION;
  1869. typedef struct entry {
  1870. char *key;
  1871. char *data;
  1872. } ENTRY;
  1874. #define hcreate(a) __db_hcreate(a)
  1875. #define hdestroy __db_hdestroy
  1876. #define hsearch(a, b) __db_hsearch(a, b)
  1878. #endif /* DB_DBM_HSEARCH */
  1880. #if defined(__cplusplus)
  1881. }
  1882. #endif
  1883. #endif /* !_DB_H_ */
  1885. /* DO NOT EDIT: automatically built by dist/s_rpc. */
  1886. #define DB_RPC_SERVERPROG 351457
  1887. #define DB_RPC_SERVERVERS 4001
  1889. /* DO NOT EDIT: automatically built by dist/s_include. */
  1890. #ifndef _DB_EXT_PROT_IN_
  1891. #define _DB_EXT_PROT_IN_
  1893. #if defined(__cplusplus)
  1894. extern "C" {
  1895. #endif
  1897. int db_create __P((DB **, DB_ENV *, u_int32_t));
  1898. char *db_strerror __P((int));
  1899. int db_env_create __P((DB_ENV **, u_int32_t));
  1900. char *db_version __P((int *, int *, int *));
  1901. int log_compare __P((const DB_LSN *, const DB_LSN *));
  1902. int db_env_set_func_close __P((int (*)(int)));
  1903. int db_env_set_func_dirfree __P((void (*)(char **, int)));
  1904. int db_env_set_func_dirlist __P((int (*)(const char *, char ***, int *)));
  1905. int db_env_set_func_exists __P((int (*)(const char *, int *)));
  1906. int db_env_set_func_free __P((void (*)(void *)));
  1907. int db_env_set_func_fsync __P((int (*)(int)));
  1908. int db_env_set_func_ioinfo __P((int (*)(const char *, int, u_int32_t *, u_int32_t *, u_int32_t *)));
  1909. int db_env_set_func_malloc __P((void *(*)(size_t)));
  1910. int db_env_set_func_map __P((int (*)(char *, size_t, int, int, void **)));
  1911. int db_env_set_func_open __P((int (*)(const char *, int, ...)));
  1912. int db_env_set_func_read __P((ssize_t (*)(int, void *, size_t)));
  1913. int db_env_set_func_realloc __P((void *(*)(void *, size_t)));
  1914. int db_env_set_func_rename __P((int (*)(const char *, const char *)));
  1915. int db_env_set_func_seek __P((int (*)(int, size_t, db_pgno_t, u_int32_t, int, int)));
  1916. int db_env_set_func_sleep __P((int (*)(u_long, u_long)));
  1917. int db_env_set_func_unlink __P((int (*)(const char *)));
  1918. int db_env_set_func_unmap __P((int (*)(void *, size_t)));
  1919. int db_env_set_func_write __P((ssize_t (*)(int, const void *, size_t)));
  1920. int db_env_set_func_yield __P((int (*)(void)));
  1921. int txn_abort __P((DB_TXN *));
  1922. int txn_begin __P((DB_ENV *, DB_TXN *, DB_TXN **, u_int32_t));
  1923. int txn_commit __P((DB_TXN *, u_int32_t));
  1924. #if DB_DBM_HSEARCH != 0
  1925. int  __db_ndbm_clearerr __P((DBM *));
  1926. void  __db_ndbm_close __P((DBM *));
  1927. int  __db_ndbm_delete __P((DBM *, datum));
  1928. int  __db_ndbm_dirfno __P((DBM *));
  1929. int  __db_ndbm_error __P((DBM *));
  1930. datum __db_ndbm_fetch __P((DBM *, datum));
  1931. datum __db_ndbm_firstkey __P((DBM *));
  1932. datum __db_ndbm_nextkey __P((DBM *));
  1933. DBM *__db_ndbm_open __P((const char *, int, int));
  1934. int  __db_ndbm_pagfno __P((DBM *));
  1935. int  __db_ndbm_rdonly __P((DBM *));
  1936. int  __db_ndbm_store __P((DBM *, datum, datum, int));
  1937. int  __db_dbm_close __P((void));
  1938. int  __db_dbm_dbrdonly __P((void));
  1939. int  __db_dbm_delete __P((datum));
  1940. int  __db_dbm_dirf __P((void));
  1941. datum __db_dbm_fetch __P((datum));
  1942. datum __db_dbm_firstkey __P((void));
  1943. int  __db_dbm_init __P((char *));
  1944. datum __db_dbm_nextkey __P((datum));
  1945. int  __db_dbm_pagf __P((void));
  1946. int  __db_dbm_store __P((datum, datum));
  1947. #endif
  1948. #if DB_DBM_HSEARCH != 0
  1949. int __db_hcreate __P((size_t));
  1950. ENTRY *__db_hsearch __P((ENTRY, ACTION));
  1951. void __db_hdestroy __P((void));
  1952. #endif
  1954. #if defined(__cplusplus)
  1955. }
  1956. #endif
  1957. #endif /* !_DB_EXT_PROT_IN_ */