anchor.diff:      send(State, ?COPY_DATA, epgsql_wire:encode_standby_status_update(ReceivedLSN, FlushedLSN, AppliedLSN)),
       Repl1 = Repl#repl{last_flushed_lsn = FlushedLSN,
                         last_applied_lsn = AppliedLSN},
  -    {reply, ok, State#state{repl = Repl1}};
  -handle_call({command, Command, Args}, From, State) ->
  -    Transport = {call, From},
  -    command_new(Transport, Command, Args, State).
  +    {reply, ok, State#state{repl = Repl1}}.
   
   handle_cast({{Method, From, Ref} = Transport, Command, Args}, State)
     when ((Method == cast) or (Method == incremental)),
  
positive.code: init([]) ->
      {ok, #state{}}.
  
  handle_call({get_parameter, Name}, _From, State) ->
      {reply, {ok, get_parameter_internal(Name, State)}, State};
  
  
negative.code:     {noreply, State};
  
  handle_info({inet_reply, _, Status}, State) ->
      {stop, Status, flush_queue(State, {error, Status})}.
  
  terminate(_Reason, #state{sock = undefined}) -> ok;
  terminate(_Reason, #state{mod = gen_tcp, sock = Sock}) -> gen_tcp:close(Sock);
  