megaco_test_msg_v2_lib.erl

来自「OTP是开放电信平台的简称」· ERL 代码 · 共 1,969 行 · 第 1/5 页

    #'EventParameter'{eventParameterName = N, 
		      value              = V}.

cre_EventParameter(N, V, relation = Tag, R) 
  when list(N), list(V), atom(R) ->
    EI = {Tag, R},
    #'EventParameter'{eventParameterName = N, 
		      value              = V,
		      extraInfo          = EI};
cre_EventParameter(N, V, range = Tag, B) 
  when list(N), list(V), atom(B) ->
    EI = {Tag, B},
    #'EventParameter'{eventParameterName = N, 
		      value              = V,
		      extraInfo          = EI};
cre_EventParameter(N, V, sublist = Tag, B) 
  when list(N), list(V), atom(B) ->
    EI = {Tag, B},
    #'EventParameter'{eventParameterName = N, 
		      value              = V,
		      extraInfo          = EI}.

cre_ServiceChangeRequest(TermIDs, SCP) 
  when list(TermIDs),
       record(SCP, 'ServiceChangeParm') ->
    #'ServiceChangeRequest'{terminationID      = TermIDs, 
			    serviceChangeParms = SCP}.

cre_ServiceChangeReply(TermIDs, {Tag, R} = SCR) 
  when list(TermIDs), atom(Tag), tuple(R) ->
    #'ServiceChangeReply'{terminationID       = TermIDs, 
			  serviceChangeResult = SCR}.

cre_ServiceChangeResult(ED) when record(ED, 'ErrorDescriptor') ->
    {errorDescriptor, ED};
cre_ServiceChangeResult(SCRP) when record(SCRP, 'ServiceChangeResParm') ->
    {serviceChangeResParms, SCRP}.

%% cre_WildcardField(L) when list(L), length(L) == 1 -> L.

cre_TerminationID(W, ID) 
  when list(W), 
       list(ID), 1 =< length(ID), length(ID) =< 8 ->
    #'TerminationID'{wildcard = W, 
		     id       = ID}.

cre_TerminationIDList(L) when list(L) ->
    L.

cre_MediaDescriptor() ->
    #'MediaDescriptor'{}.

cre_MediaDescriptor(TSD) when record(TSD, 'TerminationStateDescriptor') ->
    #'MediaDescriptor'{termStateDescr = TSD};
cre_MediaDescriptor(SP) when record(SP, 'StreamParms') ->
    Streams = {oneStream, SP},
    #'MediaDescriptor'{streams = Streams};
cre_MediaDescriptor([H|_] = SDs) when record(H, 'StreamDescriptor') ->
    Streams = {multiStream, SDs},
    #'MediaDescriptor'{streams = Streams}.

cre_MediaDescriptor(TSD, SP) 
  when record(TSD, 'TerminationStateDescriptor'), 
       record(SP, 'StreamParms') ->
    Streams = {oneStream, SP},
    #'MediaDescriptor'{termStateDescr = TSD,
		       streams        = Streams};
cre_MediaDescriptor(TSD, [H|_] = SDs) 
  when record(TSD, 'TerminationStateDescriptor'), 
       record(H, 'StreamDescriptor') ->
    Streams = {multiStream, SDs},
    #'MediaDescriptor'{termStateDescr = TSD,
		       streams        = Streams}.

cre_StreamDescriptor(SID, SP) when integer(SID), record(SP, 'StreamParms') ->
    #'StreamDescriptor'{streamID    = SID, 
			streamParms = SP}.

cre_StreamParms() ->
    #'StreamParms'{}.

cre_StreamParms(LCD) when record(LCD, 'LocalControlDescriptor') ->
    #'StreamParms'{localControlDescriptor = LCD};
cre_StreamParms(LD) when record(LD, 'LocalRemoteDescriptor') ->
    #'StreamParms'{localDescriptor = LD}.

cre_StreamParms(LCD, LD) 
  when (is_record(LCD, 'LocalControlDescriptor') or (LCD == asn1_NOVALUE)) and
       (is_record(LD,  'LocalRemoteDescriptor')  or (LD  == asn1_NOVALUE)) ->
    #'StreamParms'{localControlDescriptor = LCD,
		   localDescriptor        = LD}.

cre_StreamParms(LCD, LD, RD) 
  when (is_record(LCD, 'LocalControlDescriptor') or (LCD == asn1_NOVALUE)) and
       (is_record(LD,  'LocalRemoteDescriptor')  or (LD  == asn1_NOVALUE)) and
       (is_record(RD,  'LocalRemoteDescriptor')  or (RD  == asn1_NOVALUE)) ->
    #'StreamParms'{localControlDescriptor = LCD,
		   localDescriptor        = LD,
		   remoteDescriptor       = RD}.

cre_LocalControlDescriptor(SM) when atom(SM) ->
    #'LocalControlDescriptor'{streamMode = SM, propertyParms = []};
cre_LocalControlDescriptor([H|_] = PP) when record(H, 'PropertyParm') ->
    #'LocalControlDescriptor'{propertyParms = PP}.

cre_LocalControlDescriptor(SM, [H|_] = PP) 
  when atom(SM), record(H, 'PropertyParm') ->
    #'LocalControlDescriptor'{streamMode    = SM,
			      propertyParms = PP}.

cre_LocalControlDescriptor(SM, RV, RG, [H|_] = PP) 
  when is_atom(SM) and
     ((RV == true) or (RV == false) or (RV == asn1_NOVALUE)) and
     ((RG == true) or (RG == false) or (RG == asn1_NOVALUE)) and
     is_record(H, 'PropertyParm') ->
    #'LocalControlDescriptor'{streamMode    = SM, 
			      reserveValue  = RV, 
			      reserveGroup  = RG, 
			      propertyParms = PP}.
    
cre_StreamMode(sendOnly = M) ->
    M;
cre_StreamMode(recvOnly = M) ->
    M;
cre_StreamMode(sendRecv = M) ->
    M;
cre_StreamMode(inactive = M) ->
    M;
cre_StreamMode(loopBack = M) ->
    M.

cre_PropertyParm(N, [H|_] = V) when list(N), list(H) ->
    #'PropertyParm'{name = N, value = V}.

cre_PropertyParm(N, [H|_] = V, relation = Tag, R) 
  when list(N), list(H), atom(R) ->
    EI = {Tag, R},
    #'PropertyParm'{name = N, value = V, extraInfo = EI};
cre_PropertyParm(N, [H|_] = V, range = Tag, B) 
  when list(N), list(H), atom(B) ->
    EI = {Tag, B},
    #'PropertyParm'{name = N, value = V, extraInfo = EI};
cre_PropertyParm(N, [H|_] = V, sublist = Tag, B) 
  when list(N), list(H), atom(B) ->
    EI = {Tag, B},
    #'PropertyParm'{name = N, value = V, extraInfo = EI}.


cre_Name(N) when list(N), length(N) == 2 ->
    N.

cre_PkgdName(N) when is_list(N) ->
    case string:tokens(N, [$\\]) of
	[_PkgName, _ItemID] ->
	    N;
	_ ->
	    error({invalid_PkgdName, N})
    end.
cre_PkgdName(root, root) ->
    "*/*";
cre_PkgdName(PackageName, root) 
  when is_list(PackageName) and (length(PackageName) =< 64) ->
    PackageName ++ "/*";
cre_PkgdName(PackageName, ItemID) 
  when ((is_list(PackageName) and (length(PackageName) =< 64)) and
	(is_list(ItemID)      and (length(ItemID) =< 64))) ->
    PackageName ++ "/" ++ ItemID;
cre_PkgdName(PackageName, ItemID) ->
    error({invalid_PkgdName, {PackageName, ItemID}}).

cre_Relation(greaterThan = R) ->
    R;
cre_Relation(smallerThan = R) ->
    R;
cre_Relation(unequalTo = R) ->
    R.

cre_LocalRemoteDescriptor([H|_] = PGs) when list(H) ->
    #'LocalRemoteDescriptor'{propGrps = PGs}.

cre_PropertyGroup([H|_] = PG) when record(H, 'PropertyParm') ->
    PG.
    
cre_TerminationStateDescriptor([H|_] = PPs) when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms = PPs}.

cre_TerminationStateDescriptor([H|_] = PPs, off = EBC) 
  when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms      = PPs,
				  eventBufferControl = EBC};
cre_TerminationStateDescriptor([H|_] = PPs, lockStep = EBC) 
  when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms      = PPs,
				  eventBufferControl = EBC};
