Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
cd0ae996
Commit
cd0ae996
authored
Sep 08, 2005
by
mronstrom@mysql.com
Browse files
Options
Browse Files
Download
Plain Diff
Merge mikael@ndb.mysql.com:/home/mikael/bug12594
into mysql.com:/Users/mikron/mysql-4.1
parents
98a52fa9
43c2bc2f
Changes
4
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
110 additions
and
74 deletions
+110
-74
ndb/src/kernel/blocks/dblqh/Dblqh.hpp
ndb/src/kernel/blocks/dblqh/Dblqh.hpp
+18
-4
ndb/src/kernel/blocks/dblqh/DblqhMain.cpp
ndb/src/kernel/blocks/dblqh/DblqhMain.cpp
+71
-69
ndb/src/kernel/blocks/dblqh/redoLogReader/records.cpp
ndb/src/kernel/blocks/dblqh/redoLogReader/records.cpp
+10
-1
ndb/src/kernel/blocks/dblqh/redoLogReader/records.hpp
ndb/src/kernel/blocks/dblqh/redoLogReader/records.hpp
+11
-0
No files found.
ndb/src/kernel/blocks/dblqh/Dblqh.hpp
View file @
cd0ae996
...
@@ -86,6 +86,17 @@
...
@@ -86,6 +86,17 @@
#define ZCURR_PAGE_INDEX 8
#define ZCURR_PAGE_INDEX 8
#define ZLAST_LOG_PREP_REF 10
#define ZLAST_LOG_PREP_REF 10
#define ZPOS_DIRTY 11
#define ZPOS_DIRTY 11
/* A number of debug items written in the page header of all log files */
#define ZPOS_LOG_TIMER 12
#define ZPOS_PAGE_I 13
#define ZPOS_PLACE_WRITTEN_FROM 14
#define ZPOS_PAGE_NO 15
#define ZPOS_PAGE_FILE_NO 16
#define ZPOS_WORD_WRITTEN 17
#define ZPOS_IN_WRITING 18
#define ZPOS_PREV_PAGE_NO 19
#define ZPOS_IN_FREE_LIST 20
/* ------------------------------------------------------------------------- */
/* ------------------------------------------------------------------------- */
/* CONSTANTS FOR THE VARIOUS REPLICA AND NODE TYPES. */
/* CONSTANTS FOR THE VARIOUS REPLICA AND NODE TYPES. */
/* ------------------------------------------------------------------------- */
/* ------------------------------------------------------------------------- */
...
@@ -2278,7 +2289,7 @@ private:
...
@@ -2278,7 +2289,7 @@ private:
const
LogPartRecordPtr
&
sltLogPartPtr
);
const
LogPartRecordPtr
&
sltLogPartPtr
);
void
checkGcpCompleted
(
Signal
*
signal
,
Uint32
pageWritten
,
Uint32
wordWritten
);
void
checkGcpCompleted
(
Signal
*
signal
,
Uint32
pageWritten
,
Uint32
wordWritten
);
void
initFsopenconf
(
Signal
*
signal
);
void
initFsopenconf
(
Signal
*
signal
);
void
initFsrwconf
(
Signal
*
signal
);
void
initFsrwconf
(
Signal
*
signal
,
bool
write
);
void
initLfo
(
Signal
*
signal
);
void
initLfo
(
Signal
*
signal
);
void
initLogfile
(
Signal
*
signal
,
Uint32
fileNo
);
void
initLogfile
(
Signal
*
signal
,
Uint32
fileNo
);
void
initLogpage
(
Signal
*
signal
);
void
initLogpage
(
Signal
*
signal
);
...
@@ -2294,7 +2305,8 @@ private:
...
@@ -2294,7 +2305,8 @@ private:
void
writeFileDescriptor
(
Signal
*
signal
);
void
writeFileDescriptor
(
Signal
*
signal
);
void
writeFileHeaderOpen
(
Signal
*
signal
,
Uint32
type
);
void
writeFileHeaderOpen
(
Signal
*
signal
,
Uint32
type
);
void
writeInitMbyte
(
Signal
*
signal
);
void
writeInitMbyte
(
Signal
*
signal
);
void
writeSinglePage
(
Signal
*
signal
,
Uint32
pageNo
,
Uint32
wordWritten
);
void
writeSinglePage
(
Signal
*
signal
,
Uint32
pageNo
,
Uint32
wordWritten
,
Uint32
place
);
void
buildLinkedLogPageList
(
Signal
*
signal
);
void
buildLinkedLogPageList
(
Signal
*
signal
);
void
changeMbyte
(
Signal
*
signal
);
void
changeMbyte
(
Signal
*
signal
);
Uint32
checkIfExecLog
(
Signal
*
signal
);
Uint32
checkIfExecLog
(
Signal
*
signal
);
...
@@ -2303,7 +2315,7 @@ private:
...
@@ -2303,7 +2315,7 @@ private:
void
checkScanTcCompleted
(
Signal
*
signal
);
void
checkScanTcCompleted
(
Signal
*
signal
);
void
checkSrCompleted
(
Signal
*
signal
);
void
checkSrCompleted
(
Signal
*
signal
);
void
closeFile
(
Signal
*
signal
,
LogFileRecordPtr
logFilePtr
);
void
closeFile
(
Signal
*
signal
,
LogFileRecordPtr
logFilePtr
);
void
completedLogPage
(
Signal
*
signal
,
Uint32
clpType
);
void
completedLogPage
(
Signal
*
signal
,
Uint32
clpType
,
Uint32
place
);
void
deleteFragrec
(
Uint32
fragId
);
void
deleteFragrec
(
Uint32
fragId
);
void
deleteTransidHash
(
Signal
*
signal
);
void
deleteTransidHash
(
Signal
*
signal
);
void
findLogfile
(
Signal
*
signal
,
void
findLogfile
(
Signal
*
signal
,
...
@@ -2399,7 +2411,9 @@ private:
...
@@ -2399,7 +2411,9 @@ private:
void
writeAbortLog
(
Signal
*
signal
);
void
writeAbortLog
(
Signal
*
signal
);
void
writeCommitLog
(
Signal
*
signal
,
LogPartRecordPtr
regLogPartPtr
);
void
writeCommitLog
(
Signal
*
signal
,
LogPartRecordPtr
regLogPartPtr
);
void
writeCompletedGciLog
(
Signal
*
signal
);
void
writeCompletedGciLog
(
Signal
*
signal
);
void
writeDirty
(
Signal
*
signal
);
void
writeDbgInfoPageHeader
(
LogPageRecordPtr
logPagePtr
,
Uint32
place
,
Uint32
pageNo
,
Uint32
wordWritten
);
void
writeDirty
(
Signal
*
signal
,
Uint32
place
);
void
writeKey
(
Signal
*
signal
);
void
writeKey
(
Signal
*
signal
);
void
writeLogHeader
(
Signal
*
signal
);
void
writeLogHeader
(
Signal
*
signal
);
void
writeLogWord
(
Signal
*
signal
,
Uint32
data
);
void
writeLogWord
(
Signal
*
signal
,
Uint32
data
);
...
...
ndb/src/kernel/blocks/dblqh/DblqhMain.cpp
View file @
cd0ae996
This diff is collapsed.
Click to expand it.
ndb/src/kernel/blocks/dblqh/redoLogReader/records.cpp
View file @
cd0ae996
...
@@ -266,7 +266,16 @@ NdbOut& operator<<(NdbOut& no, const PageHeader& ph) {
...
@@ -266,7 +266,16 @@ NdbOut& operator<<(NdbOut& no, const PageHeader& ph) {
printOut
(
"Current page index:"
,
ph
.
m_current_page_index
);
printOut
(
"Current page index:"
,
ph
.
m_current_page_index
);
printOut
(
"Oldest prepare op. file No.:"
,
ph
.
m_old_prepare_file_number
);
printOut
(
"Oldest prepare op. file No.:"
,
ph
.
m_old_prepare_file_number
);
printOut
(
"Oldest prepare op. page ref.:"
,
ph
.
m_old_prepare_page_reference
);
printOut
(
"Oldest prepare op. page ref.:"
,
ph
.
m_old_prepare_page_reference
);
printOut
(
"Dirty flag:"
,
ph
.
m_dirty_flag
);
printOut
(
"Dirty flag:"
,
ph
.
m_dirty_flag
);
printOut
(
"Write Timer:"
,
ph
.
m_log_timer
);
printOut
(
"Page i-val:"
,
ph
.
m_page_i_value
);
printOut
(
"Place written:"
,
ph
.
m_place_written_from
);
printOut
(
"Page No in File:"
,
ph
.
m_page_no
);
printOut
(
"File No:"
,
ph
.
m_file_no
);
printOut
(
"Word Written:"
,
ph
.
m_word_written
);
printOut
(
"In Writing (should be 1)"
,
ph
.
m_in_writing_flag
);
printOut
(
"Prev Page No (can be garbage)"
,
ph
.
m_prev_page_no
);
printOut
(
"In Free List (should be 0):"
,
ph
.
m_in_free_list
);
no
<<
endl
;
no
<<
endl
;
return
no
;
return
no
;
}
}
...
...
ndb/src/kernel/blocks/dblqh/redoLogReader/records.hpp
View file @
cd0ae996
...
@@ -147,6 +147,17 @@ protected:
...
@@ -147,6 +147,17 @@ protected:
Uint32
m_old_prepare_file_number
;
Uint32
m_old_prepare_file_number
;
Uint32
m_old_prepare_page_reference
;
Uint32
m_old_prepare_page_reference
;
Uint32
m_dirty_flag
;
Uint32
m_dirty_flag
;
/* Debug info Start */
Uint32
m_log_timer
;
Uint32
m_page_i_value
;
Uint32
m_place_written_from
;
Uint32
m_page_no
;
Uint32
m_file_no
;
Uint32
m_word_written
;
Uint32
m_in_writing_flag
;
Uint32
m_prev_page_no
;
Uint32
m_in_free_list
;
/* Debug info End */
};
};
//----------------------------------------------------------------
//----------------------------------------------------------------
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment