anchor.diff:              {ok, Resolution, Data} = metric:get(B, M, T, C),
               Transport:send(Socket, <<Resolution:64/integer, Data/binary>>),
               loop(Socket, Transport, State, Loop - 1);
  -        {ok, <<0,_BS:?BUCKET_SS/integer, Bucket:_BS/binary, D/binary>>} ->
  +        {ok, <<?PUT,_BS:?BUCKET_SS/integer, Bucket:_BS/binary, D/binary>>} ->
               #state{cbin=CBin, nodes=Nodes, w=W} = State,
               case dalmatiner_db_udp:handle_data(D, Bucket, W, 0, CBin, Nodes, 0, dict:new()) of
                   ok ->
  
positive.code:                     lager:error("[tcp] Fast loop cancled because of: ~p.", [E]),
                      loop(Socket, Transport, State, Loop - 1)
              end;
          {error, timeout} ->
              loop(Socket, Transport, State, Loop - 1);
          E ->
              io:format("E: ~p~n", [E]),
              ok = Transport:close(Socket)
      end.
  
negative.code: 
  -include_lib("dproto/include/dproto.hrl").
  
  -define(STREAM, 4).
  -define(SENTRY, 1).
  -define(SWRITE, 2).
  
  -export([start_link/4]).
  -export([init/4]).
  
  -record(state, {cbin, nodes, n, w, fast_loop_count, wait = 5000}).
  
  -record(sstate,
          {cbin, nodes, n, w, last = 0, max_diff = 1, wait = 5000,
           dict = dict:new(), bucket}).
  
  start_link(Ref, Socket, Transport, Opts) ->
      Pid = spawn_link(?MODULE, init, [Ref, Socket, Transport, Opts]),
  