mirror of https://github.com/citusdata/citus.git
Merge pull request #2812 from citusdata/fix_memory_issues
Fix a use after free in adaptive executorpull/2816/head
commit
3359a7e6f0
|
@ -1171,16 +1171,15 @@ CleanUpSessions(DistributedExecution *execution)
|
||||||
elog(WARNING, "unexpected transaction state at the end of execution: %d",
|
elog(WARNING, "unexpected transaction state at the end of execution: %d",
|
||||||
transactionState);
|
transactionState);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* get ready for the next executions if we need use the same connection */
|
||||||
|
connection->waitFlags = WL_SOCKET_READABLE | WL_SOCKET_WRITEABLE;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
elog(WARNING, "unexpected connection state at the end of execution: %d",
|
elog(WARNING, "unexpected connection state at the end of execution: %d",
|
||||||
connection->connectionState);
|
connection->connectionState);
|
||||||
}
|
}
|
||||||
|
|
||||||
/* get ready for the next executions if we need use the same connection */
|
|
||||||
connection->waitFlags = WL_SOCKET_READABLE | WL_SOCKET_WRITEABLE;
|
|
||||||
execution->waitFlagsChanged = true;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue