anchor.diff:              {ok, fullresync, b2l(RunId), int_offset(Offset)};
           {tcp, _Sock, <<"-ERR Unrecognized REPLCONF", _/binary>>} ->
               {ok, sync};
  +        {tcp, _Sock, <<"-", Error/binary>>} ->
  +            {error, Error};
           {tcp, _Sock, <<Bulk/binary>>} ->
               {ok, load_stream, Bulk};
           {tcp, _Sock, Data} ->
  
positive.code: handle_cast(replication, S = #state{socket=Sock, state=stream}) ->
      io:format("receive stream ~n"),
      inet:setopts(Sock, [{active,once}]),
      io:format("foo ~n"),
      {noreply, S};
  
  %% Generic
  
negative.code:          code_change/3]).
  
  -define(RDB_FILE, "/tmp/master/dump3.rdb").
  -define(BS, <<" ">>). % Binary blank space
  -define(CRLF, <<"\r\n">>).
  
  -record(state, {runid="?",
  