Introduce generic_recv_pre_select().

[paraslash.git] / file_write.c

diff --git a/file_write.c b/file_write.c
index a9635ca2d558c3c541aca0c73bde435f6ef02acb..4c043864620c49ea3ee307f8c788f8e46a923969 100644 (file)
--- a/file_write.c
+++ b/file_write.c
@@ -96,12 +96,11 @@ static void file_write_pre_select_btr(struct sched *s, struct task *t)
 
        t->error = 0;
        pfwd->check_fd = 0;
-       ret = btr_node_status(wn->btrn, wn->min_iqs);
-       if (ret >= 0) {
+       ret = btr_node_status(wn->btrn, wn->min_iqs, BTR_NT_LEAF);
+       if (ret > 0) {
                para_fd_set(pfwd->fd, &s->wfds, &s->max_fileno);
                pfwd->check_fd = 1;
-       }
-       if (ret != 0) {
+       } else if (ret < 0) {
                s->timeout.tv_sec = 0;
                s->timeout.tv_usec = 1;
        }
@@ -148,7 +147,7 @@ static void file_write_post_select_btr(__a_unused struct sched *s,
        size_t bytes;
 
        t->error = 0;
-       ret = btr_node_status(btrn, wn->min_iqs);
+       ret = btr_node_status(btrn, wn->min_iqs, BTR_NT_LEAF);
        if (ret == 0)
                return;
        if (ret < 0)