anchor.diff:                                                                {dw, State#state.dw}], State#state.timeout_write) of
                   ok ->
                       {ok, State};
  +                {error, disconnected} ->
  +                    run(update_existing, KeyGen, ValueGen, State);  % suboptimal, but ...
                   {error, Reason} ->
                       {error, Reason, State}
               end;
           {error, notfound} ->
               {error, {not_found, Key}, State};
  +        {error, disconnected} ->
  +            run(update_existing, KeyGen, ValueGen, State);
           {error, Reason} ->
               {error, Reason, State}
       end;
  
positive.code:             {ok, State};
          {error, notfound} ->
              {ok, State};
          {error, Reason} ->
              {error, Reason, State}
      end;
  
negative.code:                 {error, Reason} ->
                      {error, Reason, State}
              end;
          {error, disconnected} ->
              mapred(State, Input, Query);
          {error, Reason} ->
              {error, Reason, State}
      end.
  