anchor.diff:    RMode = mc_utils:get_value(r_mode, Options, master),
     WMode = mc_utils:get_value(w_mode, Options, unsafe),
     #conn_state{database = Database, read_mode = RMode, write_mode = WMode}.
  +
  +
   
   %% @private
   %% Register this process if needed
  
positive.code: handle_cast(_, State) ->
    {noreply, State}.
  
  %% @hidden
  handle_info({tcp, _Socket, Data}, State = #state{request_storage = RequestStorage}) ->
    Buffer = <<(State#state.buffer)/binary, Data/binary>>,
    {Responses, Pending} = mc_worker_logic:decode_responses(Buffer),
    UReqStor = mc_worker_logic:process_responses(Responses, RequestStorage),
    {noreply, State#state{buffer = Pending, request_storage = UReqStor}};
  handle_info({tcp_closed, _Socket}, State) ->
    {stop, tcp_closed, State};
  handle_info({tcp_error, _Socket, Reason}, State) ->
    {stop, Reason, State}.
  
  %% @hidden
  terminate(_, State) ->
  
negative.code: code_change(_Old, State, _Extra) ->
    {ok, State}.
  
  
  
  %% @private
  %% Parses proplist to record
  form_state(Options) ->
  