Commit 378b47a3 authored by unknown's avatar unknown

Merge whalegate.ndb.mysql.com:/home/tomas/mysql-5.1-telco-gca-single-user

into  whalegate.ndb.mysql.com:/home/tomas/mysql-5.1-single-user


storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp:
  Auto merged
parents a96a0cd6 cdb16d2f
...@@ -6239,6 +6239,7 @@ void Dbtc::timeOutLoopStartLab(Signal* signal, Uint32 api_con_ptr) ...@@ -6239,6 +6239,7 @@ void Dbtc::timeOutLoopStartLab(Signal* signal, Uint32 api_con_ptr)
Uint32 api_timer= getApiConTimer(api_con_ptr); Uint32 api_timer= getApiConTimer(api_con_ptr);
jam(); jam();
if (api_timer != 0) { if (api_timer != 0) {
Uint32 error= ZTIME_OUT_ERROR;
time_out_value= time_out_param + (api_con_ptr & mask_value); time_out_value= time_out_param + (api_con_ptr & mask_value);
if (unlikely(old_mask_value)) // abort during single user mode if (unlikely(old_mask_value)) // abort during single user mode
{ {
...@@ -6252,12 +6253,16 @@ void Dbtc::timeOutLoopStartLab(Signal* signal, Uint32 api_con_ptr) ...@@ -6252,12 +6253,16 @@ void Dbtc::timeOutLoopStartLab(Signal* signal, Uint32 api_con_ptr)
time_out_value= time_out_value=
old_time_out_param + (api_con_ptr & old_mask_value); old_time_out_param + (api_con_ptr & old_mask_value);
} }
else
{
error= ZCLUSTER_IN_SINGLEUSER_MODE;
}
} }
time_passed= tc_timer - api_timer; time_passed= tc_timer - api_timer;
if (time_passed > time_out_value) if (time_passed > time_out_value)
{ {
jam(); jam();
timeOutFoundLab(signal, api_con_ptr, ZTIME_OUT_ERROR); timeOutFoundLab(signal, api_con_ptr, error);
api_con_ptr++; api_con_ptr++;
break; break;
} }
...@@ -6297,7 +6302,8 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode) ...@@ -6297,7 +6302,8 @@ void Dbtc::timeOutFoundLab(Signal* signal, Uint32 TapiConPtr, Uint32 errCode)
<< " code: " << errCode); << " code: " << errCode);
switch (apiConnectptr.p->apiConnectstate) { switch (apiConnectptr.p->apiConnectstate) {
case CS_STARTED: case CS_STARTED:
if(apiConnectptr.p->lqhkeyreqrec == apiConnectptr.p->lqhkeyconfrec){ if(apiConnectptr.p->lqhkeyreqrec == apiConnectptr.p->lqhkeyconfrec &&
errCode != ZCLUSTER_IN_SINGLEUSER_MODE){
jam(); jam();
/* /*
We are waiting for application to continue the transaction. In this We are waiting for application to continue the transaction. In this
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment