Loading ndb/src/kernel/blocks/dbdict/Dbdict.cpp +8 −2 Original line number Diff line number Diff line Loading @@ -369,6 +369,9 @@ void Dbdict::execFSCLOSECONF(Signal* signal) jam(); closeWriteTableConf(signal, fsPtr); break; case FsConnectRecord::FsConnectRecord::OPEN_READ_SCHEMA2: openSchemaFile(signal, 1, fsPtr.i, false); break; default: jamLine((fsPtr.p->fsState & 0xFFF)); ndbrequire(false); Loading Loading @@ -1012,10 +1015,13 @@ void Dbdict::readSchemaConf(Signal* signal, void Dbdict::readSchemaRef(Signal* signal, FsConnectRecordPtr fsPtr) { /** * First close corrupt file */ fsPtr.p->fsState = FsConnectRecord::OPEN_READ_SCHEMA2; openSchemaFile(signal, 1, fsPtr.i, false); closeFile(signal, fsPtr.p->filePtr, fsPtr.i); return; }//Dbdict::readSchemaRef() } void Dbdict::closeReadSchemaConf(Signal* signal, FsConnectRecordPtr fsPtr) Loading Loading
ndb/src/kernel/blocks/dbdict/Dbdict.cpp +8 −2 Original line number Diff line number Diff line Loading @@ -369,6 +369,9 @@ void Dbdict::execFSCLOSECONF(Signal* signal) jam(); closeWriteTableConf(signal, fsPtr); break; case FsConnectRecord::FsConnectRecord::OPEN_READ_SCHEMA2: openSchemaFile(signal, 1, fsPtr.i, false); break; default: jamLine((fsPtr.p->fsState & 0xFFF)); ndbrequire(false); Loading Loading @@ -1012,10 +1015,13 @@ void Dbdict::readSchemaConf(Signal* signal, void Dbdict::readSchemaRef(Signal* signal, FsConnectRecordPtr fsPtr) { /** * First close corrupt file */ fsPtr.p->fsState = FsConnectRecord::OPEN_READ_SCHEMA2; openSchemaFile(signal, 1, fsPtr.i, false); closeFile(signal, fsPtr.p->filePtr, fsPtr.i); return; }//Dbdict::readSchemaRef() } void Dbdict::closeReadSchemaConf(Signal* signal, FsConnectRecordPtr fsPtr) Loading