anchor.diff:      {timeout, _, {tick}} -> 
         prf:ticker_even(),
         {Data,NLD} = get_data(LD),
  -      Cdata = (NLD#ld.consumer):tick(NLD#ld.consumer_data, Data),
  +      Cdata = (NLD#ld.consumer):tick(NLD#ld.consumer_data, de_proxy(LD,Data)),
         ?LOOP(NLD#ld{consumer_data = Cdata});
       {'EXIT',Pid,Reason} when Pid == LD#ld.server ->
         ?log({lost_target, Reason}),
  
positive.code: %%%-------------------------------------------------------------------
  -module(prfHost).
  
  -export([start/3, stop/1,config/3]).
  -export([loop/1]).				%internal
  
  -record(ld, {node, server=[], collectors, config=[], 
               consumer, consumer_data, data=[]}).
  
  -define(LOOP, ?MODULE:loop).
  
  -include("log.hrl").
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  start(Name,{watchdog,Node},Consumer) -> start(Name,Node,Consumer,[prfDog]);
  start(Name,Node,Consumer) -> start(Name,Node,Consumer,Consumer:collectors()).
  
  start(Name, Node, Consumer, Colls) 
    when is_atom(Name),is_atom(Node),is_atom(Consumer) -> 
    SpawnFun = fun()->init(Node,Consumer,Colls) end,
    case whereis(Name) of
      undefined -> register(Name, spawn_link(SpawnFun));
      Pid -> Pid
  
negative.code:     _ -> {Name,not_running}
    end.
  
  assert_proxy(no_proxy) -> ok;
  assert_proxy(Node) ->
    erlang:set_cookie(Node,watchdog),
    case net_adm:ping(Node) of
      pong -> ok;
      _    -> exit({no_proxy,Node})
  end.
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  %% runs in the consumer process
  
  init(Consumer, Node, Proxy) ->
    process_flag(trap_exit,true),
    prf:ticker_even(),
    case Proxy of
      no_proxy ->
        loop(#ld{node = Node, 
  	       proxy = [],
  	       consumer = Consumer, 
  	       collectors = subscribe(Node,Consumer:collectors()),
  	       consumer_data = Consumer:init(Node)});
      _ ->
        loop(#ld{node = Proxy,
  	       proxy = {Node,Consumer:collectors()},
  	       consumer = Consumer, 
  	       collectors = subscribe(Proxy,[prfDog]),
  	       consumer_data = Consumer:init(Node)})
    end.
  
  loop(LD) ->
    receive
  