cre_TerminationStateDescriptor([H|_] = PPs, test = SS) 
  when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms = PPs,
				  serviceState  = SS};
cre_TerminationStateDescriptor([H|_] = PPs, outOfSvc = SS) 
  when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms = PPs,
				  serviceState  = SS};
cre_TerminationStateDescriptor([H|_] = PPs, inSvc = SS) 
  when record(H, 'PropertyParm') ->
    #'TerminationStateDescriptor'{propertyParms = PPs,
				  serviceState  = SS}.

cre_TerminationStateDescriptor([H|_] = PPs, EMC, SS) 
  when record(H, 'PropertyParm'),
       ((EMC == off)  or (EMC == lockStep)) and
       ((SS  == test) or (SS  == outOfSvc) or (SS == inSvc)) ->
    #'TerminationStateDescriptor'{propertyParms      = PPs,
				  eventBufferControl = EMC,
				  serviceState       = SS}.

cre_EventBufferControl(off = EBC) ->
    EBC;
cre_EventBufferControl(lockStep = EBC) ->
    EBC.

cre_ServiceState(test = SS) ->
    SS;
cre_ServiceState(outOfSvc = SS) ->
    SS;
cre_ServiceState(inSvc = SS) ->
    SS.

cre_MuxDescriptor(MT, [H|_] = TL) 
  when atom(MT), record(H, 'TerminationID') ->
    #'MuxDescriptor'{muxType = MT, termList = TL}.

%% cre_MuxDescriptor(MT, [H|_] = TL, NSD) 
%%   when atom(MT), record(H, 'TerminationID'), record(NSD, 'NonStandardData') ->
%%     #'MuxDescriptor'{muxType = MT, termList = TL, nonStandardData = NSD}.

cre_MuxType(h221 = MT) ->
    MT;
cre_MuxType(h223 = MT) ->
    MT;
cre_MuxType(h226 = MT) ->
    MT;
cre_MuxType(v76 = MT) ->
    MT;
cre_MuxType(nx64k = MT) ->
    MT.

cre_StreamID(Val) when 0 =< Val, Val =< 65535 ->
    Val;
cre_StreamID(Val) ->
    exit({invalid_ContextID, Val}).

%% RequestID must be present if eventList is non empty
cre_EventsDescriptor() ->
    #'EventsDescriptor'{eventList = []}.

cre_EventsDescriptor(RID, [H|_] = EL) 
  when integer(RID), record(H, 'RequestedEvent') ->
    #'EventsDescriptor'{requestID = RID, eventList = EL}.
    
cre_RequestedEvent(N) ->
    #'RequestedEvent'{pkgdName = N}.

cre_RequestedEvent(N, [H|_] = EPL) 
  when list(N),
       record(H, 'EventParameter') ->
    #'RequestedEvent'{pkgdName  = N,
		      evParList = EPL};
cre_RequestedEvent(N, EA) 
  when list(N), 
       record(EA, 'RequestedActions')->
    #'RequestedEvent'{pkgdName    = N,
		      eventAction = EA}.


cre_RequestedEvent(N, SID, [H|_] = EPL) 
  when list(N), 
       integer(SID), 
       record(H, 'EventParameter') ->
    #'RequestedEvent'{pkgdName  = N,
		      streamID  = SID, 
		      evParList = EPL};
cre_RequestedEvent(N, EA, [H|_] = EPL) 
  when list(N), 
       record(EA, 'RequestedActions'), 
       record(H, 'EventParameter') ->
    #'RequestedEvent'{pkgdName     = N,
		      eventAction  = EA, 
		      evParList    = EPL}.

cre_RequestedEvent(N, SID, EA, [H|_] = EPL) 
  when list(N), 
       integer(SID), 
       record(EA, 'RequestedActions'), 
       record(H, 'EventParameter') ->
    #'RequestedEvent'{pkgdName     = N,
		      streamID     = SID, 
		      eventAction  = EA, 
		      evParList    = EPL}.

cre_RequestedActions() ->
    #'RequestedActions'{}.

cre_RequestedActions(KA) 
  when (KA == true) or (KA == true) or (KA == asn1_NOVALUE) ->
    #'RequestedActions'{keepActive = KA};
