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
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Kirill Smelkov
mariadb
Commits
09e403aa
Commit
09e403aa
authored
Mar 19, 2007
by
jonas@perch.ndb.mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
ndb - bug#20185
Fix race in testprg...causing random TC crashes
parent
bdb70f7b
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
16 additions
and
13 deletions
+16
-13
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
+5
-10
storage/ndb/test/ndbapi/testNodeRestart.cpp
storage/ndb/test/ndbapi/testNodeRestart.cpp
+11
-3
No files found.
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
View file @
09e403aa
...
@@ -7099,20 +7099,15 @@ Dbtc::nodeFailCheckTransactions(Signal* signal,
...
@@ -7099,20 +7099,15 @@ Dbtc::nodeFailCheckTransactions(Signal* signal,
for
(
transPtr
.
i
=
transPtrI
;
transPtr
.
i
<
capiConnectFilesize
;
transPtr
.
i
++
)
for
(
transPtr
.
i
=
transPtrI
;
transPtr
.
i
<
capiConnectFilesize
;
transPtr
.
i
++
)
{
{
ptrCheckGuard
(
transPtr
,
capiConnectFilesize
,
apiConnectRecord
);
ptrCheckGuard
(
transPtr
,
capiConnectFilesize
,
apiConnectRecord
);
Uint32
state
=
transPtr
.
p
->
apiConnectstate
;
if
(
transPtr
.
p
->
m_transaction_nodes
.
get
(
failedNodeId
))
if
(
transPtr
.
p
->
m_transaction_nodes
.
get
(
failedNodeId
))
{
{
jam
();
jam
();
// avoid assertion in timeoutfoundlab
// Force timeout regardless of state
if
(
state
!=
CS_PREPARE_TO_COMMIT
)
c_appl_timeout_value
=
1
;
{
setApiConTimer
(
transPtr
.
i
,
TtcTimer
-
2
,
__LINE__
);
// Force timeout regardless of state
timeOutFoundLab
(
signal
,
transPtr
.
i
,
ZNODEFAIL_BEFORE_COMMIT
);
c_appl_timeout_value
=
1
;
c_appl_timeout_value
=
TapplTimeout
;
setApiConTimer
(
transPtr
.
i
,
TtcTimer
-
2
,
__LINE__
);
timeOutFoundLab
(
signal
,
transPtr
.
i
,
ZNODEFAIL_BEFORE_COMMIT
);
c_appl_timeout_value
=
TapplTimeout
;
}
}
}
// Send CONTINUEB to continue later
// Send CONTINUEB to continue later
...
...
storage/ndb/test/ndbapi/testNodeRestart.cpp
View file @
09e403aa
...
@@ -887,6 +887,9 @@ int runBug20185(NDBT_Context* ctx, NDBT_Step* step){
...
@@ -887,6 +887,9 @@ int runBug20185(NDBT_Context* ctx, NDBT_Step* step){
return
NDBT_FAILED
;
return
NDBT_FAILED
;
NdbSleep_MilliSleep
(
3000
);
NdbSleep_MilliSleep
(
3000
);
Vector
<
int
>
nodes
;
for
(
Uint32
i
=
0
;
i
<
restarter
.
getNumDbNodes
();
i
++
)
nodes
.
push_back
(
restarter
.
getDbNodeId
(
i
));
retry:
retry:
if
(
hugoOps
.
startTransaction
(
pNdb
)
!=
0
)
if
(
hugoOps
.
startTransaction
(
pNdb
)
!=
0
)
...
@@ -910,11 +913,16 @@ retry:
...
@@ -910,11 +913,16 @@ retry:
nodeId
=
restarter
.
getDbNodeId
(
rand
()
%
restarter
.
getNumDbNodes
());
nodeId
=
restarter
.
getDbNodeId
(
rand
()
%
restarter
.
getNumDbNodes
());
}
while
(
nodeId
==
node
);
}
while
(
nodeId
==
node
);
if
(
restarter
.
insertErrorInAllNodes
(
7030
))
ndbout_c
(
"7031 to %d"
,
nodeId
);
return
NDBT_FAILED
;
if
(
restarter
.
insertErrorInNode
(
nodeId
,
7031
))
if
(
restarter
.
insertErrorInNode
(
nodeId
,
7031
))
return
NDBT_FAILED
;
return
NDBT_FAILED
;
for
(
Uint32
i
=
0
;
i
<
nodes
.
size
();
i
++
)
{
if
(
nodes
[
i
]
!=
nodeId
)
if
(
restarter
.
insertErrorInNode
(
nodes
[
i
],
7030
))
return
NDBT_FAILED
;
}
NdbSleep_MilliSleep
(
500
);
NdbSleep_MilliSleep
(
500
);
...
...
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