basho / riak_pipe

Riak Pipelines
Apache License 2.0
162 stars 60 forks source link

Improve timeout and failure handling in riak_pipe_vnode #55

Closed kellymclaughlin closed 12 years ago

kellymclaughlin commented 12 years ago

This change has two facets. First, handle the possibility of a timeout error being returned from the call to give the pipe operation the chance to recover and continue operation. Second, remove the length checking of the UsedPreflist in the remaining_preflist function when determining any remaining eligible preflist entries.

kellymclaughlin commented 12 years ago

Removed the other case and reverted the cherry-pick commit.

beerriot commented 12 years ago

+1 code looks good, and (using the standard removal of folsom in riak_pipe's test setup) eunit passes, as does mapred_verify.