anchor.diff:  -module(worker).
   -export([init/1, terminate/2, handle_ssh_msg/2, handle_msg/2]).
   
  +prefixed(Format) -> prefixed(Format, []).
   prefixed(Format, Data) when length(Format) /= 0 ->
     F = lists:concat(["worker[~w]: ", Format, "~n"]),
     D = [self() | Data],
  
positive.code: 
  clustercc_main() ->
    {clustercc, Ref, ID} = receive V -> V end,
  
    Node = case node_manager:get() of
      undefined -> throw(enoent);
      N         -> N
    end,
    {ok, Socket} = gen_tcp:connect(Node, 3632, []),
  
    TX = fun(Data) ->
  
negative.code: 
    loop(TX, RX),
  
    gen_tcp:close(Socket).
  
  loop(TX, RX) ->
    receive
      {tcp, _, Data}    -> RX(Data), loop(TX, RX);
      {ssh, _, _, Data} -> TX(Data), loop(TX, RX);
  
      {tcp_closed, _} -> closed;
      {ssh_closed, _} -> closed;
  