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(),
        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:                 State
          end,
      ok = gen_tcp:send(Downstream, Packet),
      State1.
  
  
  validate_vbucket(VBucket, VBuckets) ->
  