← Back to branch summary

~ubuntu-branches/ubuntu/quantal/drizzle/quantal

« back to all changes in this revision

Viewing changes to plugin/innobase/trx/trx0sys.cc

  • Committer: Bazaar Package Importer
  • Author(s): Monty Taylor
  • Date: 2011-02-14 12:40:34 UTC
  • mfrom: (1.2.8 upstream)
  • Revision ID: james.westby@ubuntu.com-20110214124034-eih75vcr64qt4db1
Tags: 2011.02.10-0ubuntu1
* New upstream release.
* Incorporated all patches upstream.
* Added unix-socket-protocol package. Disabled it by default.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/innobase/trx/trx0sys.cc
90
90
UNIV_INTERN char        trx_sys_mysql_bin_log_name[TRX_SYS_MYSQL_LOG_NAME_LEN];
91
91
/** Binlog file position, or -1 if unknown */
92
92
UNIV_INTERN ib_int64_t  trx_sys_mysql_bin_log_pos       = -1;
 
93
 
 
94
UNIV_INTERN drizzled::atomic<uint64_t> trx_sys_commit_id;
 
95
 
93
96
/* @} */
94
97
#endif /* !UNIV_HOTBACKUP */
95
98
 
674
677
        mtr_commit(&mtr);
675
678
}
676
679
 
677
 
/*****************************************************************//**
678
 
Updates the offset information about the end of the MySQL binlog entry
679
 
which corresponds to the transaction just being committed. In a MySQL
680
 
replication slave updates the latest master binlog position up to which
681
 
replication has proceeded. */
682
680
UNIV_INTERN
683
681
void
684
 
trx_sys_update_mysql_binlog_offset(
685
 
/*===============================*/
686
 
        const char*     file_name,/*!< in: MySQL log file name */
687
 
        ib_int64_t      offset, /*!< in: position in that log file */
688
 
        ulint           field,  /*!< in: offset of the MySQL log info field in
689
 
                                the trx sys header */
690
 
        mtr_t*          mtr)    /*!< in: mtr */
 
682
trx_sys_flush_commit_id(uint64_t commit_id, ulint field, mtr_t* mtr)
691
683
{
692
 
        trx_sysf_t*     sys_header;
693
 
 
694
 
        if (ut_strlen(file_name) >= TRX_SYS_MYSQL_LOG_NAME_LEN) {
695
 
 
696
 
                /* We cannot fit the name to the 512 bytes we have reserved */
697
 
 
698
 
                return;
699
 
        }
700
 
 
 
684
        trx_sysf_t*     sys_header;
 
685
  
701
686
        sys_header = trx_sysf_get(mtr);
702
687
 
703
 
        if (mach_read_from_4(sys_header + field
704
 
                             + TRX_SYS_MYSQL_LOG_MAGIC_N_FLD)
705
 
            != TRX_SYS_MYSQL_LOG_MAGIC_N) {
706
 
 
707
 
                mlog_write_ulint(sys_header + field
708
 
                                 + TRX_SYS_MYSQL_LOG_MAGIC_N_FLD,
709
 
                                 TRX_SYS_MYSQL_LOG_MAGIC_N,
710
 
                                 MLOG_4BYTES, mtr);
711
 
        }
712
 
 
713
 
        if (0 != strcmp((char*) (sys_header + field + TRX_SYS_MYSQL_LOG_NAME),
714
 
                        file_name)) {
715
 
 
716
 
                mlog_write_string(sys_header + field
717
 
                                  + TRX_SYS_MYSQL_LOG_NAME,
718
 
                                  (byte*) file_name, 1 + ut_strlen(file_name),
719
 
                                  mtr);
720
 
        }
721
 
 
722
 
        if (mach_read_from_4(sys_header + field
723
 
                             + TRX_SYS_MYSQL_LOG_OFFSET_HIGH) > 0
724
 
            || (offset >> 32) > 0) {
725
 
 
726
 
                mlog_write_ulint(sys_header + field
727
 
                                 + TRX_SYS_MYSQL_LOG_OFFSET_HIGH,
728
 
                                 (ulint)(offset >> 32),
729
 
                                 MLOG_4BYTES, mtr);
730
 
        }
731
 
 
732
 
        mlog_write_ulint(sys_header + field
733
 
                         + TRX_SYS_MYSQL_LOG_OFFSET_LOW,
734
 
                         (ulint)(offset & 0xFFFFFFFFUL),
735
 
                         MLOG_4BYTES, mtr);
 
688
        mlog_write_ull(sys_header + field + TRX_SYS_DRIZZLE_MAX_COMMIT_ID, 
 
689
                       commit_id, mtr);
736
690
}
737
691
 
