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
f07e550f
Commit
f07e550f
authored
Dec 13, 2007
by
unknown
Browse files
Options
Browse Files
Download
Plain Diff
Merge whalegate.ndb.mysql.com:/home/tomas/mysql-5.0-ndb
into whalegate.ndb.mysql.com:/home/tomas/mysql-5.0-ndb-merge
parents
f4e94473
29165604
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
14 additions
and
4 deletions
+14
-4
ndb/src/kernel/blocks/dbtc/Dbtc.hpp
ndb/src/kernel/blocks/dbtc/Dbtc.hpp
+1
-0
ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
+13
-4
No files found.
ndb/src/kernel/blocks/dbtc/Dbtc.hpp
View file @
f07e550f
...
@@ -1674,6 +1674,7 @@ private:
...
@@ -1674,6 +1674,7 @@ private:
UintR
cfailure_nr
;
UintR
cfailure_nr
;
UintR
coperationsize
;
UintR
coperationsize
;
UintR
ctcTimer
;
UintR
ctcTimer
;
UintR
cDbHbInterval
;
ApiConnectRecordPtr
tmpApiConnectptr
;
ApiConnectRecordPtr
tmpApiConnectptr
;
UintR
tcheckGcpId
;
UintR
tcheckGcpId
;
...
...
ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
View file @
f07e550f
...
@@ -643,6 +643,10 @@ void Dbtc::execREAD_CONFIG_REQ(Signal* signal)
...
@@ -643,6 +643,10 @@ void Dbtc::execREAD_CONFIG_REQ(Signal* signal)
ndb_mgm_get_int_parameter
(
p
,
CFG_DB_TRANSACTION_DEADLOCK_TIMEOUT
,
&
val
);
ndb_mgm_get_int_parameter
(
p
,
CFG_DB_TRANSACTION_DEADLOCK_TIMEOUT
,
&
val
);
set_timeout_value
(
val
);
set_timeout_value
(
val
);
val
=
1500
;
ndb_mgm_get_int_parameter
(
p
,
CFG_DB_HEARTBEAT_INTERVAL
,
&
val
);
cDbHbInterval
=
(
val
<
10
)
?
10
:
val
;
val
=
3000
;
val
=
3000
;
ndb_mgm_get_int_parameter
(
p
,
CFG_DB_TRANSACTION_INACTIVE_TIMEOUT
,
&
val
);
ndb_mgm_get_int_parameter
(
p
,
CFG_DB_TRANSACTION_INACTIVE_TIMEOUT
,
&
val
);
set_appl_timeout_value
(
val
);
set_appl_timeout_value
(
val
);
...
@@ -6390,6 +6394,7 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode)
...
@@ -6390,6 +6394,7 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode)
// conditions should get us here. We ignore it.
// conditions should get us here. We ignore it.
/*------------------------------------------------------------------*/
/*------------------------------------------------------------------*/
case
CS_PREPARE_TO_COMMIT
:
case
CS_PREPARE_TO_COMMIT
:
{
jam
();
jam
();
/*------------------------------------------------------------------*/
/*------------------------------------------------------------------*/
/* WE ARE WAITING FOR DIH TO COMMIT THE TRANSACTION. WE SIMPLY*/
/* WE ARE WAITING FOR DIH TO COMMIT THE TRANSACTION. WE SIMPLY*/
...
@@ -6398,12 +6403,16 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode)
...
@@ -6398,12 +6403,16 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode)
// To ensure against strange bugs we crash the system if we have passed
// To ensure against strange bugs we crash the system if we have passed
// time-out period by a factor of 10 and it is also at least 5 seconds.
// time-out period by a factor of 10 and it is also at least 5 seconds.
/*------------------------------------------------------------------*/
/*------------------------------------------------------------------*/
if
(((
ctcTimer
-
getApiConTimer
(
apiConnectptr
.
i
))
>
(
10
*
ctimeOutValue
))
&&
Uint32
time_passed
=
ctcTimer
-
getApiConTimer
(
apiConnectptr
.
i
);
((
ctcTimer
-
getApiConTimer
(
apiConnectptr
.
i
))
>
500
))
{
if
(
time_passed
>
500
&&
time_passed
>
(
5
*
cDbHbInterval
)
&&
time_passed
>
(
10
*
ctimeOutValue
))
{
jam
();
jam
();
systemErrorLab
(
signal
,
__LINE__
);
systemErrorLab
(
signal
,
__LINE__
);
}
//if
}
//if
break
;
break
;
}
case
CS_COMMIT_SENT
:
case
CS_COMMIT_SENT
:
jam
();
jam
();
/*------------------------------------------------------------------*/
/*------------------------------------------------------------------*/
...
...
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