projects
/
paraslash.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (from parent 1:
4dc05b2
)
afh_recv: Switch to the alternative post select method.
author
Andre Noll
<maan@systemlinux.org>
Sun, 31 Mar 2013 17:03:15 +0000
(17:03 +0000)
committer
Andre Noll
<maan@systemlinux.org>
Tue, 30 Apr 2013 12:12:46 +0000
(14:12 +0200)
afh_recv.c
patch
|
blob
|
history
diff --git
a/afh_recv.c
b/afh_recv.c
index febda8a99a26acc5894ba21c255fc9d2a8a8958d..6eeb08aad058572f6bf599117f4c20eb18870a17 100644
(file)
--- a/
afh_recv.c
+++ b/
afh_recv.c
@@
-173,7
+173,7
@@
static void afh_recv_pre_select(struct sched *s, struct task *t)
sched_request_barrier_or_min_delay(&chunk_time, s);
}
sched_request_barrier_or_min_delay(&chunk_time, s);
}
-static
void
afh_recv_post_select(__a_unused struct sched *s, struct task *t)
+static
int
afh_recv_post_select(__a_unused struct sched *s, struct task *t)
{
struct receiver_node *rn = container_of(t, struct receiver_node, task);
struct afh_recv_args_info *conf = rn->conf;
{
struct receiver_node *rn = container_of(t, struct receiver_node, task);
struct afh_recv_args_info *conf = rn->conf;
@@
-233,7
+233,7
@@
out:
btr_remove_node(&rn->btrn);
pard->current_chunk = pard->first_chunk;
}
btr_remove_node(&rn->btrn);
pard->current_chunk = pard->first_chunk;
}
-
t->error =
ret;
+
return
ret;
}
/**
}
/**
@@
-252,7
+252,8
@@
void afh_recv_init(struct receiver *r)
r->open = afh_recv_open;
r->close = afh_recv_close;
r->pre_select = afh_recv_pre_select;
r->open = afh_recv_open;
r->close = afh_recv_close;
r->pre_select = afh_recv_pre_select;
- r->post_select = afh_recv_post_select;
+ r->new_post_select = afh_recv_post_select;
+ r->post_select = NULL;
r->parse_config = afh_recv_parse_config;
r->free_config = afh_recv_free_config;
r->execute = afh_execute;
r->parse_config = afh_recv_parse_config;
r->free_config = afh_recv_free_config;
r->execute = afh_execute;