r20944: if a call has been destroyed before a reply comes in then discard the

reply

diff --git a/source/cluster/ctdb/common/ctdb_call.c b/source/cluster/ctdb/common/ctdb_call.c
index 7883be8a0a75033a9e786ef5913a337a5c247162..648b2b0bc9a624768def68de53930c26221986b9 100644 (file)
--- a/source/cluster/ctdb/common/ctdb_call.c
+++ b/source/cluster/ctdb/common/ctdb_call.c
@@ -390,6 +390,7 @@ void ctdb_reply_call(struct ctdb_context *ctdb, struct ctdb_req_header *hdr)
        TDB_DATA reply_data;
 
        state = idr_find(ctdb->idr, hdr->reqid);
+       if (state == NULL) return;
 
        reply_data.dptr = c->data;
        reply_data.dsize = c->datalen;
@@ -415,6 +416,7 @@ void ctdb_reply_dmaster(struct ctdb_context *ctdb, struct ctdb_req_header *hdr)
        TDB_DATA data;
 
        state = idr_find(ctdb->idr, hdr->reqid);
+       if (state == NULL) return;
 
        data.dptr = c->data;
        data.dsize = c->datalen;
@@ -450,6 +452,7 @@ void ctdb_reply_error(struct ctdb_context *ctdb, struct ctdb_req_header *hdr)
        struct ctdb_call_state *state;
 
        state = idr_find(ctdb->idr, hdr->reqid);
+       if (state == NULL) return;
 
        talloc_steal(state, c);
 
@@ -471,6 +474,7 @@ void ctdb_reply_redirect(struct ctdb_context *ctdb, struct ctdb_req_header *hdr)
        struct ctdb_call_state *state;
 
        state = idr_find(ctdb->idr, hdr->reqid);
+       if (state == NULL) return;
 
        talloc_steal(state, c);