[ViewVC] Diff of: cvs/BDB/BDB.xs

Comparing BDB/BDB.xs (file contents):
Revision 1.45 by root, Wed Jul 9 21:08:29 2008 UTC vs.
Revision 1.49 by root, Thu Sep 25 12:28:49 2008 UTC

…		…
		1	#include <sys/user.h>
		2	#include <sys/ptrace.h>
		3
		4	#define X_STACKSIZE 1024 * 128 + sizeof (long) * 64 * 1024 / 4
		5
1	#include "xthread.h"	6	#include "xthread.h"
2		7
3	#include <errno.h>	8	#include <errno.h>
4		9
5	#include "EXTERN.h"	10	#include "EXTERN.h"
27	# include <unistd.h>	32	# include <unistd.h>
28	#endif	33	#endif
29		34
30	#include <db.h>	35	#include <db.h>
31		36
32	#if DB_VERSION_MAJOR < 4 \|\| (DB_VERSION_MAJOR == 4 && DB_VERSION_MINOR < 4)	37	#if DB_VERSION_MAJOR != 4 \|\| (DB_VERSION_MAJOR == 4 && DB_VERSION_MINOR < 3)
33	# error you need Berkeley DB 4.4 or newer installed	38	# error you need Berkeley DB 4.3 or a newer 4.x version installed
34	#endif	39	#endif
35		40
36	/* number of seconds after which idle threads exit */	41	/* number of seconds after which idle threads exit */
37	#define IDLE_TIMEOUT 10	42	#define IDLE_TIMEOUT 10
38		43
39	typedef DB_ENV DB_ENV_ornull;	44	typedef DB_ENV DB_ENV_ornull;
40	typedef DB_TXN DB_TXN_ornull;	45	typedef DB_TXN DB_TXN_ornull;
41	typedef DBC DBC_ornull;	46	typedef DBC DBC_ornull;
42	typedef DB DB_ornull;	47	typedef DB DB_ornull;
43	typedef DB_SEQUENCE DB_SEQUENCE_ornull;
44		48
45	typedef DB_ENV DB_ENV_ornuked;	49	typedef DB_ENV DB_ENV_ornuked;
46	typedef DB_TXN DB_TXN_ornuked;	50	typedef DB_TXN DB_TXN_ornuked;
47	typedef DBC DBC_ornuked;	51	typedef DBC DBC_ornuked;
48	typedef DB DB_ornuked;	52	typedef DB DB_ornuked;
		53
		54	#if DB_VERSION_MINOR >= 3
		55	typedef DB_SEQUENCE DB_SEQUENCE_ornull;
49	typedef DB_SEQUENCE DB_SEQUENCE_ornuked;	56	typedef DB_SEQUENCE DB_SEQUENCE_ornuked;
		57	#endif
50		58
51	typedef SV SV8; /* byte-sv, used for argument-checking */	59	typedef SV SV8; /* byte-sv, used for argument-checking */
52	typedef char *bdb_filename;	60	typedef char *bdb_filename;
53		61
54	static SV *prepare_cb;	62	static SV *prepare_cb;
…		…
127	dbt_to_sv (SV sv, DBT dbt)	135	dbt_to_sv (SV sv, DBT dbt)
128	{	136	{
129	if (sv)	137	if (sv)
130	{	138	{
131	SvREADONLY_off (sv);	139	SvREADONLY_off (sv);
132	sv_setpvn_mg (sv, dbt->data, dbt->size);	140	sv_setsv_mg (sv, dbt->data ? newSVpvn (dbt->data, dbt->size) : &PL_sv_undef);
133	SvREFCNT_dec (sv);	141	SvREFCNT_dec (sv);
134	}	142	}
135		143
		144	//assert (dbt->flags & DBT_MALLOC \|\| !dbt->data);
136	free (dbt->data);	145	free (dbt->data);
137	}	146	}
138		147
139	enum {	148	enum {
140	REQ_QUIT,	149	REQ_QUIT,
…		…
164	char buf1, buf2, *buf3;	173	char buf1, buf2, *buf3;
165	SV sv1, sv2, *sv3;	174	SV sv1, sv2, *sv3;
166		175
167	DBT dbt1, dbt2, dbt3;	176	DBT dbt1, dbt2, dbt3;
168	DB_KEY_RANGE key_range;	177	DB_KEY_RANGE key_range;
		178	#if DB_VERSION_MINOR >= 3
169	DB_SEQUENCE *seq;	179	DB_SEQUENCE *seq;
170	db_seq_t seq_t;	180	db_seq_t seq_t;
		181	#endif
171	} bdb_cb;	182	} bdb_cb;
172		183
173	typedef bdb_cb *bdb_req;	184	typedef bdb_cb *bdb_req;
174		185
175	enum {	186	enum {
…		…
384	sv_setsv_mg (req->sv1, newRV_noinc ((SV *)av));	395	sv_setsv_mg (req->sv1, newRV_noinc ((SV *)av));
385	SvREFCNT_dec (req->sv1);	396	SvREFCNT_dec (req->sv1);
386	}	397	}
387	break;	398	break;
388		399
		400	#if DB_VERSION_MINOR >= 3
