anchor.diff:      inc_counter(non_native_vbucket_filter_changes),
       (catch master_activity_events:note_vbucket_filter_change_old()),
   
  -    ok = gen_server:call(UpstreamSender, silence_upstream),
  +    erlang:unlink(UpstreamSender),
  +    exit(UpstreamSender, shutdown),
       ok = gen_tcp:close(Upstream),
       ?log_debug("Closed upstream connection"),
   
  
positive.code: 
  handle_info(retry_not_ready_vbuckets, _State) ->
      exit_retry_not_ready_vbuckets();
  handle_info({tcp, Socket, Data},
              #state{downstream=Downstream,
                     upstream=Upstream} = State) ->
  
negative.code:     %% ok so first lets disable socket's active flags
      ok = inet:setopts(Downstream, [{active, false}]),
      ok = inet:setopts(Upstream, [{active, false}]),
  
      ?log_debug("Proceeding with reading unread binaries"),
      %% now we need to process pending messages
  