diff options
Diffstat (limited to 'ndb/src/kernel/blocks/backup/BackupInit.cpp')
| -rw-r--r-- | ndb/src/kernel/blocks/backup/BackupInit.cpp | 215 |
1 files changed, 215 insertions, 0 deletions
diff --git a/ndb/src/kernel/blocks/backup/BackupInit.cpp b/ndb/src/kernel/blocks/backup/BackupInit.cpp new file mode 100644 index 00000000000..1997e560bb9 --- /dev/null +++ b/ndb/src/kernel/blocks/backup/BackupInit.cpp @@ -0,0 +1,215 @@ +/* Copyright (C) 2003 MySQL AB + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ + +//**************************************************************************** +// +// NAME +// Backup - Database backup / restore +// +//=========================================================================== +#include "Backup.hpp" + +#include <new> +#include <Properties.hpp> +#include <Configuration.hpp> + +//extern const unsigned Ndbcntr::g_sysTableCount; + +Backup::Backup(const Configuration & conf) : + SimulatedBlock(BACKUP, conf), + c_nodes(c_nodePool), + c_backups(c_backupPool) +{ + BLOCK_CONSTRUCTOR(Backup); + + c_nodePool.setSize(MAX_NDB_NODES); + c_masterNodeId = getOwnNodeId(); + + const Properties * p = conf.getOwnProperties(); + ndbrequire(p != 0); + + Uint32 noBackups = 0, noTables = 0, noAttribs = 0; + p->get("ParallelBackups", &noBackups); + ndbrequire(p->get("MaxNoOfTables", &noTables)); + ndbrequire(p->get("MaxNoOfAttributes", &noAttribs)); + + // To allow for user tables AND SYSTAB + // See ClusterConfig + //TODO get this infor from NdbCntr + noTables += 2; + + // Considering also TR527, this is a KISS work-around to be able to + // continue testing the real thing + noAttribs += 2 + 1; + + c_backupPool.setSize(noBackups); + c_backupFilePool.setSize(3 * noBackups); + c_tablePool.setSize(noBackups * noTables); + c_attributePool.setSize(noBackups * noAttribs); + c_triggerPool.setSize(noBackups * 3 * noTables); + + // 2 = no of replicas + c_fragmentPool.setSize(noBackups * 2 * NO_OF_FRAG_PER_NODE * noTables); + + Uint32 szMem = 0; + p->get("BackupMemory", &szMem); + Uint32 noPages = (szMem + sizeof(Page32) - 1) / sizeof(Page32); + // We need to allocate an additional of 2 pages. 1 page because of a bug in + // ArrayPool and another one for DICTTAINFO. + c_pagePool.setSize(noPages + NO_OF_PAGES_META_FILE + 2); + + Uint32 szDataBuf = (2 * 1024 * 1024); + Uint32 szLogBuf = (2 * 1024 * 1024); + Uint32 szWrite = 32768; + p->get("BackupDataBufferSize", &szDataBuf); + p->get("BackupLogBufferSize", &szLogBuf); + p->get("BackupWriteSize", &szWrite); + + c_defaults.m_logBufferSize = szLogBuf; + c_defaults.m_dataBufferSize = szDataBuf; + c_defaults.m_minWriteSize = szWrite; + c_defaults.m_maxWriteSize = szWrite; + + { // Init all tables + ArrayList<Table> tables(c_tablePool); + TablePtr ptr; + while(tables.seize(ptr)){ + new (ptr.p) Table(c_attributePool, c_fragmentPool); + } + tables.release(); + } + + { + ArrayList<BackupFile> ops(c_backupFilePool); + BackupFilePtr ptr; + while(ops.seize(ptr)){ + new (ptr.p) BackupFile(* this, c_pagePool); + } + ops.release(); + } + + { + ArrayList<BackupRecord> recs(c_backupPool); + BackupRecordPtr ptr; + while(recs.seize(ptr)){ + new (ptr.p) BackupRecord(* this, c_pagePool, c_tablePool, + c_backupFilePool, c_triggerPool); + } + recs.release(); + } + + // Initialize BAT for interface to file system + { + Page32Ptr p; + ndbrequire(c_pagePool.seizeId(p, 0)); + c_startOfPages = (Uint32 *)p.p; + c_pagePool.release(p); + + NewVARIABLE* bat = allocateBat(1); + bat[0].WA = c_startOfPages; + bat[0].nrr = c_pagePool.getSize()*sizeof(Page32)/sizeof(Uint32); + } + + // Add received signals + addRecSignal(GSN_STTOR, &Backup::execSTTOR); + addRecSignal(GSN_DUMP_STATE_ORD, &Backup::execDUMP_STATE_ORD); + addRecSignal(GSN_READ_NODESCONF, &Backup::execREAD_NODESCONF); + addRecSignal(GSN_NODE_FAILREP, &Backup::execNODE_FAILREP); + addRecSignal(GSN_INCL_NODEREQ, &Backup::execINCL_NODEREQ); + addRecSignal(GSN_CONTINUEB, &Backup::execCONTINUEB); + + addRecSignal(GSN_SCAN_HBREP, &Backup::execSCAN_HBREP); + addRecSignal(GSN_TRANSID_AI, &Backup::execTRANSID_AI); + addRecSignal(GSN_KEYINFO20, &Backup::execKEYINFO20); + addRecSignal(GSN_SCAN_FRAGREF, &Backup::execSCAN_FRAGREF); + addRecSignal(GSN_SCAN_FRAGCONF, &Backup::execSCAN_FRAGCONF); + + addRecSignal(GSN_BACKUP_TRIG_REQ, &Backup::execBACKUP_TRIG_REQ); + addRecSignal(GSN_TRIG_ATTRINFO, &Backup::execTRIG_ATTRINFO); + addRecSignal(GSN_FIRE_TRIG_ORD, &Backup::execFIRE_TRIG_ORD); + + addRecSignal(GSN_LIST_TABLES_CONF, &Backup::execLIST_TABLES_CONF); + addRecSignal(GSN_GET_TABINFOREF, &Backup::execGET_TABINFOREF); + addRecSignal(GSN_GET_TABINFO_CONF, &Backup::execGET_TABINFO_CONF); + + addRecSignal(GSN_CREATE_TRIG_REF, &Backup::execCREATE_TRIG_REF); + addRecSignal(GSN_CREATE_TRIG_CONF, &Backup::execCREATE_TRIG_CONF); + + addRecSignal(GSN_ALTER_TRIG_REF, &Backup::execALTER_TRIG_REF); + addRecSignal(GSN_ALTER_TRIG_CONF, &Backup::execALTER_TRIG_CONF); + + addRecSignal(GSN_DROP_TRIG_REF, &Backup::execDROP_TRIG_REF); + addRecSignal(GSN_DROP_TRIG_CONF, &Backup::execDROP_TRIG_CONF); + + addRecSignal(GSN_DI_FCOUNTCONF, &Backup::execDI_FCOUNTCONF); + addRecSignal(GSN_DIGETPRIMCONF, &Backup::execDIGETPRIMCONF); + + addRecSignal(GSN_FSOPENREF, &Backup::execFSOPENREF); + addRecSignal(GSN_FSOPENCONF, &Backup::execFSOPENCONF); + + addRecSignal(GSN_FSCLOSEREF, &Backup::execFSCLOSEREF); + addRecSignal(GSN_FSCLOSECONF, &Backup::execFSCLOSECONF); + + addRecSignal(GSN_FSAPPENDREF, &Backup::execFSAPPENDREF); + addRecSignal(GSN_FSAPPENDCONF, &Backup::execFSAPPENDCONF); + + addRecSignal(GSN_FSREMOVEREF, &Backup::execFSREMOVEREF); + addRecSignal(GSN_FSREMOVECONF, &Backup::execFSREMOVECONF); + + /*****/ + addRecSignal(GSN_BACKUP_REQ, &Backup::execBACKUP_REQ); + addRecSignal(GSN_ABORT_BACKUP_ORD, &Backup::execABORT_BACKUP_ORD); + + addRecSignal(GSN_DEFINE_BACKUP_REQ, &Backup::execDEFINE_BACKUP_REQ); + addRecSignal(GSN_DEFINE_BACKUP_REF, &Backup::execDEFINE_BACKUP_REF); + addRecSignal(GSN_DEFINE_BACKUP_CONF, &Backup::execDEFINE_BACKUP_CONF); + + addRecSignal(GSN_START_BACKUP_REQ, &Backup::execSTART_BACKUP_REQ); + addRecSignal(GSN_START_BACKUP_REF, &Backup::execSTART_BACKUP_REF); + addRecSignal(GSN_START_BACKUP_CONF, &Backup::execSTART_BACKUP_CONF); + + addRecSignal(GSN_BACKUP_FRAGMENT_REQ, &Backup::execBACKUP_FRAGMENT_REQ); + //addRecSignal(GSN_BACKUP_FRAGMENT_REF, &Backup::execBACKUP_FRAGMENT_REF); + addRecSignal(GSN_BACKUP_FRAGMENT_CONF, &Backup::execBACKUP_FRAGMENT_CONF); + + addRecSignal(GSN_STOP_BACKUP_REQ, &Backup::execSTOP_BACKUP_REQ); + addRecSignal(GSN_STOP_BACKUP_REF, &Backup::execSTOP_BACKUP_REF); + addRecSignal(GSN_STOP_BACKUP_CONF, &Backup::execSTOP_BACKUP_CONF); + + //addRecSignal(GSN_BACKUP_STATUS_REQ, &Backup::execBACKUP_STATUS_REQ); + //addRecSignal(GSN_BACKUP_STATUS_CONF, &Backup::execBACKUP_STATUS_CONF); + + addRecSignal(GSN_UTIL_SEQUENCE_REF, &Backup::execUTIL_SEQUENCE_REF); + addRecSignal(GSN_UTIL_SEQUENCE_CONF, &Backup::execUTIL_SEQUENCE_CONF); + + addRecSignal(GSN_WAIT_GCP_REF, &Backup::execWAIT_GCP_REF); + addRecSignal(GSN_WAIT_GCP_CONF, &Backup::execWAIT_GCP_CONF); + + /** + * Testing + */ + addRecSignal(GSN_BACKUP_REF, &Backup::execBACKUP_REF); + addRecSignal(GSN_BACKUP_CONF, &Backup::execBACKUP_CONF); + addRecSignal(GSN_BACKUP_ABORT_REP, &Backup::execBACKUP_ABORT_REP); + addRecSignal(GSN_BACKUP_COMPLETE_REP, &Backup::execBACKUP_COMPLETE_REP); +} + +Backup::~Backup() +{ +} + +BLOCK_FUNCTIONS(Backup); + |