389	case REQ_SEQ_GET:	401	case REQ_SEQ_GET:
390	SvREADONLY_off (req->sv1);	402	SvREADONLY_off (req->sv1);
391		403
392	if (sizeof (IV) > 4)	404	if (sizeof (IV) > 4)
393	sv_setiv_mg (req->sv1, (IV)req->seq_t);	405	sv_setiv_mg (req->sv1, (IV)req->seq_t);
394	else	406	else
395	sv_setnv_mg (req->sv1, (NV)req->seq_t);	407	sv_setnv_mg (req->sv1, (NV)req->seq_t);
396		408
397	SvREFCNT_dec (req->sv1);	409	SvREFCNT_dec (req->sv1);
398	break;	410	break;
		411	#endif
399	}	412	}
400		413
401	errno = req->result;	414	errno = req->result;
402		415
403	PUTBACK;	416	PUTBACK;
…		…
517	on_next_submit = 0;	530	on_next_submit = 0;
518		531
519	PUSHMARK (SP);	532	PUSHMARK (SP);
520	PUTBACK;	533	PUTBACK;
521	call_sv (cb, G_DISCARD \| G_EVAL);	534	call_sv (cb, G_DISCARD \| G_EVAL);
		535	SPAGAIN;
522	}	536	}
523		537
524	// synthesize callback if none given	538	// synthesize callback if none given
525	if (!req->callback)	539	if (!req->callback)
526	{	540	{
…		…
534		548
535	if (count != 2)	549	if (count != 2)
536	croak ("prepare callback must return exactly two values\n");	550	croak ("prepare callback must return exactly two values\n");
537		551
538	wait_callback = POPs;	552	wait_callback = POPs;
539	SvREFCNT_dec (req->callback);
540	req->callback = SvREFCNT_inc (POPs);	553	req->callback = SvREFCNT_inc (POPs);
541	}	554	}
542		555
543	++nreqs;	556	++nreqs;
544		557
…		…
745	}	758	}
746		759
747	--nready;	760	--nready;
748		761
749	X_UNLOCK (reqlock);	762	X_UNLOCK (reqlock);
750		763
751	switch (req->type)	764	switch (req->type)
752	{	765	{
753	case REQ_QUIT:	766	case REQ_QUIT:
754	req->result = ENOSYS;	767	req->result = ENOSYS;
755	goto quit;	768	goto quit;
…		…
792		805
793	case REQ_DB_CLOSE:	806	case REQ_DB_CLOSE:
794	req->result = req->db->close (req->db, req->uint1);	807	req->result = req->db->close (req->db, req->uint1);
795	break;	808	break;
796		809
		810	#if DB_VERSION_MINOR >= 4
797	case REQ_DB_COMPACT:	811	case REQ_DB_COMPACT:
798	req->result = req->db->compact (req->db, req->txn, &req->dbt1, &req->dbt2, 0, req->uint1, 0);	812	req->result = req->db->compact (req->db, req->txn, &req->dbt1, &req->dbt2, 0, req->uint1, 0);
799	break;	813	break;
		814	#endif
800		815
801	case REQ_DB_SYNC:	816	case REQ_DB_SYNC:
802	req->result = req->db->sync (req->db, req->uint1);	817	req->result = req->db->sync (req->db, req->uint1);
803	break;	818	break;
804		819
…		…
808		823
809	case REQ_DB_PUT:	824	case REQ_DB_PUT:
810	req->result = req->db->put (req->db, req->txn, &req->dbt1, &req->dbt2, req->uint1);	825	req->result = req->db->put (req->db, req->txn, &req->dbt1, &req->dbt2, req->uint1);
811	break;	826	break;
812		827
		828	#if DB_VERSION_MINOR >= 6
813	case REQ_DB_EXISTS:	829	case REQ_DB_EXISTS:
814	req->result = req->db->exists (req->db, req->txn, &req->dbt1, req->uint1);	830	req->result = req->db->exists (req->db, req->txn, &req->dbt1, req->uint1);
815	break;	831	break;
816		832	#endif
817	case REQ_DB_GET:	833	case REQ_DB_GET:
818	req->result = req->db->get (req->db, req->txn, &req->dbt1, &req->dbt3, req->uint1);	834	req->result = req->db->get (req->db, req->txn, &req->dbt1, &req->dbt3, req->uint1);
819	break;	835	break;
820		836
821	case REQ_DB_PGET:	837	case REQ_DB_PGET:
…		…
875		891
876	case REQ_C_DEL:	892	case REQ_C_DEL:
877	req->result = req->dbc->c_del (req->dbc, req->uint1);	893	req->result = req->dbc->c_del (req->dbc, req->uint1);
878	break;	894	break;
879		895
		896	#if DB_VERSION_MINOR >= 3
880	case REQ_SEQ_OPEN:	897	case REQ_SEQ_OPEN:
881	req->result = req->seq->open (req->seq, req->txn, &req->dbt1, req->uint1);	898	req->result = req->seq->open (req->seq, req->txn, &req->dbt1, req->uint1);
882	break;	899	break;
883		900
884	case REQ_SEQ_CLOSE:	901	case REQ_SEQ_CLOSE:
…		…
890	break;	907	break;
891		908
892	case REQ_SEQ_REMOVE:	909	case REQ_SEQ_REMOVE:
893	req->result = req->seq->remove (req->seq, req->txn, req->uint1);	910	req->result = req->seq->remove (req->seq, req->txn, req->uint1);
894	break;	911	break;
		912	#endif
895		913
896	default:	914	default:
897	req->result = ENOSYS;	915	req->result = ENOSYS;
898	break;	916	break;
899	}	917	}
…		…
1085	}	1103	}
1086		1104
1087	return 0;	1105	return 0;
1088	}	1106	}
1089		1107
		1108	/* stupid windoes defined CALLBACK as well */
		1109	#undef CALLBACK
