basho/riak_kv — pull request #295 by jonmeredith (2012-02-28 22:33:19+00:00)
Title: Make kvget and map workers return errors from send_output.

Previously the return was being ignored so if the send_output had
an error (e.g. worker_limit_reached) the inputs would be dropped
with no way for the client to know.

Tested by configuring a very low number of partitions (4) and workers (1 or 2), populating with a small test set and then running

```
pbmr(Inputs, MapReduce) ->
{ok, S} = riakc_pb_socket:start_link({127,0,0,1},8081),
try
riakc_pb_socket:mapred(S, Inputs, MapReduce, 9000, 10000)
after
riakc_pb_socket:stop(S)
end.

pbmr_count(Inputs) ->
pbmr(Inputs,
[{map, {modfun, riak_kv_mapreduce, map_object_value}, none, false},
{reduce, {modfun, riak_kv_mapreduce, reduce_count_inputs}, none, true}]).

```

HTTP interface needs to be checked it propagates the failure.