ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/BDB/BDB.xs
(Generate patch)

Comparing BDB/BDB.xs (file contents):
Revision 1.28 by root, Sat Dec 22 07:33:48 2007 UTC vs.
Revision 1.31 by root, Sun Mar 30 04:34:20 2008 UTC

… …
39typedef DB_ENV DB_ENV_ornull; 39typedef DB_ENV DB_ENV_ornull;
40typedef DB_TXN DB_TXN_ornull; 40typedef DB_TXN DB_TXN_ornull;
41typedef DBC DBC_ornull; 41typedef DBC DBC_ornull;
42typedef DB DB_ornull; 42typedef DB DB_ornull;
43typedef DB_SEQUENCE DB_SEQUENCE_ornull; 43typedef DB_SEQUENCE DB_SEQUENCE_ornull;
44
45typedef DB_ENV DB_ENV_ornuked;
46typedef DB_TXN DB_TXN_ornuked;
47typedef DBC DBC_ornuked;
48typedef DB DB_ornuked;
49typedef DB_SEQUENCE DB_SEQUENCE_ornuked;
44 50
45typedef SV SV8; /* byte-sv, used for argument-checking */ 51typedef SV SV8; /* byte-sv, used for argument-checking */
46typedef char *octetstring; 52typedef char *octetstring;
47 53
48static SV *prepare_cb; 54static SV *prepare_cb;
… …
922 req->pri = req_pri 928 req->pri = req_pri
923 929
924#define REQ_SEND \ 930#define REQ_SEND \
925 req_send (req) 931 req_send (req)
926 932
927#define SvPTR(var, arg, type, class, nullok) \ 933#define SvPTR(var, arg, type, class, nullok) \
928 if (!SvOK (arg)) \ 934 if (!SvOK (arg)) \
929 { \ 935 { \
930 if (!nullok) \ 936 if (nullok != 1) \
931 croak (# var " must be a " # class " object, not undef"); \ 937 croak (# var " must be a " # class " object, not undef"); \
932 \ 938 \
933 (var) = 0; \ 939 (var) = 0; \
934 } \ 940 } \
935 else if (sv_derived_from ((arg), # class)) \ 941 else if (sv_derived_from ((arg), # class)) \
936 { \ 942 { \
937 IV tmp = SvIV ((SV*) SvRV (arg)); \ 943 IV tmp = SvIV ((SV*) SvRV (arg)); \
938 (var) = INT2PTR (type, tmp); \ 944 (var) = INT2PTR (type, tmp); \
939 if (!var) \ 945 if (!var && nullok != 2) \
940 croak (# var " is not a valid " # class " object anymore"); \ 946 croak (# var " is not a valid " # class " object anymore"); \
941 } \ 947 } \
942 else \ 948 else \
943 croak (# var " is not of type " # class); \ 949 croak (# var " is not of type " # class); \
944 \ 950 \
… …
946static void 952static void
947ptr_nuke (SV *sv) 953ptr_nuke (SV *sv)
948{ 954{
949 assert (SvROK (sv)); 955 assert (SvROK (sv));
950 sv_setiv (SvRV (sv), 0); 956 sv_setiv (SvRV (sv), 0);
957}
958
959static int
960errno_get (pTHX_ SV *sv, MAGIC *mg)
961{
962 if (*mg->mg_ptr == '!') // should always be the case
963 if (-30999 <= errno && errno <= -30800)
964 {
965 sv_setpv (sv, db_strerror (errno));
966 return 0;
967 }
968
969 return PL_vtbl_sv.svt_get (aTHX_ sv, mg);
970}
971
972static MGVTBL vtbl_errno;
973
974// this wonderful hack :( patches perl's $! variable to support our errno values
975static void
976patch_errno (void)
977{
978 SV *sv;
979 MAGIC *mg;
980
981 if (!(sv = get_sv ("!", 1)))
982 return;
983
984 if (!(mg = mg_find (sv, PERL_MAGIC_sv)))
985 return;
986
987 if (mg->mg_virtual != &PL_vtbl_sv)
988 return;
989
990 vtbl_errno = PL_vtbl_sv;
991 vtbl_errno.svt_get = errno_get;
992 mg->mg_virtual = &vtbl_errno;
951} 993}
952 994
953MODULE = BDB PACKAGE = BDB 995MODULE = BDB PACKAGE = BDB
954 996
955PROTOTYPES: ENABLE 997PROTOTYPES: ENABLE
… …
1153 X_MUTEX_CHECK (reslock); 1195 X_MUTEX_CHECK (reslock);
1154 X_MUTEX_CHECK (reqlock); 1196 X_MUTEX_CHECK (reqlock);
1155 1197
1156 X_COND_CHECK (reqwait); 1198 X_COND_CHECK (reqwait);
1157#endif 1199#endif
1200 patch_errno ();
1158} 1201}
1159 1202
1160void 1203void
1161max_poll_reqs (int nreqs) 1204max_poll_reqs (int nreqs)
1162 PROTOTYPE: $ 1205 PROTOTYPE: $
… …
1324void 1367void
1325db_env_open (DB_ENV *env, octetstring db_home, U32 open_flags, int mode, SV *callback = &PL_sv_undef) 1368db_env_open (DB_ENV *env, octetstring db_home, U32 open_flags, int mode, SV *callback = &PL_sv_undef)
1326 CODE: 1369 CODE:
1327{ 1370{
1328 dREQ (REQ_ENV_OPEN); 1371 dREQ (REQ_ENV_OPEN);
1329
1330 env->set_thread_count (env, wanted + 2);
1331 1372
1332 req->env = env; 1373 req->env = env;
1333 req->uint1 = open_flags | DB_THREAD; 1374 req->uint1 = open_flags | DB_THREAD;
1334 req->int1 = mode; 1375 req->int1 = mode;
1335 req->buf1 = strdup_ornull (db_home); 1376 req->buf1 = strdup_ornull (db_home);
… …
1713 1754
1714 1755
1715MODULE = BDB PACKAGE = BDB::Env 1756MODULE = BDB PACKAGE = BDB::Env
1716 1757
1717void 1758void
1718DESTROY (DB_ENV_ornull *env) 1759DESTROY (DB_ENV_ornuked *env)
1719 CODE: 1760 CODE:
1720 if (env) 1761 if (env)
1721 env->close (env, 0); 1762 env->close (env, 0);
1722 1763
1723int set_data_dir (DB_ENV *env, const char *dir) 1764int set_data_dir (DB_ENV *env, const char *dir)
… …
1870 RETVAL 1911 RETVAL
1871 1912
1872MODULE = BDB PACKAGE = BDB::Db 1913MODULE = BDB PACKAGE = BDB::Db
1873 1914
1874void 1915void
1875DESTROY (DB_ornull *db) 1916DESTROY (DB_ornuked *db)
1876 CODE: 1917 CODE:
1877 if (db) 1918 if (db)
1878 { 1919 {
1879 SV *env = (SV *)db->app_private; 1920 SV *env = (SV *)db->app_private;
1880 db->close (db, 0); 1921 db->close (db, 0);
… …
1975 2016
1976 2017
1977MODULE = BDB PACKAGE = BDB::Txn 2018MODULE = BDB PACKAGE = BDB::Txn
1978 2019
1979void 2020void
1980DESTROY (DB_TXN_ornull *txn) 2021DESTROY (DB_TXN_ornuked *txn)
1981 CODE: 2022 CODE:
1982 if (txn) 2023 if (txn)
1983 txn->abort (txn); 2024 txn->abort (txn);
1984 2025
1985int set_timeout (DB_TXN *txn, NV timeout, U32 flags = DB_SET_TXN_TIMEOUT) 2026int set_timeout (DB_TXN *txn, NV timeout, U32 flags = DB_SET_TXN_TIMEOUT)
… …
1996 2037
1997 2038
1998MODULE = BDB PACKAGE = BDB::Cursor 2039MODULE = BDB PACKAGE = BDB::Cursor
1999 2040
2000void 2041void
2001DESTROY (DBC_ornull *dbc) 2042DESTROY (DBC_ornuked *dbc)
2002 CODE: 2043 CODE:
2003 if (dbc) 2044 if (dbc)
2004 dbc->c_close (dbc); 2045 dbc->c_close (dbc);
2005 2046
2006#if DB_VERSION_MINOR >= 6 2047#if DB_VERSION_MINOR >= 6
… …
2012#endif 2053#endif
2013 2054
2014MODULE = BDB PACKAGE = BDB::Sequence 2055MODULE = BDB PACKAGE = BDB::Sequence
2015 2056
2016void 2057void
2017DESTROY (DB_SEQUENCE_ornull *seq) 2058DESTROY (DB_SEQUENCE_ornuked *seq)
2018 CODE: 2059 CODE:
2019 if (seq) 2060 if (seq)
2020 seq->close (seq, 0); 2061 seq->close (seq, 0);
2021 2062
2022int initial_value (DB_SEQUENCE *seq, db_seq_t value) 2063int initial_value (DB_SEQUENCE *seq, db_seq_t value)
… …
2041 CODE: 2082 CODE:
2042 RETVAL = seq->set_range (seq, min, max); 2083 RETVAL = seq->set_range (seq, min, max);
2043 OUTPUT: 2084 OUTPUT:
2044 RETVAL 2085 RETVAL
2045 2086
2087

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines