← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/pbxt/src/restart_xt.cc

  • Committer: Stewart Smith
  • Date: 2010-06-16 14:17:58 UTC
  • mto: (1626.1.3 build)
  • mto: This revision was merged to the branch mainline in revision 1633.
  • Revision ID: stewart@flamingspork.com-20100616141758-odpf36m0wo09ok4c
add handler_write status variable test for when statement was rolled back

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/pbxt/src/restart_xt.cc
1
 
/* Copyright (C) 2007 PrimeBase Technologies GmbH
 
1
/* Copyright (c) 2007 PrimeBase Technologies GmbH
2
2
 *
3
3
 * PrimeBase XT
4
4
 *
14
14
 *
15
15
 * You should have received a copy of the GNU General Public License
16
16
 * along with this program; if not, write to the Free Software
17
 
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 
17
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18
18
 *
19
19
 * 2007-11-12   Paul McCullagh
20
20
 *
1736
1736
        return op_synced;
1737
1737
}
1738
1738
 
1739
 
#ifdef XT_CORRECT_TABLE_FREE_COUNT
1740
 
#define CORRECT_COUNT           TRUE
1741
 
#else
1742
 
#define CORRECT_COUNT           FALSE
1743
 
#endif
1744
 
#ifdef XT_CHECK_RECORD_FREE_COUNT
1745
 
#define CHECK_RECS                      TRUE
1746
 
#else
1747
 
#define CHECK_RECS                      FALSE
1748
 
#endif
1749
 
#if defined(XT_CHECK_RECORD_FREE_COUNT) || defined(XT_CHECK_ROW_FREE_COUNT)
1750
 
#define RECOVER_FREE_COUNTS
1751
 
#endif
1752
 
 
1753
 
#ifdef RECOVER_FREE_COUNTS
1754
 
/* {CORRECTED-ROW-COUNT}
1755
 
 * This error can be repeated by crashing the server during
1756
 
 * high activitity, after flush table writes the table header
1757
 
 * 
1758
 
 * On recovery, the free count "from the future" is used as
1759
 
 * the starting point for subsequent allocation and frees.
1760
 
 * The count is wrong after that point.
1761
 
 *
1762
 
 * The recovery of the count only works correctly if a
1763
 
 * checkpoint is complete successfully after that table
1764
 
 * header is flushed. Basically the writing of the table
1765
 
 * header should be synchronsized with the writing of the
1766
 
 * end of the checkpoint.
1767
 
 *
1768
 
 * Another solution would be to log the count, along with
1769
 
 * the allocate and free commannds.
1770
 
 *
1771
 
 * The 3rd solution is the one used here. The count is corrected
1772
 
 * after recovery.
1773
 
 */
1774
 
static void xres_recover_table_free_counts(XTThreadPtr self, XTDatabaseHPtr db, XTWriterStatePtr ws)
1775
 
{
1776
 
        u_int                   edx;
1777
 
        XTTableEntryPtr te_ptr;
1778
 
        XTTableHPtr             tab;
1779
 
 
1780
 
        xt_enum_tables_init(&edx);
1781
 
        while ((te_ptr = xt_enum_tables_next(self, db, &edx))) {
1782
 
                if ((tab = te_ptr->te_table)) {
1783
 
                        if (xres_open_table(self, ws, te_ptr->te_tab_id))
1784
 
                                xt_tab_check_free_lists(self, ws->ws_ot, CHECK_RECS, CORRECT_COUNT);
1785
 
                }
1786
 
        }
1787
 
}
1788
 
#endif
1789
 
 
1790
1739
/*
1791
1740
 * Operations from the log are applied in sequence order.
1792
1741
 * If the operations are out of sequence, they are buffered
2618
2567
                        /* This is true because if no transaction was placed in RAM then
2619
2568
                         * the next transaction in RAM will have the next ID: */
2620
2569
                        db->db_xn_min_ram_id = db->db_xn_curr_id + 1;
2621
 
 
2622
 
#ifdef RECOVER_FREE_COUNTS
2623
 
                if (xres_cp_log_id != *log_id || xres_cp_log_offset != *log_offset) {
2624
 
                        /* Recovery took place, correct the row count! */
2625
 
                        xres_recover_table_free_counts(self, db, &ws);
2626
 
                }
2627
 
#endif
2628
2570
        }
2629
2571
 
2630
2572
        failed: