diff options
author | unknown <ram@mysql.r18.ru> | 2002-10-30 15:57:05 +0400 |
---|---|---|
committer | unknown <ram@mysql.r18.ru> | 2002-10-30 15:57:05 +0400 |
commit | 155e78f014de1a2e259ae5119f4621fbb210a784 (patch) | |
tree | 6881a3cca88bea0bb9eeffd5aae34be437152786 /bdb/common | |
parent | b8798d25ab71436bf690ee8ae48285a655c5487e (diff) | |
download | mariadb-git-155e78f014de1a2e259ae5119f4621fbb210a784.tar.gz |
BDB 4.1.24
BitKeeper/deleted/.del-ex_access.wpj~3df6ae8c99bf7c5f:
Delete: bdb/build_vxworks/ex_access/ex_access.wpj
BitKeeper/deleted/.del-ex_btrec.wpj~a7622f1c6f432dc6:
Delete: bdb/build_vxworks/ex_btrec/ex_btrec.wpj
BitKeeper/deleted/.del-ex_dbclient.wpj~7345440f3b204cdd:
Delete: bdb/build_vxworks/ex_dbclient/ex_dbclient.wpj
BitKeeper/deleted/.del-ex_env.wpj~fbe1ab10b04e8b74:
Delete: bdb/build_vxworks/ex_env/ex_env.wpj
BitKeeper/deleted/.del-ex_mpool.wpj~4479cfd5c45f327d:
Delete: bdb/build_vxworks/ex_mpool/ex_mpool.wpj
BitKeeper/deleted/.del-ex_tpcb.wpj~f78093006e14bf41:
Delete: bdb/build_vxworks/ex_tpcb/ex_tpcb.wpj
BitKeeper/deleted/.del-db_buildall.dsp~bd749ff6da11682:
Delete: bdb/build_win32/db_buildall.dsp
BitKeeper/deleted/.del-cxx_app.cpp~ad8df8e0791011ed:
Delete: bdb/cxx/cxx_app.cpp
BitKeeper/deleted/.del-cxx_log.cpp~a50ff3118fe06952:
Delete: bdb/cxx/cxx_log.cpp
BitKeeper/deleted/.del-cxx_table.cpp~ecd751e79b055556:
Delete: bdb/cxx/cxx_table.cpp
BitKeeper/deleted/.del-namemap.txt~796a3acd3885d8fd:
Delete: bdb/cxx/namemap.txt
BitKeeper/deleted/.del-Design.fileop~3ca4da68f1727373:
Delete: bdb/db/Design.fileop
BitKeeper/deleted/.del-db185_int.h~61bee3736e7959ef:
Delete: bdb/db185/db185_int.h
BitKeeper/deleted/.del-acconfig.h~411e8854d67ad8b5:
Delete: bdb/dist/acconfig.h
BitKeeper/deleted/.del-mutex.m4~a13383cde18a64e1:
Delete: bdb/dist/aclocal/mutex.m4
BitKeeper/deleted/.del-options.m4~b9d0ca637213750a:
Delete: bdb/dist/aclocal/options.m4
BitKeeper/deleted/.del-programs.m4~3ce7890b47732b30:
Delete: bdb/dist/aclocal/programs.m4
BitKeeper/deleted/.del-tcl.m4~f944e2db93c3b6db:
Delete: bdb/dist/aclocal/tcl.m4
BitKeeper/deleted/.del-types.m4~59cae158c9a32cff:
Delete: bdb/dist/aclocal/types.m4
BitKeeper/deleted/.del-script~d38f6d3a4f159cb4:
Delete: bdb/dist/build/script
BitKeeper/deleted/.del-configure.in~ac795a92c8fe049c:
Delete: bdb/dist/configure.in
BitKeeper/deleted/.del-ltconfig~66bbd007d8024af:
Delete: bdb/dist/ltconfig
BitKeeper/deleted/.del-rec_ctemp~a28554362534f00a:
Delete: bdb/dist/rec_ctemp
BitKeeper/deleted/.del-s_tcl~2ffe4326459fcd9f:
Delete: bdb/dist/s_tcl
BitKeeper/deleted/.del-.IGNORE_ME~d8148b08fa7d5d15:
Delete: bdb/dist/template/.IGNORE_ME
BitKeeper/deleted/.del-btree.h~179f2aefec1753d:
Delete: bdb/include/btree.h
BitKeeper/deleted/.del-cxx_int.h~6b649c04766508f8:
Delete: bdb/include/cxx_int.h
BitKeeper/deleted/.del-db.src~6b433ae615b16a8d:
Delete: bdb/include/db.src
BitKeeper/deleted/.del-db_185.h~ad8b373d9391d35c:
Delete: bdb/include/db_185.h
BitKeeper/deleted/.del-db_am.h~a714912b6b75932f:
Delete: bdb/include/db_am.h
BitKeeper/deleted/.del-db_cxx.h~fcafadf45f5d19e9:
Delete: bdb/include/db_cxx.h
BitKeeper/deleted/.del-db_dispatch.h~6844f20f7eb46904:
Delete: bdb/include/db_dispatch.h
BitKeeper/deleted/.del-db_int.src~419a3f48b6a01da7:
Delete: bdb/include/db_int.src
BitKeeper/deleted/.del-db_join.h~76f9747a42c3399a:
Delete: bdb/include/db_join.h
BitKeeper/deleted/.del-db_page.h~e302ca3a4db3abdc:
Delete: bdb/include/db_page.h
BitKeeper/deleted/.del-db_server_int.h~e1d20b6ba3bca1ab:
Delete: bdb/include/db_server_int.h
BitKeeper/deleted/.del-db_shash.h~5fbf2d696fac90f3:
Delete: bdb/include/db_shash.h
BitKeeper/deleted/.del-db_swap.h~1e60887550864a59:
Delete: bdb/include/db_swap.h
BitKeeper/deleted/.del-db_upgrade.h~c644eee73701fc8d:
Delete: bdb/include/db_upgrade.h
BitKeeper/deleted/.del-db_verify.h~b8d6c297c61f342e:
Delete: bdb/include/db_verify.h
BitKeeper/deleted/.del-debug.h~dc2b4f2cf27ccebc:
Delete: bdb/include/debug.h
BitKeeper/deleted/.del-hash.h~2aaa548b28882dfb:
Delete: bdb/include/hash.h
BitKeeper/deleted/.del-lock.h~a761c1b7de57b77f:
Delete: bdb/include/lock.h
BitKeeper/deleted/.del-log.h~ff20184238e35e4d:
Delete: bdb/include/log.h
BitKeeper/deleted/.del-mp.h~7e317597622f3411:
Delete: bdb/include/mp.h
BitKeeper/deleted/.del-mutex.h~d3ae7a2977a68137:
Delete: bdb/include/mutex.h
BitKeeper/deleted/.del-os.h~91867cc8757cd0e3:
Delete: bdb/include/os.h
BitKeeper/deleted/.del-os_jump.h~e1b939fa5151d4be:
Delete: bdb/include/os_jump.h
BitKeeper/deleted/.del-qam.h~6fad0c1b5723d597:
Delete: bdb/include/qam.h
BitKeeper/deleted/.del-queue.h~4c72c0826c123d5:
Delete: bdb/include/queue.h
BitKeeper/deleted/.del-region.h~513fe04d977ca0fc:
Delete: bdb/include/region.h
BitKeeper/deleted/.del-shqueue.h~525fc3e6c2025c36:
Delete: bdb/include/shqueue.h
BitKeeper/deleted/.del-tcl_db.h~c536fd61a844f23f:
Delete: bdb/include/tcl_db.h
BitKeeper/deleted/.del-txn.h~c8d94b221ec147e4:
Delete: bdb/include/txn.h
BitKeeper/deleted/.del-xa.h~ecc466493aae9d9a:
Delete: bdb/include/xa.h
BitKeeper/deleted/.del-DbRecoveryInit.java~756b52601a0b9023:
Delete: bdb/java/src/com/sleepycat/db/DbRecoveryInit.java
BitKeeper/deleted/.del-DbTxnRecover.java~74607cba7ab89d6d:
Delete: bdb/java/src/com/sleepycat/db/DbTxnRecover.java
BitKeeper/deleted/.del-lock_conflict.c~fc5e0f14cf597a2b:
Delete: bdb/lock/lock_conflict.c
BitKeeper/deleted/.del-log.src~53ac9e7b5cb023f2:
Delete: bdb/log/log.src
BitKeeper/deleted/.del-log_findckp.c~24287f008916e81f:
Delete: bdb/log/log_findckp.c
BitKeeper/deleted/.del-log_rec.c~d51711f2cac09297:
Delete: bdb/log/log_rec.c
BitKeeper/deleted/.del-log_register.c~b40bb4efac75ca15:
Delete: bdb/log/log_register.c
BitKeeper/deleted/.del-Design~b3d0f179f2767b:
Delete: bdb/mp/Design
BitKeeper/deleted/.del-os_finit.c~95dbefc6fe79b26c:
Delete: bdb/os/os_finit.c
BitKeeper/deleted/.del-os_abs.c~df95d1e7db81924:
Delete: bdb/os_vxworks/os_abs.c
BitKeeper/deleted/.del-os_finit.c~803b484bdb9d0122:
Delete: bdb/os_vxworks/os_finit.c
BitKeeper/deleted/.del-os_map.c~3a6d7926398b76d3:
Delete: bdb/os_vxworks/os_map.c
BitKeeper/deleted/.del-os_finit.c~19a227c6d3c78ad:
Delete: bdb/os_win32/os_finit.c
BitKeeper/deleted/.del-log-corruption.patch~1cf2ecc7c6408d5d:
Delete: bdb/patches/log-corruption.patch
BitKeeper/deleted/.del-Btree.pm~af6d0c5eaed4a98e:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB/Btree.pm
BitKeeper/deleted/.del-BerkeleyDB.pm~7244036d4482643:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB.pm
BitKeeper/deleted/.del-BerkeleyDB.pod~e7b18fd6132448e3:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB.pod
BitKeeper/deleted/.del-Hash.pm~10292a26c06a5c95:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB/Hash.pm
BitKeeper/deleted/.del-BerkeleyDB.pod.P~79f76a1495eda203:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB.pod.P
BitKeeper/deleted/.del-BerkeleyDB.xs~80c99afbd98e392c:
Delete: bdb/perl.BerkeleyDB/BerkeleyDB.xs
BitKeeper/deleted/.del-Changes~729c1891efa60de9:
Delete: bdb/perl.BerkeleyDB/Changes
BitKeeper/deleted/.del-MANIFEST~63a1e34aecf157a0:
Delete: bdb/perl.BerkeleyDB/MANIFEST
BitKeeper/deleted/.del-Makefile.PL~c68797707d8df87a:
Delete: bdb/perl.BerkeleyDB/Makefile.PL
BitKeeper/deleted/.del-README~5f2f579b1a241407:
Delete: bdb/perl.BerkeleyDB/README
BitKeeper/deleted/.del-Todo~dca3c66c193adda9:
Delete: bdb/perl.BerkeleyDB/Todo
BitKeeper/deleted/.del-config.in~ae81681e450e0999:
Delete: bdb/perl.BerkeleyDB/config.in
BitKeeper/deleted/.del-dbinfo~28ad67d83be4f68e:
Delete: bdb/perl.BerkeleyDB/dbinfo
BitKeeper/deleted/.del-mkconsts~543ab60669c7a04e:
Delete: bdb/perl.BerkeleyDB/mkconsts
BitKeeper/deleted/.del-mkpod~182c0ca54e439afb:
Delete: bdb/perl.BerkeleyDB/mkpod
BitKeeper/deleted/.del-5.004~e008cb5a48805543:
Delete: bdb/perl.BerkeleyDB/patches/5.004
BitKeeper/deleted/.del-irix_6_5.pl~61662bb08afcdec8:
Delete: bdb/perl.BerkeleyDB/hints/irix_6_5.pl
BitKeeper/deleted/.del-solaris.pl~6771e7182394e152:
Delete: bdb/perl.BerkeleyDB/hints/solaris.pl
BitKeeper/deleted/.del-typemap~783b8f5295b05f3d:
Delete: bdb/perl.BerkeleyDB/typemap
BitKeeper/deleted/.del-5.004_01~6081ce2fff7b0bc:
Delete: bdb/perl.BerkeleyDB/patches/5.004_01
BitKeeper/deleted/.del-5.004_02~87214eac35ad9e6:
Delete: bdb/perl.BerkeleyDB/patches/5.004_02
BitKeeper/deleted/.del-5.004_03~9a672becec7cb40f:
Delete: bdb/perl.BerkeleyDB/patches/5.004_03
BitKeeper/deleted/.del-5.004_04~e326cb51af09d154:
Delete: bdb/perl.BerkeleyDB/patches/5.004_04
BitKeeper/deleted/.del-5.004_05~7ab457a1e41a92fe:
Delete: bdb/perl.BerkeleyDB/patches/5.004_05
BitKeeper/deleted/.del-5.005~f9e2d59b5964cd4b:
Delete: bdb/perl.BerkeleyDB/patches/5.005
BitKeeper/deleted/.del-5.005_01~3eb9fb7b5842ea8e:
Delete: bdb/perl.BerkeleyDB/patches/5.005_01
BitKeeper/deleted/.del-5.005_02~67477ce0bef717cb:
Delete: bdb/perl.BerkeleyDB/patches/5.005_02
BitKeeper/deleted/.del-5.005_03~c4c29a1fb21e290a:
Delete: bdb/perl.BerkeleyDB/patches/5.005_03
BitKeeper/deleted/.del-5.6.0~e1fb9897d124ee22:
Delete: bdb/perl.BerkeleyDB/patches/5.6.0
BitKeeper/deleted/.del-btree.t~e4a1a3c675ddc406:
Delete: bdb/perl.BerkeleyDB/t/btree.t
BitKeeper/deleted/.del-db-3.0.t~d2c60991d84558f2:
Delete: bdb/perl.BerkeleyDB/t/db-3.0.t
BitKeeper/deleted/.del-db-3.1.t~6ee88cd13f55e018:
Delete: bdb/perl.BerkeleyDB/t/db-3.1.t
BitKeeper/deleted/.del-db-3.2.t~f73b6461f98fd1cf:
Delete: bdb/perl.BerkeleyDB/t/db-3.2.t
BitKeeper/deleted/.del-destroy.t~cc6a2ae1980a2ecd:
Delete: bdb/perl.BerkeleyDB/t/destroy.t
BitKeeper/deleted/.del-env.t~a8604a4499c4bd07:
Delete: bdb/perl.BerkeleyDB/t/env.t
BitKeeper/deleted/.del-examples.t~2571b77c3cc75574:
Delete: bdb/perl.BerkeleyDB/t/examples.t
BitKeeper/deleted/.del-examples.t.T~8228bdd75ac78b88:
Delete: bdb/perl.BerkeleyDB/t/examples.t.T
BitKeeper/deleted/.del-examples3.t.T~66a186897a87026d:
Delete: bdb/perl.BerkeleyDB/t/examples3.t.T
BitKeeper/deleted/.del-examples3.t~fe3822ba2f2d7f83:
Delete: bdb/perl.BerkeleyDB/t/examples3.t
BitKeeper/deleted/.del-filter.t~f87b045c1b708637:
Delete: bdb/perl.BerkeleyDB/t/filter.t
BitKeeper/deleted/.del-hash.t~616bfb4d644de3a3:
Delete: bdb/perl.BerkeleyDB/t/hash.t
BitKeeper/deleted/.del-join.t~29fc39f74a83ca22:
Delete: bdb/perl.BerkeleyDB/t/join.t
BitKeeper/deleted/.del-mldbm.t~31f5015341eea040:
Delete: bdb/perl.BerkeleyDB/t/mldbm.t
BitKeeper/deleted/.del-queue.t~8f338034ce44a641:
Delete: bdb/perl.BerkeleyDB/t/queue.t
BitKeeper/deleted/.del-recno.t~d4ddbd3743add63e:
Delete: bdb/perl.BerkeleyDB/t/recno.t
BitKeeper/deleted/.del-strict.t~6885cdd2ea71ca2d:
Delete: bdb/perl.BerkeleyDB/t/strict.t
BitKeeper/deleted/.del-subdb.t~aab62a5d5864c603:
Delete: bdb/perl.BerkeleyDB/t/subdb.t
BitKeeper/deleted/.del-txn.t~65033b8558ae1216:
Delete: bdb/perl.BerkeleyDB/t/txn.t
BitKeeper/deleted/.del-unknown.t~f3710458682665e1:
Delete: bdb/perl.BerkeleyDB/t/unknown.t
BitKeeper/deleted/.del-Changes~436f74a5c414c65b:
Delete: bdb/perl.DB_File/Changes
BitKeeper/deleted/.del-DB_File.pm~ae0951c6c7665a82:
Delete: bdb/perl.DB_File/DB_File.pm
BitKeeper/deleted/.del-DB_File.xs~89e49a0b5556f1d8:
Delete: bdb/perl.DB_File/DB_File.xs
BitKeeper/deleted/.del-DB_File_BS~290fad5dbbb87069:
Delete: bdb/perl.DB_File/DB_File_BS
BitKeeper/deleted/.del-MANIFEST~90ee581572bdd4ac:
Delete: bdb/perl.DB_File/MANIFEST
BitKeeper/deleted/.del-Makefile.PL~ac0567bb5a377e38:
Delete: bdb/perl.DB_File/Makefile.PL
BitKeeper/deleted/.del-README~77e924a5a9bae6b3:
Delete: bdb/perl.DB_File/README
BitKeeper/deleted/.del-config.in~ab4c2792b86a810b:
Delete: bdb/perl.DB_File/config.in
BitKeeper/deleted/.del-dbinfo~461c43b30fab2cb:
Delete: bdb/perl.DB_File/dbinfo
BitKeeper/deleted/.del-dynixptx.pl~50dcddfae25d17e9:
Delete: bdb/perl.DB_File/hints/dynixptx.pl
BitKeeper/deleted/.del-typemap~55cffb3288a9e587:
Delete: bdb/perl.DB_File/typemap
BitKeeper/deleted/.del-version.c~a4df0e646f8b3975:
Delete: bdb/perl.DB_File/version.c
BitKeeper/deleted/.del-5.004_01~d6830d0082702af7:
Delete: bdb/perl.DB_File/patches/5.004_01
BitKeeper/deleted/.del-5.004_02~78b082dc80c91031:
Delete: bdb/perl.DB_File/patches/5.004_02
BitKeeper/deleted/.del-5.004~4411ec2e3c9e008b:
Delete: bdb/perl.DB_File/patches/5.004
BitKeeper/deleted/.del-sco.pl~1e795fe14fe4dcfe:
Delete: bdb/perl.DB_File/hints/sco.pl
BitKeeper/deleted/.del-5.004_03~33f274648b160d95:
Delete: bdb/perl.DB_File/patches/5.004_03
BitKeeper/deleted/.del-5.004_04~8f3d1b3cf18bb20a:
Delete: bdb/perl.DB_File/patches/5.004_04
BitKeeper/deleted/.del-5.004_05~9c0f02e7331e142:
Delete: bdb/perl.DB_File/patches/5.004_05
BitKeeper/deleted/.del-5.005~c2108cb2e3c8d951:
Delete: bdb/perl.DB_File/patches/5.005
BitKeeper/deleted/.del-5.005_01~3b45e9673afc4cfa:
Delete: bdb/perl.DB_File/patches/5.005_01
BitKeeper/deleted/.del-5.005_02~9fe5766bb02a4522:
Delete: bdb/perl.DB_File/patches/5.005_02
BitKeeper/deleted/.del-5.005_03~ffa1c38c19ae72ea:
Delete: bdb/perl.DB_File/patches/5.005_03
BitKeeper/deleted/.del-5.6.0~373be3a5ce47be85:
Delete: bdb/perl.DB_File/patches/5.6.0
BitKeeper/deleted/.del-db-btree.t~3231595a1c241eb3:
Delete: bdb/perl.DB_File/t/db-btree.t
BitKeeper/deleted/.del-db-hash.t~7c4ad0c795c7fad2:
Delete: bdb/perl.DB_File/t/db-hash.t
BitKeeper/deleted/.del-db-recno.t~6c2d3d80b9ba4a50:
Delete: bdb/perl.DB_File/t/db-recno.t
BitKeeper/deleted/.del-db_server.sed~cdb00ebcd48a64e2:
Delete: bdb/rpc_server/db_server.sed
BitKeeper/deleted/.del-db_server_proc.c~d46c8f409c3747f4:
Delete: bdb/rpc_server/db_server_proc.c
BitKeeper/deleted/.del-db_server_svc.sed~3f5e59f334fa4607:
Delete: bdb/rpc_server/db_server_svc.sed
BitKeeper/deleted/.del-db_server_util.c~a809f3a4629acda:
Delete: bdb/rpc_server/db_server_util.c
BitKeeper/deleted/.del-log.tcl~ff1b41f1355b97d7:
Delete: bdb/test/log.tcl
BitKeeper/deleted/.del-mpool.tcl~b0df4dc1b04db26c:
Delete: bdb/test/mpool.tcl
BitKeeper/deleted/.del-mutex.tcl~52fd5c73a150565:
Delete: bdb/test/mutex.tcl
BitKeeper/deleted/.del-txn.tcl~c4ff071550b5446e:
Delete: bdb/test/txn.tcl
BitKeeper/deleted/.del-README~e800a12a5392010a:
Delete: bdb/test/upgrade/README
BitKeeper/deleted/.del-pack-2.6.6.pl~89d5076d758d3e98:
Delete: bdb/test/upgrade/generate-2.X/pack-2.6.6.pl
BitKeeper/deleted/.del-test-2.6.patch~4a52dc83d447547b:
Delete: bdb/test/upgrade/generate-2.X/test-2.6.patch
Diffstat (limited to 'bdb/common')
-rw-r--r-- | bdb/common/db_byteorder.c | 50 | ||||
-rw-r--r-- | bdb/common/db_err.c | 359 | ||||
-rw-r--r-- | bdb/common/db_getlong.c | 73 | ||||
-rw-r--r-- | bdb/common/db_idspace.c | 93 | ||||
-rw-r--r-- | bdb/common/db_log2.c | 5 | ||||
-rw-r--r-- | bdb/common/util_arg.c | 126 | ||||
-rw-r--r-- | bdb/common/util_cache.c | 92 | ||||
-rw-r--r-- | bdb/common/util_log.c | 9 | ||||
-rw-r--r-- | bdb/common/util_sig.c | 7 |
9 files changed, 583 insertions, 231 deletions
diff --git a/bdb/common/db_byteorder.c b/bdb/common/db_byteorder.c index d089cfe4c99..d42d8e6a958 100644 --- a/bdb/common/db_byteorder.c +++ b/bdb/common/db_byteorder.c @@ -1,30 +1,42 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 1996, 1997, 1998, 1999, 2000 + * Copyright (c) 1996-2002 * Sleepycat Software. All rights reserved. */ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: db_byteorder.c,v 11.4 2000/11/30 00:58:31 ubell Exp $"; +static const char revid[] = "$Id: db_byteorder.c,v 11.8 2002/02/01 18:15:29 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES #include <sys/types.h> - -#ifdef HAVE_ENDIAN_H -#include <endian.h> -#if BYTE_ORDER == BIG_ENDIAN -#define WORDS_BIGENDIAN 1 -#endif -#endif - #endif #include "db_int.h" -#include "common_ext.h" + +/* + * __db_isbigendian -- + * Return 1 if big-endian (Motorola and Sparc), not little-endian + * (Intel and Vax). We do this work at run-time, rather than at + * configuration time so cross-compilation and general embedded + * system support is simpler. + * + * PUBLIC: int __db_isbigendian __P((void)); + */ +int +__db_isbigendian() +{ + union { /* From Harbison & Steele. */ + long l; + char c[sizeof(long)]; + } u; + + u.l = 1; + return (u.c[sizeof(long) - 1] == 1); +} /* * __db_byteorder -- @@ -38,21 +50,21 @@ __db_byteorder(dbenv, lorder) DB_ENV *dbenv; int lorder; { + int is_bigendian; + + is_bigendian = __db_isbigendian(); + switch (lorder) { case 0: break; case 1234: -#if defined(WORDS_BIGENDIAN) - return (DB_SWAPBYTES); -#else + if (is_bigendian) + return (DB_SWAPBYTES); break; -#endif case 4321: -#if defined(WORDS_BIGENDIAN) + if (!is_bigendian) + return (DB_SWAPBYTES); break; -#else - return (DB_SWAPBYTES); -#endif default: __db_err(dbenv, "unsupported byte order, only big and little-endian supported"); diff --git a/bdb/common/db_err.c b/bdb/common/db_err.c index d69bd023dfd..7c9ee3c4fde 100644 --- a/bdb/common/db_err.c +++ b/bdb/common/db_err.c @@ -1,14 +1,14 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 1996, 1997, 1998, 1999, 2000 + * Copyright (c) 1996-2002 * Sleepycat Software. All rights reserved. */ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: db_err.c,v 11.38 2001/01/22 21:50:25 sue Exp $"; +static const char revid[] = "$Id: db_err.c,v 11.80 2002/07/30 01:21:53 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES @@ -20,21 +20,12 @@ static const char revid[] = "$Id: db_err.c,v 11.38 2001/01/22 21:50:25 sue Exp $ #endif #include "db_int.h" -#include "db_shash.h" -#include "lock.h" -#include "lock_ext.h" -#include "log.h" -#include "log_ext.h" -#include "mp.h" -#include "mp_ext.h" -#include "txn.h" -#include "txn_ext.h" -#include "clib_ext.h" -#include "common_ext.h" -#include "db_auto.h" - -static void __db_errcall __P((const DB_ENV *, int, int, const char *, va_list)); -static void __db_errfile __P((const DB_ENV *, int, int, const char *, va_list)); +#include "dbinc/db_page.h" +#include "dbinc/db_am.h" +#include "dbinc/db_shash.h" +#include "dbinc/lock.h" +#include "dbinc/log.h" +#include "dbinc/txn.h" /* * __db_fchk -- @@ -89,12 +80,13 @@ __db_ferr(dbenv, name, iscombo) * __db_pgerr -- * Error when unable to retrieve a specified page. * - * PUBLIC: int __db_pgerr __P((DB *, db_pgno_t)); + * PUBLIC: void __db_pgerr __P((DB *, db_pgno_t, int)); */ -int -__db_pgerr(dbp, pgno) +void +__db_pgerr(dbp, pgno, errval) DB *dbp; db_pgno_t pgno; + int errval; { /* * Three things are certain: @@ -103,23 +95,22 @@ __db_pgerr(dbp, pgno) */ __db_err(dbp->dbenv, "unable to create/retrieve page %lu", (u_long)pgno); - return (__db_panic(dbp->dbenv, EIO)); + (void)__db_panic(dbp->dbenv, errval); } /* * __db_pgfmt -- * Error when a page has the wrong format. * - * PUBLIC: int __db_pgfmt __P((DB *, db_pgno_t)); + * PUBLIC: int __db_pgfmt __P((DB_ENV *, db_pgno_t)); */ int -__db_pgfmt(dbp, pgno) - DB *dbp; +__db_pgfmt(dbenv, pgno) + DB_ENV *dbenv; db_pgno_t pgno; { - __db_err(dbp->dbenv, - "page %lu: illegal page type or format", (u_long)pgno); - return (__db_panic(dbp->dbenv, EINVAL)); + __db_err(dbenv, "page %lu: illegal page type or format", (u_long)pgno); + return (__db_panic(dbenv, EINVAL)); } /* @@ -157,7 +148,7 @@ __db_assert(failedexpr, file, line) (void)fprintf(stderr, "__db_assert: \"%s\" failed: file \"%s\", line %d\n", failedexpr, file, line); - fflush(stderr); + (void)fflush(stderr); /* We want a stack trace of how this could possibly happen. */ abort(); @@ -176,7 +167,7 @@ int __db_panic_msg(dbenv) DB_ENV *dbenv; { - __db_err(dbenv, "region error detected; run recovery."); + __db_err(dbenv, "fatal region error detected; run recovery"); return (DB_RUNRECOVERY); } @@ -191,11 +182,10 @@ __db_panic(dbenv, errval) DB_ENV *dbenv; int errval; { - if (dbenv != NULL) { - ((REGENV *)((REGINFO *)dbenv->reginfo)->primary)->panic = 1; + PANIC_SET(dbenv, 1); - dbenv->db_panic = errval; + dbenv->panic_errval = errval; __db_err(dbenv, "PANIC: %s", db_strerror(errval)); @@ -203,6 +193,17 @@ __db_panic(dbenv, errval) dbenv->db_paniccall(dbenv, errval); } +#if defined(DIAGNOSTIC) && !defined(CONFIG_TEST) + /* + * We want a stack trace of how this could possibly happen. + * + * Don't drop core if it's the test suite -- it's reasonable for the + * test suite to check to make sure that DB_RUNRECOVERY is returned + * under certain conditions. + */ + abort(); +#endif + /* * Chaos reigns within. * Reflect, repent, and reboot. @@ -214,6 +215,8 @@ __db_panic(dbenv, errval) /* * db_strerror -- * ANSI C strerror(3) for DB. + * + * EXTERN: char *db_strerror __P((int)); */ char * db_strerror(error) @@ -232,8 +235,8 @@ db_strerror(error) * altered. */ switch (error) { - case DB_INCOMPLETE: - return ("DB_INCOMPLETE: Cache flush was unable to complete"); + case DB_DONOTINDEX: + return ("DB_DONOTINDEX: Secondary index callback returns null"); case DB_KEYEMPTY: return ("DB_KEYEMPTY: Non-existent key/data pair"); case DB_KEYEXIST: @@ -253,8 +256,26 @@ db_strerror(error) return ("DB_NOTFOUND: No matching key/data pair found"); case DB_OLD_VERSION: return ("DB_OLDVERSION: Database requires a version upgrade"); + case DB_PAGE_NOTFOUND: + return ("DB_PAGE_NOTFOUND: Requested page not found"); + case DB_REP_DUPMASTER: + return ("DB_REP_DUPMASTER: A second master site appeared"); + case DB_REP_HOLDELECTION: + return ("DB_REP_HOLDELECTION: Need to hold an election"); + case DB_REP_NEWMASTER: + return ("DB_REP_NEWMASTER: A new master has declared itself"); + case DB_REP_NEWSITE: + return ("DB_REP_NEWSITE: A new site has entered the system"); + case DB_REP_OUTDATED: + return + ("DB_REP_OUTDATED: Insufficient logs on master to recover"); + case DB_REP_UNAVAIL: + return ("DB_REP_UNAVAIL: Unable to elect a master"); case DB_RUNRECOVERY: return ("DB_RUNRECOVERY: Fatal error, run database recovery"); + case DB_SECONDARY_BAD: + return + ("DB_SECONDARY_BAD: Secondary index item missing from primary"); case DB_VERIFY_BAD: return ("DB_VERIFY_BAD: Database verification failed"); default: { @@ -274,8 +295,8 @@ db_strerror(error) /* * __db_err -- - * Standard DB error routine. The same as db_errx, except that we - * don't write to stderr if no output mechanism was specified. + * Standard DB error routine. The same as errx, except we don't write + * to stderr if no output mechanism was specified. * * PUBLIC: void __db_err __P((const DB_ENV *, const char *, ...)); */ @@ -289,81 +310,17 @@ __db_err(dbenv, fmt, va_alist) va_dcl #endif { - va_list ap; - -/* - XXX - Log the message. - - It would be nice to automatically log the error into the log files - if the application is configured for logging. The problem is that - if we currently hold the log region mutex, we will self-deadlock. - Leave all the structure in place, but turned off. I'd like to fix - this in the future by detecting if we have the log region already - locked (e.g., a flag in the environment handle), or perhaps even - have a finer granularity so that the only calls to __db_err we - can't log are those made while we have the current log buffer - locked, or perhaps have a separate buffer into which we log error - messages. - -#ifdef __STDC__ - va_start(ap, fmt); -#else - va_start(ap); -#endif - __db_real_log(dbenv, NULL, "db_err", 0, fmt, ap); - - va_end(ap); -#endif -*/ - - /* Tell the application. */ -#ifdef __STDC__ - va_start(ap, fmt); -#else - va_start(ap); -#endif - __db_real_err(dbenv, 0, 0, 0, fmt, ap); - - va_end(ap); -} - -/* - * __db_real_err -- - * All the DB error routines end up here. - * - * PUBLIC: void __db_real_err - * PUBLIC: __P((const DB_ENV *, int, int, int, const char *, va_list)); - */ -void -__db_real_err(dbenv, error, error_set, stderr_default, fmt, ap) - const DB_ENV *dbenv; - int error, error_set, stderr_default; - const char *fmt; - va_list ap; -{ - /* Call the user's callback function, if specified. */ - if (dbenv != NULL && dbenv->db_errcall != NULL) - __db_errcall(dbenv, error, error_set, fmt, ap); - - /* Write to the user's file descriptor, if specified. */ - if (dbenv != NULL && dbenv->db_errfile != NULL) - __db_errfile(dbenv, error, error_set, fmt, ap); - - /* - * If we have a default and we didn't do either of the above, write - * to the default. - */ - if (stderr_default && (dbenv == NULL || - (dbenv->db_errcall == NULL && dbenv->db_errfile == NULL))) - __db_errfile(dbenv, error, error_set, fmt, ap); + DB_REAL_ERR(dbenv, 0, 0, 0, fmt); } /* * __db_errcall -- * Do the error message work for callback functions. + * + * PUBLIC: void __db_errcall + * PUBLIC: __P((const DB_ENV *, int, int, const char *, va_list)); */ -static void +void __db_errcall(dbenv, error, error_set, fmt, ap) const DB_ENV *dbenv; int error, error_set; @@ -371,27 +328,44 @@ __db_errcall(dbenv, error, error_set, fmt, ap) va_list ap; { char *p; - char __errbuf[2048]; /* !!!: END OF THE STACK DON'T TRUST SPRINTF. */ + char errbuf[2048]; /* !!!: END OF THE STACK DON'T TRUST SPRINTF. */ - p = __errbuf; - if (fmt != NULL) { - p += vsnprintf(__errbuf, sizeof(__errbuf), fmt, ap); - if (error_set) { - *p++ = ':'; - *p++ = ' '; - } - } + p = errbuf; + if (fmt != NULL) + p += vsnprintf(errbuf, sizeof(errbuf), fmt, ap); if (error_set) - (void)strcpy(p, db_strerror(error)); + p += snprintf(p, + sizeof(errbuf) - (p - errbuf), ": %s", db_strerror(error)); + /* + * !!! + * We're potentially manipulating strings handed us by the application, + * and on systems without a real snprintf() the sprintf() calls could + * have overflowed the buffer. We can't do anything about it now, but + * we don't want to return control to the application, we might have + * overwritten the stack with a Trojan horse. We're not trying to do + * anything recoverable here because systems without snprintf support + * are pretty rare anymore. + */ + if ((size_t)(p - errbuf) > sizeof(errbuf)) { + (void)fprintf(stderr, + "Berkeley DB: error callback interface buffer overflow\n"); + (void)fflush(stderr); + + abort(); + /* NOTREACHED */ + } - dbenv->db_errcall(dbenv->db_errpfx, __errbuf); + dbenv->db_errcall(dbenv->db_errpfx, errbuf); } /* * __db_errfile -- * Do the error message work for FILE *s. + * + * PUBLIC: void __db_errfile + * PUBLIC: __P((const DB_ENV *, int, int, const char *, va_list)); */ -static void +void __db_errfile(dbenv, error, error_set, fmt, ap) const DB_ENV *dbenv; int error, error_set; @@ -436,48 +410,22 @@ __db_logmsg(dbenv, txnid, opname, flags, fmt, va_alist) va_dcl #endif { - va_list ap; - -#ifdef __STDC__ - va_start(ap, fmt); -#else - va_start(ap); -#endif - __db_real_log(dbenv, txnid, opname, flags, fmt, ap); - - va_end(ap); -} - -/* - * __db_real_log -- - * Write information into the DB log. - * - * PUBLIC: void __db_real_log __P((const DB_ENV *, - * PUBLIC: DB_TXN *, const char *, u_int32_t, const char *, va_list ap)); - */ -void -#ifdef __STDC__ -__db_real_log(const DB_ENV *dbenv, DB_TXN *txnid, - const char *opname, u_int32_t flags, const char *fmt, va_list ap) -#else -__db_real_log(dbenv, txnid, opname, flags, fmt, ap) - const DB_ENV *dbenv; - DB_TXN *txnid; - const char *opname, *fmt; - u_int32_t flags; - va_list ap; -#endif -{ DBT opdbt, msgdbt; DB_LSN lsn; + va_list ap; char __logbuf[2048]; /* !!!: END OF THE STACK DON'T TRUST SPRINTF. */ if (!LOGGING_ON(dbenv)) return; +#ifdef __STDC__ + va_start(ap, fmt); +#else + va_start(ap); +#endif memset(&opdbt, 0, sizeof(opdbt)); opdbt.data = (void *)opname; - opdbt.size = strlen(opname) + 1; + opdbt.size = (u_int32_t)(strlen(opname) + 1); memset(&msgdbt, 0, sizeof(msgdbt)); msgdbt.data = __logbuf; @@ -490,6 +438,8 @@ __db_real_log(dbenv, txnid, opname, flags, fmt, ap) */ __db_debug_log( (DB_ENV *)dbenv, txnid, &lsn, flags, &opdbt, -1, &msgdbt, NULL, 0); + + va_end(ap); } /* @@ -511,34 +461,119 @@ __db_unknown_flag(dbenv, routine, flag) /* * __db_unknown_type -- report internal error * - * PUBLIC: int __db_unknown_type __P((DB_ENV *, char *, u_int32_t)); + * PUBLIC: int __db_unknown_type __P((DB_ENV *, char *, DBTYPE)); */ int __db_unknown_type(dbenv, routine, type) DB_ENV *dbenv; char *routine; - u_int32_t type; + DBTYPE type; { __db_err(dbenv, "%s: Unknown db type: 0x%x", routine, type); DB_ASSERT(0); return (EINVAL); } -#ifdef DIAGNOSTIC /* - * __db_missing_txn_err -- - * Cannot combine operations with and without transactions. + * __db_check_txn -- + * Check for common transaction errors. * - * PUBLIC: #ifdef DIAGNOSTIC - * PUBLIC: int __db_missing_txn_err __P((DB_ENV *)); - * PUBLIC: #endif + * PUBLIC: int __db_check_txn __P((DB *, DB_TXN *, u_int32_t, int)); */ int -__db_missing_txn_err(dbenv) - DB_ENV *dbenv; +__db_check_txn(dbp, txn, assoc_lid, read_op) + DB *dbp; + DB_TXN *txn; + u_int32_t assoc_lid; + int read_op; { + DB_ENV *dbenv; + + dbenv = dbp->dbenv; + + /* + * If we are in recovery or aborting a transaction, then we + * don't need to enforce the rules about dbp's not allowing + * transactional operations in non-transactional dbps and + * vica-versa. This happens all the time as the dbp during + * an abort may be transactional, but we undo operations + * outside a transaction since we're aborting. + */ + if (IS_RECOVERING(dbenv) || F_ISSET(dbp, DB_AM_RECOVER)) + return (0); + + /* + * Check for common transaction errors: + * Failure to pass a transaction handle to a DB operation + * Failure to configure the DB handle in a proper environment + * Operation on a handle whose open commit hasn't completed. + * + * Read operations don't require a txn even if we've used one before + * with this handle, although if they do have a txn, we'd better be + * prepared for it. + */ + if (txn == NULL) { + if (!read_op && F_ISSET(dbp, DB_AM_TXN)) { + __db_err(dbenv, + "DB handle previously used in transaction, missing transaction handle"); + return (EINVAL); + } + + if (dbp->cur_lid >= TXN_MINIMUM) + goto open_err; + } else { + if (dbp->cur_lid >= TXN_MINIMUM && dbp->cur_lid != txn->txnid) + goto open_err; + + if (!TXN_ON(dbenv)) + return (__db_not_txn_env(dbenv)); + + if (!F_ISSET(dbp, DB_AM_TXN)) { + __db_err(dbenv, + "Transaction specified for a DB handle opened outside a transaction"); + return (EINVAL); + } + } + + /* + * If dbp->associate_lid is not DB_LOCK_INVALIDID, that means we're in + * the middle of a DB->associate with DB_CREATE (i.e., a secondary index + * creation). + * + * In addition to the usual transaction rules, we need to lock out + * non-transactional updates that aren't part of the associate (and + * thus are using some other locker ID). + * + * Transactional updates should simply block; from the time we + * decide to build the secondary until commit, we'll hold a write + * lock on all of its pages, so it should be safe to attempt to update + * the secondary in another transaction (presumably by updating the + * primary). + */ + if (!read_op && dbp->associate_lid != DB_LOCK_INVALIDID && + txn != NULL && dbp->associate_lid != assoc_lid) { + __db_err(dbenv, + "Operation forbidden while secondary index is being created"); + return (EINVAL); + } + + return (0); +open_err: __db_err(dbenv, - "DB handle previously used in transaction, missing transaction handle."); + "Transaction that opened the DB handle is still active"); + return (EINVAL); +} + +/* + * __db_not_txn_env -- + * DB handle must be in an environment that supports transactions. + * + * PUBLIC: int __db_not_txn_env __P((DB_ENV *)); + */ +int +__db_not_txn_env(dbenv) + DB_ENV *dbenv; +{ + __db_err(dbenv, "DB environment not configured for transactions"); return (EINVAL); } -#endif diff --git a/bdb/common/db_getlong.c b/bdb/common/db_getlong.c index bead530cd94..6ba8ebfcdaa 100644 --- a/bdb/common/db_getlong.c +++ b/bdb/common/db_getlong.c @@ -1,14 +1,14 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 1996, 1997, 1998, 1999, 2000 + * Copyright (c) 1996-2002 * Sleepycat Software. All rights reserved. */ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: db_getlong.c,v 11.11 2000/12/22 19:16:04 bostic Exp $"; +static const char revid[] = "$Id: db_getlong.c,v 11.18 2002/03/28 20:13:33 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES @@ -20,7 +20,6 @@ static const char revid[] = "$Id: db_getlong.c,v 11.11 2000/12/22 19:16:04 bosti #endif #include "db_int.h" -#include "clib_ext.h" /* * __db_getlong -- @@ -43,42 +42,40 @@ __db_getlong(dbp, progname, p, min, max, storep) val = strtol(p, &end, 10); if ((val == LONG_MIN || val == LONG_MAX) && __os_get_errno() == ERANGE) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: %s\n", progname, p, strerror(ERANGE)); - exit(1); - } - dbp->err(dbp, ERANGE, "%s", p); + else + dbp->err(dbp, ERANGE, "%s", p); return (1); } if (p[0] == '\0' || (end[0] != '\0' && end[0] != '\n')) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: Invalid numeric argument\n", progname, p); - exit(1); - } - dbp->errx(dbp, "%s: Invalid numeric argument", p); + else + dbp->errx(dbp, "%s: Invalid numeric argument", p); return (1); } if (val < min) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: Less than minimum value (%ld)\n", progname, p, min); - exit(1); - } - dbp->errx(dbp, "%s: Less than minimum value (%ld)", p, min); + else + dbp->errx(dbp, + "%s: Less than minimum value (%ld)", p, min); return (1); } if (val > max) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: Greater than maximum value (%ld)\n", progname, p, max); - exit(1); - } - dbp->errx(dbp, "%s: Greater than maximum value (%ld)", p, max); - exit(1); + else + dbp->errx(dbp, + "%s: Greater than maximum value (%ld)", p, max); + return (1); } *storep = val; return (0); @@ -109,31 +106,29 @@ __db_getulong(dbp, progname, p, min, max, storep) __os_set_errno(0); val = strtoul(p, &end, 10); if (val == ULONG_MAX && __os_get_errno() == ERANGE) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: %s\n", progname, p, strerror(ERANGE)); - exit(1); - } - dbp->err(dbp, ERANGE, "%s", p); + else + dbp->err(dbp, ERANGE, "%s", p); return (1); } if (p[0] == '\0' || (end[0] != '\0' && end[0] != '\n')) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, "%s: %s: Invalid numeric argument\n", progname, p); - exit(1); - } - dbp->errx(dbp, "%s: Invalid numeric argument", p); + else + dbp->errx(dbp, "%s: Invalid numeric argument", p); return (1); } if (val < min) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, - "%s: %s: Less than minimum value (%ld)\n", + "%s: %s: Less than minimum value (%lu)\n", progname, p, min); - exit(1); - } - dbp->errx(dbp, "%s: Less than minimum value (%ld)", p, min); + else + dbp->errx(dbp, + "%s: Less than minimum value (%lu)", p, min); return (1); } @@ -144,14 +139,14 @@ __db_getulong(dbp, progname, p, min, max, storep) * may not exist on all platforms. */ if (max != 0 && val > max) { - if (dbp == NULL) { + if (dbp == NULL) fprintf(stderr, - "%s: %s: Greater than maximum value (%ld)\n", + "%s: %s: Greater than maximum value (%lu)\n", progname, p, max); - exit(1); - } - dbp->errx(dbp, "%s: Greater than maximum value (%ld)", p, max); - exit(1); + else + dbp->errx(dbp, + "%s: Greater than maximum value (%lu)", p, max); + return (1); } *storep = val; return (0); diff --git a/bdb/common/db_idspace.c b/bdb/common/db_idspace.c new file mode 100644 index 00000000000..588ffd9fca9 --- /dev/null +++ b/bdb/common/db_idspace.c @@ -0,0 +1,93 @@ +/*- + * See the file LICENSE for redistribution information. + * + * Copyright (c) 2001-2002 + * Sleepycat Software. All rights reserved. + */ + +#include "db_config.h" + +#ifndef lint +static const char revid[] = "$Id: db_idspace.c,v 1.5 2002/02/01 18:15:29 bostic Exp $"; +#endif /* not lint */ + +#ifndef NO_SYSTEM_INCLUDES +#include <sys/types.h> + +#include <stdlib.h> +#endif + +#include "db_int.h" + +static int __db_idcmp __P((const void *, const void *)); + +static int +__db_idcmp(a, b) + const void *a; + const void *b; +{ + u_int32_t i, j; + + i = *(u_int32_t *)a; + j = *(u_int32_t *)b; + + if (i < j) + return (-1); + else if (i > j) + return (1); + else + return (0); +} + +/* + * __db_idspace -- + * + * On input, minp and maxp contain the minimum and maximum valid values for + * the name space and on return, they contain the minimum and maximum ids + * available (by finding the biggest gap). + * + * PUBLIC: void __db_idspace __P((u_int32_t *, int, u_int32_t *, u_int32_t *)); + */ +void +__db_idspace(inuse, n, minp, maxp) + u_int32_t *inuse; + int n; + u_int32_t *minp, *maxp; +{ + int i, low; + u_int32_t gap, t; + + /* A single locker ID is a special case. */ + if (n == 1) { + /* + * If the single item in use is the last one in the range, + * then we've got to perform wrap which means that we set + * the min to the minimum ID, which is what we came in with, + * so we don't do anything. + */ + if (inuse[0] != *maxp) + *minp = inuse[0]; + *maxp = inuse[0] - 1; + return; + } + + gap = 0; + low = 0; + qsort(inuse, n, sizeof(u_int32_t), __db_idcmp); + for (i = 0; i < n - 1; i++) + if ((t = (inuse[i + 1] - inuse[i])) > gap) { + gap = t; + low = i; + } + + /* Check for largest gap at the end of the space. */ + if ((*maxp - inuse[n - 1]) + (inuse[0] - *minp) > gap) { + /* Do same check as we do in the n == 1 case. */ + if (inuse[n - 1] != *maxp) + *minp = inuse[n - 1]; + *maxp = inuse[0]; + } else { + *minp = inuse[low]; + *maxp = inuse[low + 1]; + } +} diff --git a/bdb/common/db_log2.c b/bdb/common/db_log2.c index 95bc69499c6..cdd87dda11d 100644 --- a/bdb/common/db_log2.c +++ b/bdb/common/db_log2.c @@ -1,7 +1,7 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 1996, 1997, 1998, 1999, 2000 + * Copyright (c) 1996-2002 * Sleepycat Software. All rights reserved. */ /* @@ -39,7 +39,7 @@ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: db_log2.c,v 11.4 2000/02/14 02:59:41 bostic Exp $"; +static const char revid[] = "$Id: db_log2.c,v 11.7 2002/02/01 18:15:30 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES @@ -47,7 +47,6 @@ static const char revid[] = "$Id: db_log2.c,v 11.4 2000/02/14 02:59:41 bostic Ex #endif #include "db_int.h" -#include "common_ext.h" /* * PUBLIC: u_int32_t __db_log2 __P((u_int32_t)); diff --git a/bdb/common/util_arg.c b/bdb/common/util_arg.c new file mode 100644 index 00000000000..e034e3bd194 --- /dev/null +++ b/bdb/common/util_arg.c @@ -0,0 +1,126 @@ +/*- + * See the file LICENSE for redistribution information. + * + * Copyright (c) 2001-2002 + * Sleepycat Software. All rights reserved. + */ + +#include "db_config.h" + +#ifndef lint +static const char revid[] = "$Id: util_arg.c,v 1.4 2002/02/01 18:15:30 bostic Exp $"; +#endif /* not lint */ + +#ifndef NO_SYSTEM_INCLUDES +#include <sys/types.h> +#endif + +#include "db_int.h" + +static char *__db_strsep __P((char **, const char *)); + +/* + * __db_util_arg -- + * Convert a string into an argc/argv pair. + * + * PUBLIC: int __db_util_arg __P((char *, char *, int *, char ***)); + */ +int +__db_util_arg(arg0, str, argcp, argvp) + char *arg0, *str, ***argvp; + int *argcp; +{ + int n, ret; + char **ap, **argv; + +#define MAXARGS 25 + if ((ret = + __os_malloc(NULL, (MAXARGS + 1) * sizeof(char **), &argv)) != 0) + return (ret); + + ap = argv; + *ap++ = arg0; + for (n = 1; (*ap = __db_strsep(&str, " \t")) != NULL;) + if (**ap != '\0') { + ++ap; + if (++n == MAXARGS) + break; + } + *ap = NULL; + + *argcp = ap - argv; + *argvp = argv; + + return (0); +} + +/*- + * Copyright (c) 1990, 1993 + * The Regents of the University of California. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * 3. All advertising materials mentioning features or use of this software + * must display the following acknowledgement: + * This product includes software developed by the University of + * California, Berkeley and its contributors. + * 4. Neither the name of the University nor the names of its contributors + * may be used to endorse or promote products derived from this software + * without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND + * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE + * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE + * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL + * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS + * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) + * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT + * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY + * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF + * SUCH DAMAGE. + */ +/* + * Get next token from string *stringp, where tokens are possibly-empty + * strings separated by characters from delim. + * + * Writes NULs into the string at *stringp to end tokens. + * delim need not remain constant from call to call. + * On return, *stringp points past the last NUL written (if there might + * be further tokens), or is NULL (if there are definitely no more tokens). + * + * If *stringp is NULL, strsep returns NULL. + */ +static char * +__db_strsep(stringp, delim) + char **stringp; + const char *delim; +{ + const char *spanp; + int c, sc; + char *s, *tok; + + if ((s = *stringp) == NULL) + return (NULL); + for (tok = s;;) { + c = *s++; + spanp = delim; + do { + if ((sc = *spanp++) == c) { + if (c == 0) + s = NULL; + else + s[-1] = 0; + *stringp = s; + return (tok); + } + } while (sc != 0); + } + /* NOTREACHED */ +} diff --git a/bdb/common/util_cache.c b/bdb/common/util_cache.c new file mode 100644 index 00000000000..5ca88665cc7 --- /dev/null +++ b/bdb/common/util_cache.c @@ -0,0 +1,92 @@ +/*- + * See the file LICENSE for redistribution information. + * + * Copyright (c) 2000-2002 + * Sleepycat Software. All rights reserved. + */ + +#include "db_config.h" + +#ifndef lint +static const char revid[] = "$Id: util_cache.c,v 1.3 2002/04/04 18:50:10 bostic Exp $"; +#endif /* not lint */ + +#ifndef NO_SYSTEM_INCLUDES +#include <sys/types.h> + +#include <stdlib.h> + +#include <string.h> +#include <unistd.h> +#endif + +#include "db_int.h" + +/* + * __db_util_cache -- + * Compute if we have enough cache. + * + * PUBLIC: int __db_util_cache __P((DB_ENV *, DB *, u_int32_t *, int *)); + */ +int +__db_util_cache(dbenv, dbp, cachep, resizep) + DB_ENV *dbenv; + DB *dbp; + u_int32_t *cachep; + int *resizep; +{ + DBTYPE type; + DB_BTREE_STAT *bsp; + DB_HASH_STAT *hsp; + DB_QUEUE_STAT *qsp; + u_int32_t pgsize; + int ret; + void *sp; + + /* + * The current cache size is in cachep. If it's insufficient, set the + * the memory referenced by resizep to 1 and set cachep to the minimum + * size needed. + */ + if ((ret = dbp->get_type(dbp, &type)) != 0) { + dbenv->err(dbenv, ret, "DB->get_type"); + return (ret); + } + + if ((ret = dbp->stat(dbp, &sp, DB_FAST_STAT)) != 0) { + dbenv->err(dbenv, ret, "DB->stat"); + return (ret); + } + + switch (type) { + case DB_QUEUE: + qsp = (DB_QUEUE_STAT *)sp; + pgsize = qsp->qs_pagesize; + break; + case DB_HASH: + hsp = (DB_HASH_STAT *)sp; + pgsize = hsp->hash_pagesize; + break; + case DB_BTREE: + case DB_RECNO: + bsp = (DB_BTREE_STAT *)sp; + pgsize = bsp->bt_pagesize; + break; + default: + dbenv->err(dbenv, ret, "unknown database type: %d", type); + return (EINVAL); + } + free(sp); + + /* + * Make sure our current cache is big enough. We want at least + * DB_MINPAGECACHE pages in the cache. + */ + if ((*cachep / pgsize) < DB_MINPAGECACHE) { + *resizep = 1; + *cachep = pgsize * DB_MINPAGECACHE; + } else + *resizep = 0; + + return (0); +} diff --git a/bdb/common/util_log.c b/bdb/common/util_log.c index a4743cc2cee..ae215fca64a 100644 --- a/bdb/common/util_log.c +++ b/bdb/common/util_log.c @@ -1,14 +1,14 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 2000 + * Copyright (c) 2000-2002 * Sleepycat Software. All rights reserved. */ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: util_log.c,v 1.7 2000/11/30 00:58:31 ubell Exp $"; +static const char revid[] = "$Id: util_log.c,v 1.11 2002/02/01 18:15:30 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES @@ -31,7 +31,6 @@ static const char revid[] = "$Id: util_log.c,v 1.7 2000/11/30 00:58:31 ubell Exp #endif #include "db_int.h" -#include "common_ext.h" /* * __db_util_logset -- @@ -46,12 +45,14 @@ __db_util_logset(progname, fname) { FILE *fp; time_t now; + u_int32_t id; if ((fp = fopen(fname, "w")) == NULL) goto err; (void)time(&now); - fprintf(fp, "%s: %lu %s", progname, (u_long)getpid(), ctime(&now)); + __os_id(&id); + fprintf(fp, "%s: %lu %s", progname, (u_long)id, ctime(&now)); if (fclose(fp) == EOF) goto err; diff --git a/bdb/common/util_sig.c b/bdb/common/util_sig.c index 6fe0166fe64..9714427ad33 100644 --- a/bdb/common/util_sig.c +++ b/bdb/common/util_sig.c @@ -1,14 +1,14 @@ /*- * See the file LICENSE for redistribution information. * - * Copyright (c) 2000 + * Copyright (c) 2000-2002 * Sleepycat Software. All rights reserved. */ #include "db_config.h" #ifndef lint -static const char revid[] = "$Id: util_sig.c,v 1.3 2000/04/28 19:32:00 bostic Exp $"; +static const char revid[] = "$Id: util_sig.c,v 1.7 2002/02/02 17:04:42 bostic Exp $"; #endif /* not lint */ #ifndef NO_SYSTEM_INCLUDES @@ -18,7 +18,6 @@ static const char revid[] = "$Id: util_sig.c,v 1.3 2000/04/28 19:32:00 bostic Ex #endif #include "db_int.h" -#include "common_ext.h" static int interrupt; static void onint __P((int)); @@ -79,7 +78,7 @@ void __db_util_sigresend() { /* Resend any caught signal. */ - if (__db_util_interrupted != 0) { + if (interrupt != 0) { (void)signal(interrupt, SIG_DFL); (void)raise(interrupt); /* NOTREACHED */ |