X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=buffer_tree.c;h=b0cd6665416627806d922cda50fac2e2eeeab17f;hp=b1eeb0363e3741d288656e8c5cea5aa9d186c0ab;hb=534a94f441767947874cb15d18211edf758e9277;hpb=5ae09eae1f157cbfcbe6f20c50d559cd6ad4c128

diff --git a/buffer_tree.c b/buffer_tree.c
index b1eeb036..b0cd6665 100644
--- a/buffer_tree.c
+++ b/buffer_tree.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2009-2013 Andre Noll <maan@systemlinux.org>
+ * Copyright (C) 2009 Andre Noll <maan@tuebingen.mpg.de>
  *
  * Licensed under the GPL v2. For licencing details see COPYING.
  */
@@ -771,6 +771,12 @@ void btr_drain(struct btr_node *btrn)
 		btr_drop_buffer_reference(br);
 }
 
+static void btr_free_node(struct btr_node *btrn)
+{
+	free(btrn->name);
+	free(btrn);
+}
+
 /**
  * Remove a node from a buffer tree.
  *
@@ -798,8 +804,7 @@ void btr_remove_node(struct btr_node **btrnp)
 	btr_drain(btrn);
 	if (btrn->parent)
 		list_del(&btrn->node);
-	free(btrn->name);
-	free(btrn);
+	btr_free_node(btrn);
 out:
 	*btrnp = NULL;
 }
@@ -835,7 +840,7 @@ size_t btr_get_input_queue_size(struct btr_node *btrn)
 /**
  * Remove a node from the buffer tree, reconnecting parent and children.
  *
- * \param btrn The node to splice out.
+ * \param btrnp The node to splice out.
  *
  * This function is used by buffer tree nodes that do not exist during the
  * whole lifetime of the buffer tree. Unlike btr_remove_node(), calling
@@ -843,9 +848,9 @@ size_t btr_get_input_queue_size(struct btr_node *btrn)
  * but reconnects the buffer tree by making all child nodes of \a btrn children
  * of the parent of \a btrn.
  */
-void btr_splice_out_node(struct btr_node *btrn)
+void btr_splice_out_node(struct btr_node **btrnp)
 {
-	struct btr_node *ch, *tmp;
+	struct btr_node *btrn = *btrnp, *ch, *tmp;
 
 	assert(btrn);
 	PARA_NOTICE_LOG("splicing out %s\n", btrn->name);
@@ -862,7 +867,8 @@ void btr_splice_out_node(struct btr_node *btrn)
 			list_del(&ch->node);
 	}
 	assert(list_empty(&btrn->children));
-	btrn->parent = NULL;
+	btr_free_node(btrn);
+	*btrnp = NULL;
 }
 
 /**
@@ -1203,21 +1209,20 @@ int btr_node_status(struct btr_node *btrn, size_t min_iqs,
 	size_t iqs;
 
 	assert(btrn);
-	if (type != BTR_NT_LEAF) {
-		if (btr_no_children(btrn))
-			return -E_BTR_NO_CHILD;
-		if (btr_get_output_queue_size(btrn) > BTRN_MAX_PENDING)
-			return 0;
-	}
-	if (type != BTR_NT_ROOT) {
-		if (btr_eof(btrn))
-			return -E_BTR_EOF;
-		iqs = btr_get_input_queue_size(btrn);
-		if (iqs == 0) /* we have a parent, because not eof */
-			return 0;
-		if (iqs < min_iqs && !btr_no_parent(btrn))
-			return 0;
-	}
+	if (type != BTR_NT_LEAF && btr_no_children(btrn))
+		return -E_BTR_NO_CHILD;
+	if (type != BTR_NT_ROOT && btr_eof(btrn))
+		return -E_BTR_EOF;
+
+	if (btr_get_output_queue_size(btrn) > BTRN_MAX_PENDING)
+		return 0;
+	if (type == BTR_NT_ROOT)
+		return 1;
+	iqs = btr_get_input_queue_size(btrn);
+	if (iqs == 0) /* we have a parent, because not eof */
+		return 0;
+	if (iqs < min_iqs && !btr_no_parent(btrn))
+		return 0;
 	return 1;
 }