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

Comparing BDB/BDB.xs (file contents):
Revision 1.47 by root, Fri Jul 18 22:39:10 2008 UTC vs.
Revision 1.50 by root, Thu Sep 25 13:22:32 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"
… …
130dbt_to_sv (SV *sv, DBT *dbt) 135dbt_to_sv (SV *sv, DBT *dbt)
131{ 136{
132 if (sv) 137 if (sv)
133 { 138 {
134 SvREADONLY_off (sv); 139 SvREADONLY_off (sv);
135 sv_setpvn_mg (sv, dbt->data, dbt->size); 140 sv_setsv_mg (sv, dbt->data ? newSVpvn (dbt->data, dbt->size) : &PL_sv_undef);
136 SvREFCNT_dec (sv); 141 SvREFCNT_dec (sv);
137 } 142 }
138 143
144 //assert (dbt->flags & DBT_MALLOC || !dbt->data);
139 free (dbt->data); 145 free (dbt->data);
140} 146}
141 147
142enum { 148enum {
143 REQ_QUIT, 149 REQ_QUIT,
… …
171 DB_KEY_RANGE key_range; 177 DB_KEY_RANGE key_range;
172#if DB_VERSION_MINOR >= 3 178#if DB_VERSION_MINOR >= 3
173 DB_SEQUENCE *seq; 179 DB_SEQUENCE *seq;
174 db_seq_t seq_t; 180 db_seq_t seq_t;
175#endif 181#endif
182
183 SV *rsv1, *rsv2; // keep some request objects alive
176} bdb_cb; 184} bdb_cb;
177 185
178typedef bdb_cb *bdb_req; 186typedef bdb_cb *bdb_req;
179 187
180enum { 188enum {
… …
419} 427}
420 428
421static void req_free (bdb_req req) 429static void req_free (bdb_req req)
422{ 430{
423 SvREFCNT_dec (req->callback); 431 SvREFCNT_dec (req->callback);
432
433 SvREFCNT_dec (req->rsv1);
434 SvREFCNT_dec (req->rsv2);
424 435
425 free (req->buf1); 436 free (req->buf1);
426 free (req->buf2); 437 free (req->buf2);
427 free (req->buf3); 438 free (req->buf3);
428 439
… …
524 on_next_submit = 0; 535 on_next_submit = 0;
525 536
526 PUSHMARK (SP); 537 PUSHMARK (SP);
527 PUTBACK; 538 PUTBACK;
528 call_sv (cb, G_DISCARD | G_EVAL); 539 call_sv (cb, G_DISCARD | G_EVAL);
540 SPAGAIN;
529 } 541 }
530 542
531 // synthesize callback if none given 543 // synthesize callback if none given
532 if (!req->callback) 544 if (!req->callback)
533 { 545 {
… …
541 553
542 if (count != 2) 554 if (count != 2)
543 croak ("prepare callback must return exactly two values\n"); 555 croak ("prepare callback must return exactly two values\n");
544 556
545 wait_callback = POPs; 557 wait_callback = POPs;
546 SvREFCNT_dec (req->callback);
547 req->callback = SvREFCNT_inc (POPs); 558 req->callback = SvREFCNT_inc (POPs);
548 } 559 }
549 560
550 ++nreqs; 561 ++nreqs;
551 562
… …
752 } 763 }
753 764
754 --nready; 765 --nready;
755 766
756 X_UNLOCK (reqlock); 767 X_UNLOCK (reqlock);
757 768
758 switch (req->type) 769 switch (req->type)
759 { 770 {
760 case REQ_QUIT: 771 case REQ_QUIT:
761 req->result = ENOSYS; 772 req->result = ENOSYS;
762 goto quit; 773 goto quit;
… …
981 create_respipe (); 992 create_respipe ();
982 993
983 atfork_parent (); 994 atfork_parent ();
984} 995}
985 996
986#define dREQ(reqtype) \ 997#define dREQ(reqtype,rsvcnt) \
987 bdb_req req; \ 998 bdb_req req; \
988 int req_pri = next_pri; \ 999 int req_pri = next_pri; \
989 next_pri = DEFAULT_PRI + PRI_BIAS; \ 1000 next_pri = DEFAULT_PRI + PRI_BIAS; \
990 \ 1001 \
991 if (callback && SvOK (callback)) \ 1002 if (callback && SvOK (callback)) \
… …
993 \ 1004 \
994 Newz (0, req, 1, bdb_cb); \ 1005 Newz (0, req, 1, bdb_cb); \
995 if (!req) \ 1006 if (!req) \
996 croak ("out of memory during bdb_req allocation"); \ 1007 croak ("out of memory during bdb_req allocation"); \
997 \ 1008 \
998 req->callback = cb ? SvREFCNT_inc (cb) : 0; \ 1009 req->callback = SvREFCNT_inc (cb); \
999 req->type = (reqtype); \ 1010 req->type = (reqtype); \
1000 req->pri = req_pri 1011 req->pri = req_pri; \
1012 if (rsvcnt >= 1) req->rsv1 = SvREFCNT_inc (ST (0)); \
1013 if (rsvcnt >= 2) req->rsv2 = SvREFCNT_inc (ST (1)); \
1014 (void)0;
1001 1015
1002#define REQ_SEND \ 1016#define REQ_SEND \
1003 req_send (req) 1017 req_send (req)
1004 1018
1005#define SvPTR(var, arg, type, class, nullok) \ 1019#define SvPTR(var, arg, type, class, nullok) \
… …
1494db_env_open (DB_ENV *env, bdb_filename db_home, U32 open_flags, int mode, SV *callback = 0) 1508db_env_open (DB_ENV *env, bdb_filename db_home, U32 open_flags, int mode, SV *callback = 0)
1495 PREINIT: 1509 PREINIT:
1496 CALLBACK 1510 CALLBACK
1497 CODE: 1511 CODE:
1498{ 1512{
1499 dREQ (REQ_ENV_OPEN); 1513 dREQ (REQ_ENV_OPEN, 1);
1500 req->env = env; 1514 req->env = env;
1501 req->uint1 = open_flags | DB_THREAD; 1515 req->uint1 = open_flags | DB_THREAD;
1502 req->int1 = mode; 1516 req->int1 = mode;
1503 req->buf1 = strdup_ornull (db_home); 1517 req->buf1 = strdup_ornull (db_home);
1504 REQ_SEND; 1518 REQ_SEND;
… …
1508db_env_close (DB_ENV *env, U32 flags = 0, SV *callback = 0) 1522db_env_close (DB_ENV *env, U32 flags = 0, SV *callback = 0)
1509 PREINIT: 1523 PREINIT:
1510 CALLBACK 1524 CALLBACK
1511 CODE: 1525 CODE:
1512{ 1526{
1513 dREQ (REQ_ENV_CLOSE); 1527 dREQ (REQ_ENV_CLOSE, 1);
1514 req->env = env; 1528 req->env = env;
1515 req->uint1 = flags; 1529 req->uint1 = flags;
1516 REQ_SEND; 1530 REQ_SEND;
1517 ptr_nuke (ST (0)); 1531 ptr_nuke (ST (0));
1518} 1532}
… …
1521db_env_txn_checkpoint (DB_ENV *env, U32 kbyte = 0, U32 min = 0, U32 flags = 0, SV *callback = 0) 1535db_env_txn_checkpoint (DB_ENV *env, U32 kbyte = 0, U32 min = 0, U32 flags = 0, SV *callback = 0)
1522 PREINIT: 1536 PREINIT:
1523 CALLBACK 1537 CALLBACK
1524 CODE: 1538 CODE:
1525{ 1539{
1526 dREQ (REQ_ENV_TXN_CHECKPOINT); 1540 dREQ (REQ_ENV_TXN_CHECKPOINT, 1);
1527 req->env = env; 1541 req->env = env;
1528 req->uint1 = kbyte; 1542 req->uint1 = kbyte;
1529 req->int1 = min; 1543 req->int1 = min;
1530 req->uint2 = flags; 1544 req->uint2 = flags;
1531 REQ_SEND; 1545 REQ_SEND;
… …
1535db_env_lock_detect (DB_ENV *env, U32 flags = 0, U32 atype = DB_LOCK_DEFAULT, SV *dummy = 0, SV *callback = 0) 1549db_env_lock_detect (DB_ENV *env, U32 flags = 0, U32 atype = DB_LOCK_DEFAULT, SV *dummy = 0, SV *callback = 0)
1536 PREINIT: 1550 PREINIT:
1537 CALLBACK 1551 CALLBACK
1538 CODE: 1552 CODE:
1539{ 1553{
1540 dREQ (REQ_ENV_LOCK_DETECT); 1554 dREQ (REQ_ENV_LOCK_DETECT, 1);
1541 req->env = env; 1555 req->env = env;
1542 req->uint1 = flags; 1556 req->uint1 = flags;
1543 req->uint2 = atype; 1557 req->uint2 = atype;
1544 /* req->int2 = 0; dummy */ 1558 /* req->int2 = 0; dummy */
1545 REQ_SEND; 1559 REQ_SEND;
… …
1549db_env_memp_sync (DB_ENV *env, SV *dummy = 0, SV *callback = 0) 1563db_env_memp_sync (DB_ENV *env, SV *dummy = 0, SV *callback = 0)
1550 PREINIT: 1564 PREINIT:
1551 CALLBACK 1565 CALLBACK
1552 CODE: 1566 CODE:
1553{ 1567{
1554 dREQ (REQ_ENV_MEMP_SYNC); 1568 dREQ (REQ_ENV_MEMP_SYNC, 1);
1555 req->env = env; 1569 req->env = env;
1556 REQ_SEND; 1570 REQ_SEND;
1557} 1571}
1558 1572
1559void 1573void
1560db_env_memp_trickle (DB_ENV *env, int percent, SV *dummy = 0, SV *callback = 0) 1574db_env_memp_trickle (DB_ENV *env, int percent, SV *dummy = 0, SV *callback = 0)
1561 PREINIT: 1575 PREINIT:
1562 CALLBACK 1576 CALLBACK
1563 CODE: 1577 CODE:
1564{ 1578{
1565 dREQ (REQ_ENV_MEMP_TRICKLE); 1579 dREQ (REQ_ENV_MEMP_TRICKLE, 1);
1566 req->env = env; 1580 req->env = env;
1567 req->int1 = percent; 1581 req->int1 = percent;
1568 REQ_SEND; 1582 REQ_SEND;
1569} 1583}
1570 1584
… …
1572db_env_dbremove (DB_ENV *env, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, U32 flags = 0, SV *callback = 0) 1586db_env_dbremove (DB_ENV *env, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, U32 flags = 0, SV *callback = 0)
1573 PREINIT: 1587 PREINIT:
1574 CALLBACK 1588 CALLBACK
1575 CODE: 1589 CODE:
1576{ 1590{
1577 dREQ (REQ_ENV_DBREMOVE); 1591 dREQ (REQ_ENV_DBREMOVE, 2);
1578 req->env = env; 1592 req->env = env;
1579 req->buf1 = strdup_ornull (file); 1593 req->buf1 = strdup_ornull (file);
1580 req->buf2 = strdup_ornull (database); 1594 req->buf2 = strdup_ornull (database);
1581 req->uint1 = flags; 1595 req->uint1 = flags;
1582 REQ_SEND; 1596 REQ_SEND;
… …
1586db_env_dbrename (DB_ENV *env, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, bdb_filename newname, U32 flags = 0, SV *callback = 0) 1600db_env_dbrename (DB_ENV *env, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, bdb_filename newname, U32 flags = 0, SV *callback = 0)
1587 PREINIT: 1601 PREINIT:
1588 CALLBACK 1602 CALLBACK
1589 CODE: 1603 CODE:
1590{ 1604{
1591 dREQ (REQ_ENV_DBRENAME); 1605 dREQ (REQ_ENV_DBRENAME, 2);
1592 req->env = env; 1606 req->env = env;
1593 req->buf1 = strdup_ornull (file); 1607 req->buf1 = strdup_ornull (file);
1594 req->buf2 = strdup_ornull (database); 1608 req->buf2 = strdup_ornull (database);
1595 req->buf3 = strdup_ornull (newname); 1609 req->buf3 = strdup_ornull (newname);
1596 req->uint1 = flags; 1610 req->uint1 = flags;
… …
1615db_open (DB *db, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, int type, U32 flags, int mode, SV *callback = 0) 1629db_open (DB *db, DB_TXN_ornull *txnid, bdb_filename file, bdb_filename database, int type, U32 flags, int mode, SV *callback = 0)
1616 PREINIT: 1630 PREINIT:
1617 CALLBACK 1631 CALLBACK
1618 CODE: 1632 CODE:
1619{ 1633{
1620 dREQ (REQ_DB_OPEN); 1634 dREQ (REQ_DB_OPEN, 2);
1621 req->db = db; 1635 req->db = db;
1622 req->txn = txnid; 1636 req->txn = txnid;
1623 req->buf1 = strdup_ornull (file); 1637 req->buf1 = strdup_ornull (file);
1624 req->buf2 = strdup_ornull (database); 1638 req->buf2 = strdup_ornull (database);
1625 req->int1 = type; 1639 req->int1 = type;
… …
1632db_close (DB *db, U32 flags = 0, SV *callback = 0) 1646db_close (DB *db, U32 flags = 0, SV *callback = 0)
1633 PREINIT: 1647 PREINIT:
1634 CALLBACK 1648 CALLBACK
1635 CODE: 1649 CODE:
1636{ 1650{
1637 dREQ (REQ_DB_CLOSE); 1651 dREQ (REQ_DB_CLOSE, 1);
1638 req->db = db; 1652 req->db = db;
1639 req->uint1 = flags; 1653 req->uint1 = flags;
1640 req->sv1 = (SV *)db->app_private; 1654 req->sv1 = (SV *)db->app_private;
1641 REQ_SEND; 1655 REQ_SEND;
1642 ptr_nuke (ST (0)); 1656 ptr_nuke (ST (0));
… …
1648db_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) 1662db_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)
1649 PREINIT: 1663 PREINIT:
1650 CALLBACK 1664 CALLBACK
1651 CODE: 1665 CODE:
1652{ 1666{
1653 dREQ (REQ_DB_COMPACT); 1667 dREQ (REQ_DB_COMPACT, 2);
1654 req->db = db; 1668 req->db = db;
1655 req->txn = txn; 1669 req->txn = txn;
1656 sv_to_dbt (&req->dbt1, start); 1670 sv_to_dbt (&req->dbt1, start);
1657 sv_to_dbt (&req->dbt2, stop); 1671 sv_to_dbt (&req->dbt2, stop);
1658 req->uint1 = flags; 1672 req->uint1 = flags;
… …
1665db_sync (DB *db, U32 flags = 0, SV *callback = 0) 1679db_sync (DB *db, U32 flags = 0, SV *callback = 0)
1666 PREINIT: 1680 PREINIT:
1667 CALLBACK 1681 CALLBACK
1668 CODE: 1682 CODE:
1669{ 1683{
1670 dREQ (REQ_DB_SYNC); 1684 dREQ (REQ_DB_SYNC, 1);
1671 req->db = db; 1685 req->db = db;
1672 req->uint1 = flags; 1686 req->uint1 = flags;
1673 REQ_SEND; 1687 REQ_SEND;
1674} 1688}
1675 1689
… …
1677db_upgrade (DB *db, bdb_filename file, U32 flags = 0, SV *callback = 0) 1691db_upgrade (DB *db, bdb_filename file, U32 flags = 0, SV *callback = 0)
1678 PREINIT: 1692 PREINIT:
1679 CALLBACK 1693 CALLBACK
1680 CODE: 1694 CODE:
1681{ 1695{
1682 dREQ (REQ_DB_SYNC); 1696 dREQ (REQ_DB_SYNC, 1);
1683 req->db = db; 1697 req->db = db;
1684 req->buf1 = strdup (file); 1698 req->buf1 = strdup (file);
1685 req->uint1 = flags; 1699 req->uint1 = flags;
1686 REQ_SEND; 1700 REQ_SEND;
1687} 1701}
… …
1690db_key_range (DB *db, DB_TXN_ornull *txn, SV *key, SV *key_range, U32 flags = 0, SV *callback = 0) 1704db_key_range (DB *db, DB_TXN_ornull *txn, SV *key, SV *key_range, U32 flags = 0, SV *callback = 0)
1691 PREINIT: 1705 PREINIT:
1692 CALLBACK 1706 CALLBACK
1693 CODE: 1707 CODE:
1694{ 1708{
1695 dREQ (REQ_DB_KEY_RANGE); 1709 dREQ (REQ_DB_KEY_RANGE, 2);
1696 req->db = db; 1710 req->db = db;
1697 req->txn = txn; 1711 req->txn = txn;
1698 sv_to_dbt (&req->dbt1, key); 1712 sv_to_dbt (&req->dbt1, key);
1699 req->uint1 = flags; 1713 req->uint1 = flags;
1700 req->sv1 = SvREFCNT_inc (key_range); SvREADONLY_on (key_range); 1714 req->sv1 = SvREFCNT_inc (key_range); SvREADONLY_on (key_range);
… …
1705db_put (DB *db, DB_TXN_ornull *txn, SV *key, SV *data, U32 flags = 0, SV *callback = 0) 1719db_put (DB *db, DB_TXN_ornull *txn, SV *key, SV *data, U32 flags = 0, SV *callback = 0)
1706 PREINIT: 1720 PREINIT:
1707 CALLBACK 1721 CALLBACK
1708 CODE: 1722 CODE:
1709{ 1723{
1710 dREQ (REQ_DB_PUT); 1724 dREQ (REQ_DB_PUT, 2);
1711 req->db = db; 1725 req->db = db;
1712 req->txn = txn; 1726 req->txn = txn;
1713 sv_to_dbt (&req->dbt1, key); 1727 sv_to_dbt (&req->dbt1, key);
1714 sv_to_dbt (&req->dbt2, data); 1728 sv_to_dbt (&req->dbt2, data);
1715 req->uint1 = flags; 1729 req->uint1 = flags;
… …
1722db_exists (DB *db, DB_TXN_ornull *txn, SV *key, U32 flags = 0, SV *callback = 0) 1736db_exists (DB *db, DB_TXN_ornull *txn, SV *key, U32 flags = 0, SV *callback = 0)
1723 PREINIT: 1737 PREINIT:
1724 CALLBACK 1738 CALLBACK
1725 CODE: 1739 CODE:
1726{ 1740{
1727 dREQ (REQ_DB_EXISTS); 1741 dREQ (REQ_DB_EXISTS, 2);
1728 req->db = db; 1742 req->db = db;
1729 req->txn = txn; 1743 req->txn = txn;
1730 req->uint1 = flags; 1744 req->uint1 = flags;
1731 sv_to_dbt (&req->dbt1, key); 1745 sv_to_dbt (&req->dbt1, key);
1732 REQ_SEND; 1746 REQ_SEND;
… …
1740 CALLBACK 1754 CALLBACK
1741 CODE: 1755 CODE:
1742 if (SvREADONLY (data)) 1756 if (SvREADONLY (data))
1743 croak ("can't modify read-only data scalar in db_get"); 1757 croak ("can't modify read-only data scalar in db_get");
1744{ 1758{
1745 dREQ (REQ_DB_GET); 1759 dREQ (REQ_DB_GET, 2);
1746 req->db = db; 1760 req->db = db;
1747 req->txn = txn; 1761 req->txn = txn;
1748 req->uint1 = flags; 1762 req->uint1 = flags;
1749 sv_to_dbt (&req->dbt1, key); 1763 sv_to_dbt (&req->dbt1, key);
1750 req->dbt3.flags = DB_DBT_MALLOC; 1764 req->dbt3.flags = DB_DBT_MALLOC;
… …
1758 CALLBACK 1772 CALLBACK
1759 CODE: 1773 CODE:
1760 if (SvREADONLY (data)) 1774 if (SvREADONLY (data))
1761 croak ("can't modify read-only data scalar in db_pget"); 1775 croak ("can't modify read-only data scalar in db_pget");
1762{ 1776{
1763 dREQ (REQ_DB_PGET); 1777 dREQ (REQ_DB_PGET, 2);
1764 req->db = db; 1778 req->db = db;
1765 req->txn = txn; 1779 req->txn = txn;
1766 req->uint1 = flags; 1780 req->uint1 = flags;
1767 sv_to_dbt (&req->dbt1, key); 1781 sv_to_dbt (&req->dbt1, key);
1768 sv_to_dbt (&req->dbt2, pkey); 1782 sv_to_dbt (&req->dbt2, pkey);
… …
1775db_del (DB *db, DB_TXN_ornull *txn, SV *key, U32 flags = 0, SV *callback = 0) 1789db_del (DB *db, DB_TXN_ornull *txn, SV *key, U32 flags = 0, SV *callback = 0)
1776 PREINIT: 1790 PREINIT:
1777 CALLBACK 1791 CALLBACK
1778 CODE: 1792 CODE:
1779{ 1793{
1780 dREQ (REQ_DB_DEL); 1794 dREQ (REQ_DB_DEL, 2);
1781 req->db = db; 1795 req->db = db;
1782 req->txn = txn; 1796 req->txn = txn;
1783 req->uint1 = flags; 1797 req->uint1 = flags;
1784 sv_to_dbt (&req->dbt1, key); 1798 sv_to_dbt (&req->dbt1, key);
1785 REQ_SEND; 1799 REQ_SEND;
… …
1789db_txn_commit (DB_TXN *txn, U32 flags = 0, SV *callback = 0) 1803db_txn_commit (DB_TXN *txn, U32 flags = 0, SV *callback = 0)
1790 PREINIT: 1804 PREINIT:
1791 CALLBACK 1805 CALLBACK
1792 CODE: 1806 CODE:
1793{ 1807{
1794 dREQ (REQ_TXN_COMMIT); 1808 dREQ (REQ_TXN_COMMIT, 1);
1795 req->txn = txn; 1809 req->txn = txn;
1796 req->uint1 = flags; 1810 req->uint1 = flags;
1797 REQ_SEND; 1811 REQ_SEND;
1798 ptr_nuke (ST (0)); 1812 ptr_nuke (ST (0));
1799} 1813}
… …
1802db_txn_abort (DB_TXN *txn, SV *callback = 0) 1816db_txn_abort (DB_TXN *txn, SV *callback = 0)
1803 PREINIT: 1817 PREINIT:
1804 CALLBACK 1818 CALLBACK
1805 CODE: 1819 CODE:
1806{ 1820{
1807 dREQ (REQ_TXN_ABORT); 1821 dREQ (REQ_TXN_ABORT, 1);
1808 req->txn = txn; 1822 req->txn = txn;
1809 REQ_SEND; 1823 REQ_SEND;
1810 ptr_nuke (ST (0)); 1824 ptr_nuke (ST (0));
1811} 1825}
1812 1826
… …
1814db_txn_finish (DB_TXN *txn, U32 flags = 0, SV *callback = 0) 1828db_txn_finish (DB_TXN *txn, U32 flags = 0, SV *callback = 0)
1815 PREINIT: 1829 PREINIT:
1816 CALLBACK 1830 CALLBACK
1817 CODE: 1831 CODE:
1818{ 1832{
1819 dREQ (REQ_TXN_FINISH); 1833 dREQ (REQ_TXN_FINISH, 1);
1820 req->txn = txn; 1834 req->txn = txn;
1821 req->uint1 = flags; 1835 req->uint1 = flags;
1822 REQ_SEND; 1836 REQ_SEND;
1823 ptr_nuke (ST (0)); 1837 ptr_nuke (ST (0));
1824} 1838}
… …
1827db_c_close (DBC *dbc, SV *callback = 0) 1841db_c_close (DBC *dbc, SV *callback = 0)
1828 PREINIT: 1842 PREINIT:
1829 CALLBACK 1843 CALLBACK
1830 CODE: 1844 CODE:
1831{ 1845{
1832 dREQ (REQ_C_CLOSE); 1846 dREQ (REQ_C_CLOSE, 1);
1833 req->dbc = dbc; 1847 req->dbc = dbc;
1834 REQ_SEND; 1848 REQ_SEND;
1835 ptr_nuke (ST (0)); 1849 ptr_nuke (ST (0));
1836} 1850}
1837 1851
… …
1839db_c_count (DBC *dbc, SV *count, U32 flags = 0, SV *callback = 0) 1853db_c_count (DBC *dbc, SV *count, U32 flags = 0, SV *callback = 0)
1840 PREINIT: 1854 PREINIT:
1841 CALLBACK 1855 CALLBACK
1842 CODE: 1856 CODE:
1843{ 1857{
1844 dREQ (REQ_C_COUNT); 1858 dREQ (REQ_C_COUNT, 1);
1845 req->dbc = dbc; 1859 req->dbc = dbc;
1846 req->sv1 = SvREFCNT_inc (count); 1860 req->sv1 = SvREFCNT_inc (count);
1847 REQ_SEND; 1861 REQ_SEND;
1848} 1862}
1849 1863
… …
1851db_c_put (DBC *dbc, SV *key, SV *data, U32 flags = 0, SV *callback = 0) 1865db_c_put (DBC *dbc, SV *key, SV *data, U32 flags = 0, SV *callback = 0)
1852 PREINIT: 1866 PREINIT:
1853 CALLBACK 1867 CALLBACK
1854 CODE: 1868 CODE:
1855{ 1869{
1856 dREQ (REQ_C_PUT); 1870 dREQ (REQ_C_PUT, 1);
1857 req->dbc = dbc; 1871 req->dbc = dbc;
1858 sv_to_dbt (&req->dbt1, key); 1872 sv_to_dbt (&req->dbt1, key);
1859 sv_to_dbt (&req->dbt2, data); 1873 sv_to_dbt (&req->dbt2, data);
1860 req->uint1 = flags; 1874 req->uint1 = flags;
1861 REQ_SEND; 1875 REQ_SEND;
… …
1865db_c_get (DBC *dbc, SV *key, SV *data, U32 flags = 0, SV *callback = 0) 1879db_c_get (DBC *dbc, SV *key, SV *data, U32 flags = 0, SV *callback = 0)
1866 PREINIT: 1880 PREINIT:
1867 CALLBACK 1881 CALLBACK
1868 CODE: 1882 CODE:
1869{ 1883{
1870 dREQ (REQ_C_GET); 1884 dREQ (REQ_C_GET, 1);
1871 req->dbc = dbc; 1885 req->dbc = dbc;
1872 req->uint1 = flags; 1886 req->uint1 = flags;
1873 if ((flags & DB_SET) == DB_SET 1887 if ((flags & DB_SET) == DB_SET
1874 || (flags & DB_SET_RANGE) == DB_SET_RANGE) 1888 || (flags & DB_SET_RANGE) == DB_SET_RANGE)
1875 sv_to_dbt (&req->dbt1, key); 1889 sv_to_dbt (&req->dbt1, key);
… …
1892db_c_pget (DBC *dbc, SV *key, SV *pkey, SV *data, U32 flags = 0, SV *callback = 0) 1906db_c_pget (DBC *dbc, SV *key, SV *pkey, SV *data, U32 flags = 0, SV *callback = 0)
1893 PREINIT: 1907 PREINIT:
1894 CALLBACK 1908 CALLBACK
1895 CODE: 1909 CODE:
1896{ 1910{
1897 dREQ (REQ_C_PGET); 1911 dREQ (REQ_C_PGET, 1);
1898 req->dbc = dbc; 1912 req->dbc = dbc;
1899 req->uint1 = flags; 1913 req->uint1 = flags;
1900 if ((flags & DB_SET) == DB_SET 1914 if ((flags & DB_SET) == DB_SET
1901 || (flags & DB_SET_RANGE) == DB_SET_RANGE) 1915 || (flags & DB_SET_RANGE) == DB_SET_RANGE)
1902 sv_to_dbt (&req->dbt1, key); 1916 sv_to_dbt (&req->dbt1, key);
… …
1922db_c_del (DBC *dbc, U32 flags = 0, SV *callback = 0) 1936db_c_del (DBC *dbc, U32 flags = 0, SV *callback = 0)
1923 PREINIT: 1937 PREINIT:
1924 CALLBACK 1938 CALLBACK
1925 CODE: 1939 CODE:
1926{ 1940{
1927 dREQ (REQ_C_DEL); 1941 dREQ (REQ_C_DEL, 1);
1928 req->dbc = dbc; 1942 req->dbc = dbc;
1929 req->uint1 = flags; 1943 req->uint1 = flags;
1930 REQ_SEND; 1944 REQ_SEND;
1931} 1945}
1932 1946
… …
1937db_sequence_open (DB_SEQUENCE *seq, DB_TXN_ornull *txnid, SV *key, U32 flags = 0, SV *callback = 0) 1951db_sequence_open (DB_SEQUENCE *seq, DB_TXN_ornull *txnid, SV *key, U32 flags = 0, SV *callback = 0)
1938 PREINIT: 1952 PREINIT:
1939 CALLBACK 1953 CALLBACK
1940 CODE: 1954 CODE:
1941{ 1955{
1942 dREQ (REQ_SEQ_OPEN); 1956 dREQ (REQ_SEQ_OPEN, 2);
1943 req->seq = seq; 1957 req->seq = seq;
1944 req->txn = txnid; 1958 req->txn = txnid;
1945 req->uint1 = flags | DB_THREAD; 1959 req->uint1 = flags | DB_THREAD;
1946 sv_to_dbt (&req->dbt1, key); 1960 sv_to_dbt (&req->dbt1, key);
1947 REQ_SEND; 1961 REQ_SEND;
… …
1951db_sequence_close (DB_SEQUENCE *seq, U32 flags = 0, SV *callback = 0) 1965db_sequence_close (DB_SEQUENCE *seq, U32 flags = 0, SV *callback = 0)
1952 PREINIT: 1966 PREINIT:
1953 CALLBACK 1967 CALLBACK
1954 CODE: 1968 CODE:
1955{ 1969{
1956 dREQ (REQ_SEQ_CLOSE); 1970 dREQ (REQ_SEQ_CLOSE, 1);
1957 req->seq = seq; 1971 req->seq = seq;
1958 req->uint1 = flags; 1972 req->uint1 = flags;
1959 REQ_SEND; 1973 REQ_SEND;
1960 ptr_nuke (ST (0)); 1974 ptr_nuke (ST (0));
1961} 1975}
… …
1964db_sequence_get (DB_SEQUENCE *seq, DB_TXN_ornull *txnid, int delta, SV *seq_value, U32 flags = DB_TXN_NOSYNC, SV *callback = 0) 1978db_sequence_get (DB_SEQUENCE *seq, DB_TXN_ornull *txnid, int delta, SV *seq_value, U32 flags = DB_TXN_NOSYNC, SV *callback = 0)
1965 PREINIT: 1979 PREINIT:
1966 CALLBACK 1980 CALLBACK
1967 CODE: 1981 CODE:
1968{ 1982{
1969 dREQ (REQ_SEQ_GET); 1983 dREQ (REQ_SEQ_GET, 2);
1970 req->seq = seq; 1984 req->seq = seq;
1971 req->txn = txnid; 1985 req->txn = txnid;
1972 req->int1 = delta; 1986 req->int1 = delta;
1973 req->uint1 = flags; 1987 req->uint1 = flags;
1974 req->sv1 = SvREFCNT_inc (seq_value); SvREADONLY_on (seq_value); 1988 req->sv1 = SvREFCNT_inc (seq_value); SvREADONLY_on (seq_value);
… …
1979db_sequence_remove (DB_SEQUENCE *seq, DB_TXN_ornull *txnid = 0, U32 flags = 0, SV *callback = 0) 1993db_sequence_remove (DB_SEQUENCE *seq, DB_TXN_ornull *txnid = 0, U32 flags = 0, SV *callback = 0)
1980 PREINIT: 1994 PREINIT:
1981 CALLBACK 1995 CALLBACK
1982 CODE: 1996 CODE:
1983{ 1997{
1984 dREQ (REQ_SEQ_REMOVE); 1998 dREQ (REQ_SEQ_REMOVE, 2);
1985 req->seq = seq; 1999 req->seq = seq;
1986 req->txn = txnid; 2000 req->txn = txnid;
1987 req->uint1 = flags; 2001 req->uint1 = flags;
1988 REQ_SEND; 2002 REQ_SEND;
1989} 2003}

Diff Legend

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