DISPATCH-2032: Zero out the link_work references on delivery during link cleanup. This closes #1122.

Author: ganeshmurthy

src/router_core/connections.c

@@ -746,7 +746,7 @@ static void qdr_generate_link_name(const char *label, char *buffer, size_t lengt
 }
 
 
-static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *conn, qdr_link_t *link)
+void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *conn, qdr_link_t *link)
 {
     //
     // Clean up the lists of deliveries on this link
@@ -766,6 +766,7 @@ static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *c
         if (d->presettled)
             core->dropped_presettled_deliveries++;
         d->where = QDR_DELIVERY_NOWHERE;
+        d->link_work = 0;
         d = DEQ_NEXT(d);
     }
 
@@ -774,6 +775,7 @@ static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *c
     while (d) {
         assert(d->where == QDR_DELIVERY_IN_UNSETTLED);
         d->where = QDR_DELIVERY_NOWHERE;
+        d->link_work = 0;
         d = DEQ_NEXT(d);
     }
 
@@ -782,6 +784,7 @@ static void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *c
     while (d) {
         assert(d->where == QDR_DELIVERY_IN_SETTLED);
         d->where = QDR_DELIVERY_NOWHERE;
+        d->link_work = 0;
         d = DEQ_NEXT(d);
     }
     sys_mutex_unlock(conn->work_lock);

src/router_core/router_core.c

@@ -224,8 +224,12 @@ void qdr_core_free(qdr_core_t *core)
             DEQ_REMOVE_N(STREAMING_POOL, link->conn->streaming_link_pool, link);
             link->in_streaming_pool = false;
         }
+
+        qdr_link_cleanup_deliveries_CT(core, link->conn, link);
+
         if (link->core_endpoint)
             qdrc_endpoint_do_cleanup_CT(core, link->core_endpoint);
+
         qdr_del_link_ref(&link->conn->links, link, QDR_LINK_LIST_CLASS_CONNECTION);
         qdr_del_link_ref(&link->conn->links_with_work[link->priority], link, QDR_LINK_LIST_CLASS_WORK);
         free(link->name);

src/router_core/router_core_private.h

@@ -987,6 +987,7 @@ qdr_edge_t *qdr_edge(qdr_core_t *);
 void qdr_edge_free(qdr_edge_t *);
 void qdr_edge_connection_opened(qdr_edge_t *edge, qdr_connection_t *conn);
 void qdr_edge_connection_closed(qdr_edge_t *edge);
+void qdr_link_cleanup_deliveries_CT(qdr_core_t *core, qdr_connection_t *conn, qdr_link_t *link);
 
 void qdr_connection_enqueue_work_CT(qdr_core_t            *core,
                                     qdr_connection_t      *conn,