anchor.diff:                  State
           end,
       ok = gen_tcp:send(Downstream, Packet),
  -    %% Keep track of the number of messages we've seen with each opcode
  -    State1#state{opcode_counts=dict:update_counter(
  -                                 Opcode, 1, State1#state.opcode_counts)}.
  +    State1.
   
   
   validate_vbucket(VBucket, VBuckets) ->
  
positive.code:                      _ -> VBuckets
                   end),
        last_seen=now(),
        opcode_counts=dict:new(),
        takeover=TakeOver
       },
      %% Trap exits so we can log
      process_flag(trap_exit, true),
      gen_server:enter_loop(?MODULE, [], State).
  
  
  terminate(_Reason, State) ->
      ?log_info("Opcode counts: ~p", [dict:to_list(State#state.opcode_counts)]),
      ok.
  
  
  
negative.code:                 vbuckets,
                  takeover :: boolean(),
                  takeover_msgs_seen = 0 :: non_neg_integer(),
                  last_seen}).
  
  %% external API
  