738
 
/*****************************************************************//**
739
 
Stores the MySQL binlog offset info in the trx system header if
740
 
the magic number shows it valid, and print the info to stderr */
 
692
 
741
693
UNIV_INTERN
742
694
void
743
 
trx_sys_print_mysql_binlog_offset(void)
 
695
trx_sys_read_commit_id(void)
744
696
/*===================================*/
745
697
{
746
 
        trx_sysf_t*     sys_header;
747
 
        mtr_t           mtr;
748
 
        ulint           trx_sys_mysql_bin_log_pos_high;
749
 
        ulint           trx_sys_mysql_bin_log_pos_low;
750
 
 
751
 
        mtr_start(&mtr);
752
 
 
753
 
        sys_header = trx_sysf_get(&mtr);
754
 
 
755
 
        if (mach_read_from_4(sys_header + TRX_SYS_MYSQL_LOG_INFO
756
 
                             + TRX_SYS_MYSQL_LOG_MAGIC_N_FLD)
757
 
            != TRX_SYS_MYSQL_LOG_MAGIC_N) {
758
 
 
759
 
                mtr_commit(&mtr);
760
 
 
761
 
                return;
762
 
        }
763
 
 
764
 
        trx_sys_mysql_bin_log_pos_high = mach_read_from_4(
765
 
                sys_header + TRX_SYS_MYSQL_LOG_INFO
766
 
                + TRX_SYS_MYSQL_LOG_OFFSET_HIGH);
767
 
        trx_sys_mysql_bin_log_pos_low = mach_read_from_4(
768
 
                sys_header + TRX_SYS_MYSQL_LOG_INFO
769
 
                + TRX_SYS_MYSQL_LOG_OFFSET_LOW);
770
 
 
771
 
        trx_sys_mysql_bin_log_pos
772
 
                = (((ib_int64_t)trx_sys_mysql_bin_log_pos_high) << 32)
773
 
                + (ib_int64_t)trx_sys_mysql_bin_log_pos_low;
774
 
 
775
 
        ut_memcpy(trx_sys_mysql_bin_log_name,
776
 
                  sys_header + TRX_SYS_MYSQL_LOG_INFO
777
 
                  + TRX_SYS_MYSQL_LOG_NAME, TRX_SYS_MYSQL_LOG_NAME_LEN);
778
 
 
779
 
        fprintf(stderr,
780
 
                "InnoDB: Last MySQL binlog file position %lu %lu,"
781
 
                " file name %s\n",
782
 
                trx_sys_mysql_bin_log_pos_high, trx_sys_mysql_bin_log_pos_low,
783
 
                trx_sys_mysql_bin_log_name);
784
 
 
785
 
        mtr_commit(&mtr);
786
 
}
787
 
 
788
 
/*****************************************************************//**
789
 
Prints to stderr the MySQL master log offset info in the trx system header if
790
 
the magic number shows it valid. */
791
 
UNIV_INTERN
792
 
void
793
 
trx_sys_print_mysql_master_log_pos(void)
794
 
/*====================================*/
795
 