cre_RequestedActions(SE) 
  when is_record(SE, 'SecondEventsDescriptor') or (SE == asn1_NOVALUE) ->
    #'RequestedActions'{secondEvent = SE};
cre_RequestedActions(SD) 
  when is_list(SD) or (SD == asn1_NOVALUE) ->
    #'RequestedActions'{signalsDescriptor = SD};
cre_RequestedActions({Tag, _} = EDM) 
  when is_atom(Tag) or (EDM == asn1_NOVALUE) ->
    #'RequestedActions'{eventDM = EDM}.

cre_RequestedActions(KA, {Tag, _} = EDM, SE, SD) 
  when ((KA == true) or (KA == true) or (KA == asn1_NOVALUE)) and
       (is_atom(Tag) or (EDM == asn1_NOVALUE)) and
       (is_record(SE, 'SecondEventsDescriptor') or (SE == asn1_NOVALUE)) and
       (is_list(SD) or (SD == asn1_NOVALUE)) ->
    #'RequestedActions'{keepActive        = KA, 
			eventDM           = EDM, 
			secondEvent       = SE, 
			signalsDescriptor = SD}.

cre_EventDM(N) when list(N) ->
    {digitMapName, N};
cre_EventDM(V) when record(V, 'DigitMapValue') ->
    {digitMapValue, V}.

cre_SecondEventsDescriptor([H|_] = EL) 
  when record(H, 'SecondRequestedEvent') ->
    #'SecondEventsDescriptor'{eventList = EL}.
    
cre_SecondEventsDescriptor(RID, [H|_] = EL) 
  when integer(RID), record(H, 'SecondRequestedEvent') ->
    #'SecondEventsDescriptor'{requestID = RID, eventList = EL}.
    
cre_SecondRequestedEvent(N, [H|_] = EPL) 
  when list(N),
       record(H, 'EventParameter') ->
    #'SecondRequestedEvent'{pkgdName  = N,
			    evParList = EPL}.

cre_SecondRequestedEvent(N, SID, [H|_] = EPL) 
  when list(N), 
       integer(SID), 
       record(H, 'EventParameter') ->
    #'SecondRequestedEvent'{pkgdName  = N,
			    streamID  = SID, 
			    evParList = EPL};
cre_SecondRequestedEvent(N, EA, [H|_] = EPL) 
  when list(N), 
       record(EA, 'SecondRequestedActions'), 
       record(H, 'EventParameter') ->
    #'SecondRequestedEvent'{pkgdName     = N,
			    eventAction  = EA, 
			    evParList    = EPL}.

cre_SecondRequestedEvent(N, SID, EA, [H|_] = EPL) 
  when list(N), 
       integer(SID), 
       record(EA, 'SecondRequestedActions'), 
       record(H, 'EventParameter') ->
    #'SecondRequestedEvent'{pkgdName     = N,
			    streamID     = SID, 
			    eventAction  = EA, 
			    evParList    = EPL}.

cre_SecondRequestedActions() ->
    #'SecondRequestedActions'{}.

cre_SecondRequestedActions(KA) 
  when ((KA == true) or (KA == false) or (KA == asn1_NOVALUE)) ->
    #'SecondRequestedActions'{keepActive = KA};
cre_SecondRequestedActions(SD) when list(SD) ->
    #'SecondRequestedActions'{signalsDescriptor = SD};
cre_SecondRequestedActions({Tag, _} = EDM) when atom(Tag) ->
    #'SecondRequestedActions'{eventDM = EDM}.

cre_SecondRequestedActions(KA, SD) 
  when ((KA == true) or (KA == false) or (KA == asn1_NOVALUE)) and
       is_list(SD) ->
    #'SecondRequestedActions'{keepActive = KA, signalsDescriptor = SD};
cre_SecondRequestedActions(KA, {Tag, _} = EDM) 
  when ((KA == true) or (KA == false) or (KA == asn1_NOVALUE)) and
       is_atom(Tag) ->
    #'SecondRequestedActions'{keepActive = KA, eventDM = EDM}.

cre_SecondRequestedActions(KA, {Tag, _} = EDM, SD) 
  when ((KA == true) or (KA == false) or (KA == asn1_NOVALUE)) and
       is_atom(Tag), 
       is_list(SD) ->
    #'SecondRequestedActions'{keepActive        = KA,