anchor.diff:                          binary_to_existing_atom(V, latin1)} | Acc]
                 end, []),
       {reply, Reply, State};
  +handle_call(noop, _From, State) ->
  +    {reply, ok, State};
   handle_call({set_flush_param, Key, Value}, _From, State) ->
       Reply = mc_client_binary:set_flush_param(State#state.sock, Key, Value),
       {reply, Reply, State};
  
positive.code: 
  
  terminate(Reason, #state{bucket=Bucket, sock=Sock}) ->
      if
          Reason == normal; Reason == shutdown ->
              case ns_bucket:get_bucket(Bucket) of
  
negative.code: -record(state, {bucket::nonempty_string(), sock::port()}).
  
  %% external API
  -export([active_buckets/0, connected/2,
           delete_vbucket/2, delete_vbucket/3,
           get_vbucket/3,
           host_port_str/0, host_port_str/1,
  