Skip to content

Commit c4d425f

Browse files
committed
Change bin_put path to handle bucket type hashes.
1 parent 4d4d4ad commit c4d425f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/riak_repl_fullsync_worker.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ handle_cast({put, RObj, Pool}, State) ->
140140
poolboy:checkin(Pool, self()),
141141
{noreply, State};
142142
handle_cast({bin_put, BinObj, Pool}, State) ->
143-
RObj = riak_repl_util:from_wire(BinObj),
143+
RObj = riak_repl_util:decode_bin_obj(BinObj),
144144
riak_repl_util:do_repl_put(RObj),
145145
poolboy:checkin(Pool, self()), % resume work
146146
{noreply, State};

0 commit comments

Comments
 (0)