{
796
 
        trx_sysf_t*     sys_header;
797
 
        mtr_t           mtr;
798
 
 
799
 
        mtr_start(&mtr);
800
 
 
801
 
        sys_header = trx_sysf_get(&mtr);
802
 
 
803
 
        if (mach_read_from_4(sys_header + TRX_SYS_MYSQL_MASTER_LOG_INFO
804
 
                             + TRX_SYS_MYSQL_LOG_MAGIC_N_FLD)
805
 
            != TRX_SYS_MYSQL_LOG_MAGIC_N) {
806
 
 
807
 
                mtr_commit(&mtr);
808
 
 
809
 
                return;
810
 
        }
811
 
 
812
 
        fprintf(stderr,
813
 
                "InnoDB: In a MySQL replication slave the last"
814
 
                " master binlog file\n"
815
 
                "InnoDB: position %lu %lu, file name %s\n",
816
 
                (ulong) mach_read_from_4(sys_header
817
 
                                         + TRX_SYS_MYSQL_MASTER_LOG_INFO
818
 
                                         + TRX_SYS_MYSQL_LOG_OFFSET_HIGH),
819
 
                (ulong) mach_read_from_4(sys_header
820
 
                                         + TRX_SYS_MYSQL_MASTER_LOG_INFO
821
 
                                         + TRX_SYS_MYSQL_LOG_OFFSET_LOW),
822
 
                sys_header + TRX_SYS_MYSQL_MASTER_LOG_INFO
823
 
                + TRX_SYS_MYSQL_LOG_NAME);
824
 
        /* Copy the master log position info to global variables we can
825
 
        use in ha_innobase.cc to initialize glob_mi to right values */
826
 
 
827
 
        ut_memcpy(trx_sys_mysql_master_log_name,
828
 
                  sys_header + TRX_SYS_MYSQL_MASTER_LOG_INFO
829
 
                  + TRX_SYS_MYSQL_LOG_NAME,
830
 
                  TRX_SYS_MYSQL_LOG_NAME_LEN);
831
 
 
832
 
        trx_sys_mysql_master_log_pos
833
 
                = (((ib_int64_t) mach_read_from_4(
834
 
                            sys_header + TRX_SYS_MYSQL_MASTER_LOG_INFO
835
 
                            + TRX_SYS_MYSQL_LOG_OFFSET_HIGH)) << 32)
836
 
                + ((ib_int64_t) mach_read_from_4(
837
 
                           sys_header + TRX_SYS_MYSQL_MASTER_LOG_INFO
838
 
                           + TRX_SYS_MYSQL_LOG_OFFSET_LOW));
 
698
        trx_sysf_t*     sys_header;
 
699
        mtr_t           mtr;
 
700
 
 
701
        mtr_start(&mtr);
 
702
 
 
703
        sys_header = trx_sysf_get(&mtr);
 
704
 
 
705
        trx_sys_commit_id = mach_read_from_8(sys_header + TRX_SYS_DRIZZLE_LOG_INFO 
 
706
                                             + TRX_SYS_DRIZZLE_MAX_COMMIT_ID);
 
707
 
839
708
        mtr_commit(&mtr);
840
709
}
841
710
 
1341
1210
}
1342
1211
 
1343
1212
#else /* !UNIV_HOTBACKUP */
1344
 
/*****************************************************************//**
1345
 
Prints to stderr the MySQL binlog info in the system header if the
1346
 
magic number shows it valid. */
1347
 
UNIV_INTERN
1348
 
void
1349
 
trx_sys_print_mysql_binlog_offset_from_page(
1350
 
/*========================================*/
1351
 
        const byte*     page)   /*!< in: buffer containing the trx
1352
 
                                system header page, i.e., page number
1353
 
                                TRX_SYS_PAGE_NO in the tablespace */
1354
 
{
1355
 
        const trx_sysf_t*       sys_header;
1356
 
 
1357
 
        sys_header = page + TRX_SYS;
1358
 
 
1359
 
        if (mach_read_from_4(sys_header + TRX_SYS_MYSQL_LOG_INFO
1360
 
                             + TRX_SYS_MYSQL_LOG_MAGIC_N_FLD)
1361
 
            == TRX_SYS_MYSQL_LOG_MAGIC_N) {
1362
 
 
1363
 
                fprintf(stderr,
1364
 
                        "ibbackup: Last MySQL binlog file position %lu %lu,"
1365
 
                        " file name %s\n",
1366
 
                        (ulong) mach_read_from_4(
1367
 
                                sys_header + TRX_SYS_MYSQL_LOG_INFO
1368
 
                                + TRX_SYS_MYSQL_LOG_OFFSET_HIGH),
1369
 
                        (ulong) mach_read_from_4(
1370
 
                                sys_header + TRX_SYS_MYSQL_LOG_INFO
1371
 
                                + TRX_SYS_MYSQL_LOG_OFFSET_LOW),
1372
 
                        sys_header + TRX_SYS_MYSQL_LOG_INFO
1373
 
                        + TRX_SYS_MYSQL_LOG_NAME);
1374
 
        }
1375
 
}
1376
 
 
1377
1213
 
1378
1214
/* THESE ARE COPIED FROM NON-HOTBACKUP PART OF THE INNODB SOURCE TREE
1379
1215
   (This code duplicaton should be fixed at some point!)