anchor.diff:  disconnect(State) ->
   
       %% Tell any pending requests we've disconnected
  -    case State#state.pending of
  +    case State#state.active of
           undefined ->
               ok;
           Request ->
  
positive.code:     {ok, #state{address = Address, port = Port, queue = queue:new()}}.
  
  %% @private
  handle_call({req, Msg, Timeout}, From, State) when State#state.pending =/= undefined;
                                                     State#state.sock =:= undefined ->
      {noreply, queue_request(new_request(Msg, From, Timeout), State)};
  handle_call({req, Msg, Timeout, Ctx}, From, State) when State#state.pending =/= undefined;
                                                          State#state.sock =:= undefined ->
      {noreply, queue_request(new_request(Msg, From, Timeout, Ctx), State)};
  handle_call({req, Msg, Timeout}, From, State) ->
  
negative.code: 
      %% Schedule the reconnect message and return state
      erlang:send_after(State#state.reconnect_interval, self(), reconnect),
      increase_reconnect_interval(State#state{sock = undefined, active = undefined}).
   
  %% Double the reconnect interval up to the maximum
  increase_reconnect_interval(State) ->
  