anchor.diff:                  vbuckets,
                   takeover :: boolean(),
                   takeover_msgs_seen = 0 :: non_neg_integer(),
  +                opcode_counts :: dict(),
                   last_seen}).
   
   %% external API
  
positive.code:                                   _ -> VBuckets
                                end),
                     last_seen=now(),
                     takeover=TakeOver},
      gen_server:enter_loop(?MODULE, [], State).
  
  
  terminate(_Reason, _State) ->
      ok.
  
  
  
negative.code:                 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)}.
  
  
  validate_vbucket(VBucket, VBuckets) ->
  