anchor.diff:  	Msg = #m3ua_msg{version = 1, msg_class = MsgClass, msg_type = MsgType, payload = Params},
   	send_sctp_to_peer(LoopDat, Msg),
   	% start T(ack) timer and wait for ASP_UP_ACK
  +	timer:cancel(LoopDat#m3ua_state.t_ack),
   	{ok, Tack} = timer:apply_after(?T_ACK_TIMEOUT, gen_fsm, send_event,
   				 [self(), {timer_expired, t_ack, {MsgClass, MsgType, Params}}]),
   	{next_state, State, LoopDat#m3ua_state{t_ack = Tack}}.
  
positive.code: 			   inbound_streams = _InStreams, assoc_id = _AssocId} = SAC,
  	case SacState of 
  		comm_up ->
  			% FIXME: primmitive to the user
  			LoopDat2 = LoopDat;
  		comm_lost ->
  			LoopDat2 = reconnect_sctp(LoopDat);
  		addr_unreachable ->
  			LoopDat2 = reconnect_sctp(LoopDat)
  
negative.code: 	{next_state, State, LoopDat}.
  
  
  
  rx_m3ua(Msg = #m3ua_msg{version = 1, msg_class = ?M3UA_MSGC_MGMT,
  			msg_type = ?M3UA_MSGT_MGMT_NTFY}, State, LoopDat) ->
  	io:format("M3UA NOTIFY~n"),
  	send_prim_to_user(LoopDat, osmo_util:make_prim('M','NOTIFY',indication,[Msg])),
  	{next_state, State, LoopDat};
  
  rx_m3ua(Msg = #m3ua_msg{version = 1, msg_class = ?M3UA_MSGC_ASPSM,
  