Rooba
/
drogon
mirror of https://github.com/drogonframework/drogon.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

MysqlConnection:Automatic reconnection

This commit is contained in:
antao 2019-01-12 22:18:35 +08:00
parent 40906894ef
commit ffbf244b73
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
orm_lib/src/mysql_impl/MysqlConnection.cc
View File

@ -111,14 +111,20 @@ MysqlConnection::MysqlConnection(trantor::EventLoop *loop, const std::string &co
void MysqlConnection::setChannel()
{
_channelPtr->disableAll();
if ((_waitStatus & MYSQL_WAIT_READ) || (_waitStatus & MYSQL_WAIT_EXCEPT))
{
_channelPtr->enableReading();
if (!_channelPtr->isReading())
_channelPtr->enableReading();
}
if (_waitStatus & MYSQL_WAIT_WRITE)
{
_channelPtr->enableWriting();
if (!_channelPtr->isWriting())
_channelPtr->enableWriting();
}
else
{
if (_channelPtr->isWriting())
_channelPtr->disableWriting();
}
//(status & MYSQL_WAIT_EXCEPT) ///FIXME
if (_waitStatus & MYSQL_WAIT_TIMEOUT)
@ -258,12 +264,18 @@ void MysqlConnection::handleEvent()
//FIXME exception callback;
return;
}
//make result!
getResult(ret);
}
setChannel();
break;
}
case ExecStatus_None:
{
//Connection closed!
if (_waitStatus == 0)
handleClosed();
break;
}
default:
return;
}