mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-29 18:20:07 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

ndb dd - Remove incorrect assertion making it's impossible to only use 1 undo file with "high" load

Browse source 
storage/ndb/src/kernel/blocks/lgman.cpp:
  Remove incorrect assertion making it's impossible to only use 1 undo file with "high" load
This commit is contained in:
unknown 2006-01-27 14:23:43 +01:00
parent d255344c0b
commit 9ea27d3250
1 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
storage/ndb/src/kernel/blocks/lgman.cpp
View file

@ -1461,6 +1461,8 @@ Lgman::process_log_buffer_waiters(Signal* signal, Ptr<Logfile_group> ptr)
}
}
#define REALLY_SLOW_FS 0
Uint32
Lgman::write_log_pages(Signal* signal, Ptr<Logfile_group> ptr,
Uint32 pageId, Uint32 in_pages)
@ -1506,9 +1508,13 @@ Lgman::write_log_pages(Signal* signal, Ptr<Logfile_group> ptr,
max= pages;
head.m_idx += max;
ptr.p->m_file_pos[HEAD] = head;
sendSignal(NDBFS_REF, GSN_FSWRITEREQ, signal,
FsReadWriteReq::FixedLength + 1, JBA);
if (REALLY_SLOW_FS)
sendSignalWithDelay(NDBFS_REF, GSN_FSWRITEREQ, signal, REALLY_SLOW_FS,
FsReadWriteReq::FixedLength + 1);
else
sendSignal(NDBFS_REF, GSN_FSWRITEREQ, signal,
FsReadWriteReq::FixedLength + 1, JBA);
ptr.p->m_outstanding_fs++;
filePtr.p->m_online.m_outstanding = max;
@ -1529,8 +1535,12 @@ Lgman::write_log_pages(Signal* signal, Ptr<Logfile_group> ptr,
req->numberOfPages = max;
FsReadWriteReq::setSyncFlag(req->operationFlag, 1);
sendSignal(NDBFS_REF, GSN_FSWRITEREQ, signal,
FsReadWriteReq::FixedLength + 1, JBA);
if (REALLY_SLOW_FS)
sendSignalWithDelay(NDBFS_REF, GSN_FSWRITEREQ, signal, REALLY_SLOW_FS,
FsReadWriteReq::FixedLength + 1);
else
sendSignal(NDBFS_REF, GSN_FSWRITEREQ, signal,
FsReadWriteReq::FixedLength + 1, JBA);
ptr.p->m_outstanding_fs++;
filePtr.p->m_online.m_outstanding = max;
@ -1553,7 +1563,6 @@ Lgman::write_log_pages(Signal* signal, Ptr<Logfile_group> ptr,
files.first(next);
}
ndbout_c("changing file from %d to %d", filePtr.i, next.i);
ndbassert(filePtr.i != next.i);
filePtr.p->m_state |= Undofile::FS_MOVE_NEXT;
next.p->m_state &= ~(Uint32)Undofile::FS_EMPTY;