Do not unlock upstream without referencing its dying ops

diff --git a/servers/lloadd/operation.c b/servers/lloadd/operation.c
index efd2531a5afb1179d6d25adcb36e7e2df6530cb4..c9e69cd94d276a7d8343975230c6d30f36ce897b 100644 (file)
--- a/servers/lloadd/operation.c
+++ b/servers/lloadd/operation.c
@@ -806,16 +806,11 @@ void
 operation_lost_upstream( LloadOperation *op )
 {
     LloadConnection *c = op->o_upstream;
-    CONNECTION_LOCK(c);
-    op->o_res = LLOAD_OP_FAILED;
-    op->o_upstream_refcnt++;
-    /* Matching the op reference on the connection as well */
-    CONNECTION_UNLOCK_INCREF(c);
 
     operation_send_reject( op, LDAP_UNAVAILABLE,
             "connection to the remote server has been severed", 0 );
 
-    CONNECTION_LOCK_DECREF(c);
+    CONNECTION_LOCK(c);
     op->o_upstream_refcnt--;
     operation_destroy_from_upstream( op );
     CONNECTION_UNLOCK(c);

diff --git a/servers/lloadd/upstream.c b/servers/lloadd/upstream.c
index a1d17ab9bfc839ba21fc7fc8c5869c5fb4e55602..391b609108924036d6fdcace7168f5b78cab8f84 100644 (file)
--- a/servers/lloadd/upstream.c
+++ b/servers/lloadd/upstream.c
@@ -760,7 +760,7 @@ upstream_destroy( LloadConnection *c )
 {
     LloadBackend *b = c->c_private;
     struct event *read_event, *write_event;
-    TAvlnode *root;
+    TAvlnode *root, *node;
     long freed, executing;
     enum sc_state state;
 
@@ -780,6 +780,14 @@ upstream_destroy( LloadConnection *c )
     read_event = c->c_read_event;
     write_event = c->c_write_event;
 
+    for ( node = tavl_end( root, TAVL_DIR_LEFT ); node;
+            node = tavl_next( node, TAVL_DIR_RIGHT ) ) {
+        LloadOperation *op = node->avl_data;
+
+        op->o_res = LLOAD_OP_FAILED;
+        op->o_upstream_refcnt++;
+    }
+
     CONNECTION_UNLOCK_INCREF(c);
 
     freed = tavl_free( root, (AVL_FREE)operation_lost_upstream );