1090	#define CALLBACK SV *cb = pop_callback (&items, ST (items - 1));	1110	#define CALLBACK SV *cb = pop_callback (&items, ST (items - 1));
1091		1111
1092	MODULE = BDB PACKAGE = BDB	1112	MODULE = BDB PACKAGE = BDB
1093		1113
1094	PROTOTYPES: ENABLE	1114	PROTOTYPES: ENABLE
…		…
1116	const_iv (RDONLY)	1136	const_iv (RDONLY)
1117	const_iv (USE_ENVIRON)	1137	const_iv (USE_ENVIRON)
1118	const_iv (USE_ENVIRON_ROOT)	1138	const_iv (USE_ENVIRON_ROOT)
1119	const_iv (LOCKDOWN)	1139	const_iv (LOCKDOWN)
1120	const_iv (PRIVATE)	1140	const_iv (PRIVATE)
1121	const_iv (REGISTER)
1122	const_iv (SYSTEM_MEM)	1141	const_iv (SYSTEM_MEM)
1123	const_iv (AUTO_COMMIT)	1142	const_iv (AUTO_COMMIT)
1124	const_iv (CDB_ALLDB)	1143	const_iv (CDB_ALLDB)
1125	const_iv (DIRECT_DB)	1144	const_iv (DIRECT_DB)
1126	const_iv (DSYNC_DB)
1127	const_iv (NOLOCKING)	1145	const_iv (NOLOCKING)
1128	const_iv (NOMMAP)	1146	const_iv (NOMMAP)
1129	const_iv (NOPANIC)	1147	const_iv (NOPANIC)
1130	const_iv (OVERWRITE)	1148	const_iv (OVERWRITE)
1131	const_iv (PANIC_ENVIRONMENT)	1149	const_iv (PANIC_ENVIRONMENT)
…		…
1142	const_iv (HASH)	1160	const_iv (HASH)
1143	const_iv (QUEUE)	1161	const_iv (QUEUE)
1144	const_iv (RECNO)	1162	const_iv (RECNO)
1145	const_iv (UNKNOWN)	1163	const_iv (UNKNOWN)
1146	const_iv (EXCL)	1164	const_iv (EXCL)
1147	const_iv (READ_COMMITTED)
1148	const_iv (READ_UNCOMMITTED)
1149	const_iv (TRUNCATE)	1165	const_iv (TRUNCATE)
1150	const_iv (NOSYNC)	1166	const_iv (NOSYNC)
1151	const_iv (CHKSUM)	1167	const_iv (CHKSUM)
1152	const_iv (ENCRYPT)	1168	const_iv (ENCRYPT)
1153	const_iv (DUP)	1169	const_iv (DUP)
1154	const_iv (DUPSORT)	1170	const_iv (DUPSORT)
1155	const_iv (RECNUM)	1171	const_iv (RECNUM)
1156	const_iv (RENUMBER)	1172	const_iv (RENUMBER)
1157	const_iv (REVSPLITOFF)	1173	const_iv (REVSPLITOFF)
1158	const_iv (INORDER)
1159	const_iv (CONSUME)	1174	const_iv (CONSUME)
1160	const_iv (CONSUME_WAIT)	1175	const_iv (CONSUME_WAIT)
1161	const_iv (GET_BOTH)	1176	const_iv (GET_BOTH)
1162	const_iv (GET_BOTH_RANGE)	1177	const_iv (GET_BOTH_RANGE)
1163	//const_iv (SET_RECNO)	1178	//const_iv (SET_RECNO)
…		…
1172	const_iv (LOCK_DEADLOCK)	1187	const_iv (LOCK_DEADLOCK)
1173	const_iv (LOCK_NOTGRANTED)	1188	const_iv (LOCK_NOTGRANTED)
1174	const_iv (RUNRECOVERY)	1189	const_iv (RUNRECOVERY)
1175	const_iv (OLD_VERSION)	1190	const_iv (OLD_VERSION)
1176	const_iv (REP_HANDLE_DEAD)	1191	const_iv (REP_HANDLE_DEAD)
1177	const_iv (REP_LOCKOUT)
1178	const_iv (SECONDARY_BAD)	1192	const_iv (SECONDARY_BAD)
1179
1180	const_iv (FREE_SPACE)
1181	const_iv (FREELIST_ONLY)
1182		1193
1183	const_iv (APPEND)	1194	const_iv (APPEND)
1184	const_iv (NODUPDATA)	1195	const_iv (NODUPDATA)
1185	const_iv (NOOVERWRITE)	1196	const_iv (NOOVERWRITE)
1186		1197
…		…
1209	const_iv (FORCE)	1220	const_iv (FORCE)
1210		1221
1211	const_iv (LOCK_DEFAULT)	1222	const_iv (LOCK_DEFAULT)
1212	const_iv (LOCK_EXPIRE)	1223	const_iv (LOCK_EXPIRE)
1213	const_iv (LOCK_MAXLOCKS)	1224	const_iv (LOCK_MAXLOCKS)
1214	const_iv (LOCK_MAXWRITE)
1215	const_iv (LOCK_MINLOCKS)	1225	const_iv (LOCK_MINLOCKS)
1216	const_iv (LOCK_MINWRITE)	1226	const_iv (LOCK_MINWRITE)
1217	const_iv (LOCK_OLDEST)	1227	const_iv (LOCK_OLDEST)
1218	const_iv (LOCK_RANDOM)	1228	const_iv (LOCK_RANDOM)
1219	const_iv (LOCK_YOUNGEST)	1229	const_iv (LOCK_YOUNGEST)
1220		1230
1221	const_iv (SEQ_DEC)
1222	const_iv (SEQ_INC)
1223	const_iv (SEQ_WRAP)
1224
1225	const_iv (BUFFER_SMALL)
1226	const_iv (DONOTINDEX)	1231	const_iv (DONOTINDEX)
1227	const_iv (KEYEMPTY )	1232	const_iv (KEYEMPTY )
1228	const_iv (KEYEXIST )	1233	const_iv (KEYEXIST )
1229	const_iv (LOCK_DEADLOCK)	1234	const_iv (LOCK_DEADLOCK)
1230	const_iv (LOCK_NOTGRANTED)	1235	const_iv (LOCK_NOTGRANTED)
1231	const_iv (LOG_BUFFER_FULL)
1232	const_iv (NOSERVER)	1236	const_iv (NOSERVER)
1233	const_iv (NOSERVER_HOME)	1237	const_iv (NOSERVER_HOME)
1234	const_iv (NOSERVER_ID)	1238	const_iv (NOSERVER_ID)
1235	const_iv (NOTFOUND)	1239	const_iv (NOTFOUND)
1236	const_iv (PAGE_NOTFOUND)	1240	const_iv (PAGE_NOTFOUND)
1237	const_iv (REP_DUPMASTER)	1241	const_iv (REP_DUPMASTER)
1238	const_iv (REP_HANDLE_DEAD)	1242	const_iv (REP_HANDLE_DEAD)
1239	const_iv (REP_HOLDELECTION)	1243	const_iv (REP_HOLDELECTION)
1240	const_iv (REP_IGNORE)
1241	const_iv (REP_ISPERM)	1244	const_iv (REP_ISPERM)
1242	const_iv (REP_JOIN_FAILURE)
1243	const_iv (REP_LOCKOUT)
1244	const_iv (REP_NEWMASTER)	1245	const_iv (REP_NEWMASTER)
1245	const_iv (REP_NEWSITE)	1246	const_iv (REP_NEWSITE)
1246	const_iv (REP_NOTPERM)	1247	const_iv (REP_NOTPERM)
1247	const_iv (REP_UNAVAIL)	1248	const_iv (REP_UNAVAIL)
1248	const_iv (RUNRECOVERY)	1249	const_iv (RUNRECOVERY)
1249	const_iv (SECONDARY_BAD)	1250	const_iv (SECONDARY_BAD)
1250	const_iv (VERIFY_BAD)	1251	const_iv (VERIFY_BAD)
1251	const_iv (VERSION_MISMATCH)
1252		1252
1253	const_iv (VERB_DEADLOCK)	1253	const_iv (VERB_DEADLOCK)
1254	const_iv (VERB_RECOVERY)	1254	const_iv (VERB_RECOVERY)
1255	const_iv (VERB_REGISTER)
1256	const_iv (VERB_REPLICATION)	1255	const_iv (VERB_REPLICATION)
1257	const_iv (VERB_WAITSFOR)	1256	const_iv (VERB_WAITSFOR)
1258		1257
1259	const_iv (VERSION_MAJOR)	1258	const_iv (VERSION_MAJOR)
1260	const_iv (VERSION_MINOR)	1259	const_iv (VERSION_MINOR)
1261	const_iv (VERSION_PATCH)	1260	const_iv (VERSION_PATCH)
		1261	#if DB_VERSION_MINOR >= 3
		1262	const_iv (INORDER)
		1263	const_iv (LOCK_MAXWRITE)
		1264	const_iv (SEQ_DEC)
		1265	const_iv (SEQ_INC)
		1266	const_iv (SEQ_WRAP)
		1267	const_iv (BUFFER_SMALL)
		1268	const_iv (LOG_BUFFER_FULL)
		1269	const_iv (VERSION_MISMATCH)
		1270	#endif
		1271	#if DB_VERSION_MINOR >= 4
		1272	const_iv (REGISTER)
		1273	const_iv (DSYNC_DB)
		1274	const_iv (READ_COMMITTED)
		1275	const_iv (READ_UNCOMMITTED)
		1276	const_iv (REP_IGNORE)
		1277	const_iv (REP_LOCKOUT)
		1278	const_iv (REP_JOIN_FAILURE)
		1279	const_iv (FREE_SPACE)
		1280	const_iv (FREELIST_ONLY)
		1281	const_iv (VERB_REGISTER)
		1282	#endif
1262	#if DB_VERSION_MINOR >= 5	1283	#if DB_VERSION_MINOR >= 5
1263	const_iv (MULTIVERSION)	1284	const_iv (MULTIVERSION)
1264	const_iv (TXN_SNAPSHOT)	1285	const_iv (TXN_SNAPSHOT)
1265	#endif	1286	#endif
1266	#if DB_VERSION_MINOR >= 6	1287	#if DB_VERSION_MINOR >= 6
…		…
1278	const_iv (LOG_AUTO_REMOVE)	1299	const_iv (LOG_AUTO_REMOVE)
1279	const_iv (LOG_IN_MEMORY)	1300	const_iv (LOG_IN_MEMORY)
1280	const_iv (LOG_ZERO)	1301	const_iv (LOG_ZERO)
1281	#else	1302	#else
1282	const_iv (DIRECT_LOG)	1303	const_iv (DIRECT_LOG)
		1304	const_iv (LOG_AUTOREMOVE)
		1305	# if DB_VERSION_MINOR >= 3
1283	const_iv (DSYNC_LOG)	1306	const_iv (DSYNC_LOG)
1284	const_iv (LOG_AUTOREMOVE)
1285	const_iv (LOG_INMEMORY)	1307	const_iv (LOG_INMEMORY)
		1308	# endif
1286	#endif	1309	#endif
1287	};	1310	};
1288		1311
1289	for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )	1312	for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ-- > const_iv; )
1290	newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));	1313	newCONSTSUB (stash, (char *)civ->name, newSViv (civ->iv));
…		…
1623	req->sv1 = (SV *)db->app_private;	1646	req->sv1 = (SV *)db->app_private;
1624	REQ_SEND;	1647	REQ_SEND;
1625	ptr_nuke (ST (0));	1648	ptr_nuke (ST (0));
1626	}	1649	}
1627		1650
		1651	#if DB_VERSION_MINOR >= 4
		1652
1628	void	1653	void
1629	db_compact (DB db, DB_TXN_ornull txn = 0, SV start = 0, SV stop = 0, SV unused1 = 0, U32 flags = DB_FREE_SPACE, SV unused2 = 0, SV *callback = 0)	1654	db_compact (DB db, DB_TXN_ornull txn = 0, SV start = 0, SV stop = 0, SV unused1 = 0, U32 flags = DB_FREE_SPACE, SV unused2 = 0, SV *callback = 0)
1630	PREINIT:	1655	PREINIT:
1631	CALLBACK	1656	CALLBACK
1632	CODE:	1657	CODE:
…		…
1638	sv_to_dbt (&req->dbt2, stop);	1663	sv_to_dbt (&req->dbt2, stop);
1639	req->uint1 = flags;	1664	req->uint1 = flags;
1640	REQ_SEND;	1665	REQ_SEND;
1641	}	1666	}
1642		1667
		1668	#endif
		1669
