Cluster crash
Former-commit-id: f25c405ad2a8004b79a816072cb011c1dc2407d5
This commit is contained in:
parent
2aed24d0a5
commit
343745f218
@ -2235,6 +2235,8 @@ void clusterWriteHandler(connection *conn) {
|
|||||||
void clusterLinkConnectHandler(connection *conn) {
|
void clusterLinkConnectHandler(connection *conn) {
|
||||||
clusterLink *link = (clusterLink*)connGetPrivateData(conn);
|
clusterLink *link = (clusterLink*)connGetPrivateData(conn);
|
||||||
clusterNode *node = link->node;
|
clusterNode *node = link->node;
|
||||||
|
if (node == nullptr)
|
||||||
|
return; // we're about to be freed
|
||||||
|
|
||||||
/* Check if connection succeeded */
|
/* Check if connection succeeded */
|
||||||
if (connGetState(conn) != CONN_STATE_CONNECTED) {
|
if (connGetState(conn) != CONN_STATE_CONNECTED) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user