You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-07-29 08:21:15 +03:00
MCOL-4071 BRM::send_recv doesn't wait 10 seconds before re-stablishing
the network connection towards workernode
This commit is contained in:
committed by
Roman Nozdrin
parent
59f04c9743
commit
1dde4927f7
@ -877,6 +877,7 @@ int8_t DBRM::send_recv(const ByteStream& in, ByteStream& out) throw()
|
|||||||
|
|
||||||
#endif
|
#endif
|
||||||
bool firstAttempt = true;
|
bool firstAttempt = true;
|
||||||
|
bool secondAttempt = true;
|
||||||
|
|
||||||
mutex.lock();
|
mutex.lock();
|
||||||
|
|
||||||
@ -926,12 +927,16 @@ reconnect:
|
|||||||
{
|
{
|
||||||
cerr << "DBRM::send_recv: controller node closed the connection" << endl;
|
cerr << "DBRM::send_recv: controller node closed the connection" << endl;
|
||||||
|
|
||||||
if (firstAttempt)
|
if (secondAttempt)
|
||||||
{
|
{
|
||||||
firstAttempt = false;
|
|
||||||
MessageQueueClientPool::releaseInstance(msgClient);
|
MessageQueueClientPool::releaseInstance(msgClient);
|
||||||
msgClient = NULL;
|
msgClient = NULL;
|
||||||
sleep(10);
|
if (!firstAttempt)
|
||||||
|
{
|
||||||
|
secondAttempt = false;
|
||||||
|
sleep(3);
|
||||||
|
}
|
||||||
|
firstAttempt = false;
|
||||||
goto reconnect;
|
goto reconnect;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user