1643	void	1670	void
1644	db_sync (DB db, U32 flags = 0, SV callback = 0)	1671	db_sync (DB db, U32 flags = 0, SV callback = 0)
1645	PREINIT:	1672	PREINIT:
1646	CALLBACK	1673	CALLBACK
1647	CODE:	1674	CODE:
…		…
1693	sv_to_dbt (&req->dbt2, data);	1720	sv_to_dbt (&req->dbt2, data);
1694	req->uint1 = flags;	1721	req->uint1 = flags;
1695	REQ_SEND;	1722	REQ_SEND;
1696	}	1723	}
1697		1724
		1725	#if DB_VERSION_MINOR >= 6
		1726
1698	void	1727	void
1699	db_exists (DB db, DB_TXN_ornull txn, SV key, U32 flags = 0, SV callback = 0)	1728	db_exists (DB db, DB_TXN_ornull txn, SV key, U32 flags = 0, SV callback = 0)
1700	PREINIT:	1729	PREINIT:
1701	CALLBACK	1730	CALLBACK
1702	CODE:	1731	CODE:
…		…
1706	req->txn = txn;	1735	req->txn = txn;
1707	req->uint1 = flags;	1736	req->uint1 = flags;
1708	sv_to_dbt (&req->dbt1, key);	1737	sv_to_dbt (&req->dbt1, key);
1709	REQ_SEND;	1738	REQ_SEND;
1710	}	1739	}
		1740
		1741	#endif
1711		1742
1712	void	1743	void
1713	db_get (DB db, DB_TXN_ornull txn, SV key, SV data, U32 flags = 0, SV *callback = 0)	1744	db_get (DB db, DB_TXN_ornull txn, SV key, SV data, U32 flags = 0, SV *callback = 0)
1714	PREINIT:	1745	PREINIT:
1715	CALLBACK	1746	CALLBACK
…		…
1904	req->uint1 = flags;	1935	req->uint1 = flags;
1905	REQ_SEND;	1936	REQ_SEND;
1906	}	1937	}
1907		1938
1908		1939
		1940	#if DB_VERSION_MINOR >= 3
		1941
1909	void	1942	void
1910	db_sequence_open (DB_SEQUENCE seq, DB_TXN_ornull txnid, SV key, U32 flags = 0, SV callback = 0)	1943	db_sequence_open (DB_SEQUENCE seq, DB_TXN_ornull txnid, SV key, U32 flags = 0, SV callback = 0)
1911	PREINIT:	1944	PREINIT:
1912	CALLBACK	1945	CALLBACK
1913	CODE:	1946	CODE:
…		…
1959	req->txn = txnid;	1992	req->txn = txnid;
1960	req->uint1 = flags;	1993	req->uint1 = flags;
1961	REQ_SEND;	1994	REQ_SEND;
1962	}	1995	}
1963		1996
		1997	#endif
		1998
1964		1999
1965	MODULE = BDB PACKAGE = BDB::Env	2000	MODULE = BDB PACKAGE = BDB::Env
1966		2001
1967	void	2002	void
1968	DESTROY (DB_ENV_ornuked *env)	2003	DESTROY (DB_ENV_ornuked *env)
…		…
2100	int set_lg_max (DB_ENV *env, U32 max)	2135	int set_lg_max (DB_ENV *env, U32 max)
2101	CODE:	2136	CODE:
2102	RETVAL = env->set_lg_max (env, max);	2137	RETVAL = env->set_lg_max (env, max);
2103	OUTPUT:	2138	OUTPUT:
2104	RETVAL	2139	RETVAL
		2140
		2141	#if DB_VERSION_MINOR >= 4
2105		2142
2106	int mutex_set_max (DB_ENV *env, U32 max)	2143	int mutex_set_max (DB_ENV *env, U32 max)
2107	CODE:	2144	CODE:
2108	RETVAL = env->mutex_set_max (env, max);	2145	RETVAL = env->mutex_set_max (env, max);
2109	OUTPUT:	2146	OUTPUT:
…		…
2125	CODE:	2162	CODE:
2126	RETVAL = env->mutex_set_align (env, align);	2163	RETVAL = env->mutex_set_align (env, align);
2127	OUTPUT:	2164	OUTPUT:
2128	RETVAL	2165	RETVAL
2129		2166
		2167	#endif
		2168
2130	DB_TXN *	2169	DB_TXN *
2131	txn_begin (DB_ENV env, DB_TXN_ornull parent = 0, U32 flags = 0)	2170	txn_begin (DB_ENV env, DB_TXN_ornull parent = 0, U32 flags = 0)
2132	CODE:	2171	CODE:
2133	errno = env->txn_begin (env, parent, &RETVAL, flags);	2172	errno = env->txn_begin (env, parent, &RETVAL, flags);
2134	if (errno)	2173	if (errno)
2135	croak ("DB_ENV->txn_begin: %s", db_strerror (errno));	2174	croak ("DB_ENV->txn_begin: %s", db_strerror (errno));
2136	OUTPUT:	2175	OUTPUT:
2137	RETVAL	2176	RETVAL
2138		2177
		2178	#if DB_VERSION_MINOR >= 5
		2179
