anchor.diff:              ssl:setopts(SslSocket, [{active, true}, {mode, binary}]),
   
               CommonName = common_name(SslSocket),
  -            lager:debug("ssl_cert: ~p", [CommonName]),
  +	    lager:md([{wtp, CommonName}]),
  +	    lager:debug("ssl_cert: ~p", [CommonName]),
   
               maybe_takeover(CommonName),
               capwap_wtp_reg:register_args(CommonName, WTPControlChannelAddress),
  
positive.code: 
  data_check({keep_alive, DataPath, WTPDataChannelAddress, Header, PayLoad}, _From,
  	   State = #state{ctrl_stream = CtrlStreamState}) ->
      lager:info("in DATA_CHECK got expected keep_alive: ~p", [{Header, PayLoad}]),
      capwap_wtp_reg:register(WTPDataChannelAddress),
      MTU = capwap_stream:get_mtu(CtrlStreamState),
      capwap_dp:add_wtp(WTPDataChannelAddress, MTU),
  
negative.code: format_peer(IP) ->
      io_lib:format("~p", [IP]).
  
  peer_log_str(State = #state{ctrl_channel_address = WTPControlChannelAddress}) ->
      peer_log_str(WTPControlChannelAddress, State).
  
  peer_log_str(Address, #state{id = undefined}) ->
      io_lib:format("~p", [Address]);
  peer_log_str(Address, #state{id = Id}) ->
      io_lib:format("~s[~s]", [Id, format_peer(Address)]).
  
  next_state(NextStateName, State)
    when NextStateName == idle; NextStateName == run ->
  