X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=sync_filter.c;h=3877c13d1d932bc566303299565d87d3e6c948e6;hb=181beb316afad036ac01a778544c5dec0a8d51c7;hp=2ca2a657de6a79cb9b9e9ee3be47789e11f48e05;hpb=e5de57de1b8bf1df96c152fc92f5a49f75d6d96c;p=paraslash.git

diff --git a/sync_filter.c b/sync_filter.c
index 2ca2a657..3877c13d 100644
--- a/sync_filter.c
+++ b/sync_filter.c
@@ -103,7 +103,7 @@ static void sync_open(struct filter_node *fn)
 	const struct lls_opt_result *r_b;
 
 	ctx = fn->private_data = para_calloc(sizeof(*ctx));
-	INIT_LIST_HEAD(&ctx->buddies);
+	init_list_head(&ctx->buddies);
 
 	/* create socket to listen for incoming packets */
 	ret = makesock(
@@ -324,7 +324,7 @@ static int sync_post_select(__a_unused struct sched *s, void *context)
 		}
 		ctx->ping_sent = true;
 	}
-	if (FD_ISSET(ctx->listen_fd, &s->rfds)) {
+	if (sched_read_ok(ctx->listen_fd, s)) {
 		char c;
 		for (;;) {
 			struct sockaddr src_addr;
@@ -365,7 +365,8 @@ success:
 	ret = -E_SYNC_COMPLETE; /* success */
 	goto out;
 fail:
-	PARA_WARNING_LOG("%s\n", para_strerror(-ret));
+	if (ret != -E_BTR_EOF)
+		PARA_WARNING_LOG("%s\n", para_strerror(-ret));
 out:
 	sync_close_buddies(ctx);
 	btr_splice_out_node(&fn->btrn);