2139	DB_TXN *	2180	DB_TXN *
2140	cdsgroup_begin (DB_ENV *env)	2181	cdsgroup_begin (DB_ENV *env)
2141	CODE:	2182	CODE:
2142	errno = env->cdsgroup_begin (env, &RETVAL);	2183	errno = env->cdsgroup_begin (env, &RETVAL);
2143	if (errno)	2184	if (errno)
2144	croak ("DB_ENV->cdsgroup_begin: %s", db_strerror (errno));	2185	croak ("DB_ENV->cdsgroup_begin: %s", db_strerror (errno));
2145	OUTPUT:	2186	OUTPUT:
2146	RETVAL	2187	RETVAL
		2188
		2189	#endif
2147		2190
2148	MODULE = BDB PACKAGE = BDB::Db	2191	MODULE = BDB PACKAGE = BDB::Db
2149		2192
2150	void	2193	void
2151	DESTROY (DB_ornuked *db)	2194	DESTROY (DB_ornuked *db)
…		…
2236	if (errno)	2279	if (errno)
2237	croak ("DB->cursor: %s", db_strerror (errno));	2280	croak ("DB->cursor: %s", db_strerror (errno));
2238	OUTPUT:	2281	OUTPUT:
2239	RETVAL	2282	RETVAL
2240		2283
		2284	#if DB_VERSION_MINOR >= 3
		2285
2241	DB_SEQUENCE *	2286	DB_SEQUENCE *
2242	sequence (DB *db, U32 flags = 0)	2287	sequence (DB *db, U32 flags = 0)
2243	CODE:	2288	CODE:
2244	{	2289	{
2245	errno = db_sequence_create (&RETVAL, db, flags);	2290	errno = db_sequence_create (&RETVAL, db, flags);
…		…
2247	croak ("db_sequence_create: %s", db_strerror (errno));	2292	croak ("db_sequence_create: %s", db_strerror (errno));
2248	}	2293	}
2249	OUTPUT:	2294	OUTPUT:
2250	RETVAL	2295	RETVAL
2251		2296
		2297	#endif
		2298
2252		2299
2253	MODULE = BDB PACKAGE = BDB::Txn	2300	MODULE = BDB PACKAGE = BDB::Txn
2254		2301
2255	void	2302	void
2256	DESTROY (DB_TXN_ornuked *txn)	2303	DESTROY (DB_TXN_ornuked *txn)
…		…
2285	CODE:	2332	CODE:
2286	dbc->set_priority (dbc, priority);	2333	dbc->set_priority (dbc, priority);
2287		2334
2288	#endif	2335	#endif
2289		2336
		2337	#if DB_VERSION_MINOR >= 3
		2338
2290	MODULE = BDB PACKAGE = BDB::Sequence	2339	MODULE = BDB PACKAGE = BDB::Sequence
2291		2340
2292	void	2341	void
2293	DESTROY (DB_SEQUENCE_ornuked *seq)	2342	DESTROY (DB_SEQUENCE_ornuked *seq)
2294	CODE:	2343	CODE:
…		…
2317	CODE:	2366	CODE:
2318	RETVAL = seq->set_range (seq, min, max);	2367	RETVAL = seq->set_range (seq, min, max);
2319	OUTPUT:	2368	OUTPUT:
2320	RETVAL	2369	RETVAL
2321		2370
		2371	#endif
2322		2372
		2373

Diff Legend

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

Comparing BDB/BDB.xs (file contents): Revision 1.45 by root, Wed Jul 9 21:08:29 2008 UTC vs. Revision 1.49 by root, Thu Sep 25 12:28:49 2008 UTC

Diff Legend

Comparing BDB/BDB.xs (file contents):
Revision 1.45 by root, Wed Jul 9 21:08:29 2008 UTC vs.
Revision 1.49 by root, Thu Sep 25 12:28:49 2008 UTC