anchor.diff:      end;
   handle_info({tcp, Socket, Data},#?STATE{ parser = Parser, version = Version } = State) ->
       inet:setopts(Socket, [{active, once}]),
  -    io:format("... [~p] handle tcp data...\n", [?MODULE]),
  -    {ok, SwitchVersionParser} = ofp_parser:new(Version),
  -    {ok, NewParser, Messages} = ofp_parser:parse(SwitchVersionParser, Data),
  -    io:format("... [~p] Messages : ~p\n\n",[?MODULE,Messages]),
  -    {noreply,State};
  +    %% io:format("... [~p] handle tcp data...\n", [?MODULE]),
  +    {ok, NewParser, Messages} = ofp_parser:parse(Parser, Data),
  +    %% io:format("... [~p] Messages : ~p\n\n",[?MODULE,Messages]),
  +    
  +    [ io:format("... [~p] MSG: ~p ...\n",[?MODULE,MSG]) || MSG <- Messages ],
  +    
  +    {noreply,State#?STATE{ parser = NewParser }};
   
   handle_info({tcp_closed, Socket},State) ->
       inet:setopts(Socket, [{active, once}]),
  
positive.code:         _Error ->
              lager:error("...!!! Error in encode of: ~p", [Message])
      end.
  
  handle_msg(#ofp_message{ version = Version,
                           body = #ofp_error_msg{type = hello_failed,
                                                 code = incompatible}} = Message,_Socket) ->
      io:format("___hello_failed...\n"),
      %% io:format("___new hello version: ~p...\n",[Version]),
      %% io:format("___Received message ~p\n", [Message]),
      
      %% io:format(" resending hello with compatible version ... \n", []),
      
      
      ok;
  handle_msg(#ofp_message{ body = #ofp_packet_in{buffer_id = _BufferId,
                                                 match     = _Match,
                                                 data      = _Data}} = Message,_Socket) ->
      io:format("___switch entry...\n"),
      %% io:format("___Received message ~p\n", [Message]),
      ok;
  handle_msg(Message,_Socket) ->
      io:format("___Received message ~p\n", [Message]),
      ok.
  %%---------------------------------------------------------------------------------
  
  version_negotiation(Version,StateVersion) when Version == StateVersion ->
      {ok,Version};
  version_negotiation(Version,StateVersion) when Version < StateVersion ->
      {version_down,Version}; %% Controller needs to use lower version, and maybe resend hello ? ...
  version_negotiation(Version,StateVersion) when Version > StateVersion ->
      {version_up,Version}. %% Controller needs to use higer version, and maybe resend hello ? ...
  
negative.code: hello(Version) ->
      message(#ofp_hello{},Version).
  
  %%--- Helpers --------------
  message(Body,Version) ->
      #ofp_message{version = Version,
                   xid     = get_xid(),
  