anchor.diff:                      _ ->
                           State
                   end,
  -            case sets:is_element(VBucket, VBuckets) of
  -                true ->
  -                    ok = prim_inet:send(Downstream, Packet),
  -                    State1#state{last_sent_seqno = Opaque};
  -                false ->
  -                    %% Filter it out and count it
  -                    State1#state{bad_vbucket_count =
  -                                     State1#state.bad_vbucket_count + 1}
  -            end
  +            State2 =
  +                case sets:is_element(VBucket, VBuckets) of
  +                    true ->
  +                        ok = prim_inet:send(Downstream, Packet),
  +                        State1#state{last_sent_seqno = Opaque};
  +                    false ->
  +                        %% Filter it out and count it
  +                        State1#state{bad_vbucket_count =
  +                                         State1#state.bad_vbucket_count + 1}
  +                end,
  +            {ok, State2}
       end.
  
positive.code: 
  %% @doc Process a packet from the downstream server.
  -spec process_downstream(<<_:8,_:_*8>>, #state{}) ->
                                  #state{}.
  process_downstream(<<?RES_MAGIC:8, _/binary>> = Packet,
                     State) ->
      State#state.upstream_sender ! Packet,
      State.
  
  
  %% @doc Process a packet from the upstream server.
  -spec process_upstream(<<_:64,_:_*8>>, #state{}) ->
                                #state{}.
  process_upstream(<<?REQ_MAGIC:8, Opcode:8, _KeyLen:16, _ExtLen:8, _DataType:8,
                     VBucket:16, _BodyLen:32, Opaque:32, _CAS:64, _EnginePriv:16,
                     _Flags:16, _TTL:8, _Res1:8, _Res2:8, _Res3:8, Rest/binary>> =
  
negative.code:                 _ ->
                      ok
              end,
              {ok, State};
          _ ->
              State1 =
                  case Opcode of
  