co⚡e: Sparkplug™ MQTT edge

CODESYS + MQTT + Sparkplug B = 'Plug & Play' IIoT

Brought to you by: hermsen, i-campbell

MIT License

Diff of /branches/develop/mqttsparkplug/mqttsparkplug/Sparkplug™ MQTT edge and host/Function Blocks/FB_Metric/FB_Metric/svnobj [r926] .. [r927] Maximize Restore

Switch to unified view


Gx_l›!0…jüoâžÀG‘¹·QaSystem.StringL{6f9dac99-8de1-4efc-8465-68ac443b7d08}SpecialFuncL{0db3d7bb-cde0-4416-9a7b-ce49a0124323}NoneImplementationL{3b83b776-fb25-43b8-99f2-3c507c9143fc}TextDocument    L{f3878285-8e4f-490b-bb1b-9acbb7eb04db}

TextLinesL{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}Id
longTagTextBIF THIS^.itfMetricOwner <> 0 THENV    itfMetricOwner.RegisterMetric( THIS^ );HELSIF THIS^.itfPrimaryHost <> 0 THENl    IF __QUERYPOINTER( itfPrimaryHost, pPrimary ) THENT        pPrimary^.RegisterMetric( THIS^ );    END_IFEND_IFInterfaceL{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}¦// An instance of FB_Metric represents a "standard" metric  for primitive datatypes.// usage: Instance it, ¤//  tell it what datatype it should carry (which may NOT change during it's use), 6//  provide a proces value  //  a timestamp.//// Example 0// MyMetric : FB_Metric;!|// MyMetric.Name := "Bool/B1"; // Choose a name which (static)"®// MyMetric.Datatype := Sparkplug.MetricDataType.Boolean; // Choose a datatype (static)#ê// MyMetric.Value := MyProcesValue(); // Provide a process value. Any proces value changes are detected and signaled for sending automaticly, you don't have to do anything special! $v// MyMetric.TimeStamp := Time.Now(); // Provide a timestamp%&:{attribute 'call_after_init'}'–FUNCTION_BLOCK PUBLIC FB_Metric EXTENDS FBF.InstanceBase IMPLEMENTS IMetric(VAR_INPUT)D    itfPrimaryHost : IPrimaryHost;*°    itfMetricOwner : IMetricOwner; // if this is a pool Metric, it will be set by the primary node.  if not then attach it yourself to the correct Owner+END_VAR,VAR_OUTPUT-2    {attribute 'no_copy'}.B    itfMetric : IMetric := THIS^;/Œ    // FALSE when metric value is representative of the remote value. 0z    // TRUE when Edge or Device dies, or when Host is OFFLINE16    isStale : BOOL := TRUE;2VAR3^    pPrimary       : POINTER TO FB_PrimaryHost;4:    _name          : WSTRING;5@    _TS            : T_DateTime;6D    _Status        : MetricStatus;7ì    _NotifyThem    : BOOL           := FALSE; // TRUE if the Value is changed in regard of the previous stored value  8   9 // IElement:0    _itfPrev : IElement;;0    _itfNext : IElement;<*    _itfList : IList;=$   // IPropertyOwner>L   _Properties : LIST; // OF FB_Property?   //IValue@l _dataType : MetricDataType := MetricDataType.Unknown;A&   _uLint    : ULINT;B& _lReal    : LREAL;Cx _WSTRING  : WSTRING(gc_sparkplug.supported_string_lengths);DB   //BYTES VALUE IS NOT IMPLEMENTEDE"UniqueIdGeneratorF324GPOULevelHL{8e575c5b-1d37-49c6-941b-5c0ec7874787}IStandardJ ChildObjectGuidsK8System.Collections.ArrayListL,AddAttributeSubsequentMboolÐÐ-ÐÐ    E
ÐÐ
­âÚÐ-ÐÐ
­åÚÐ-ÐÐ
­ÚÚÐ-ÐÐ
­ÛÚÐ-ÐÐ
­ÝÚÐ-ÐÐ
­ÞÚÐ-ÐÐ
­   ÚÐ-ÐÐ   E
2ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-ÐÐ
­ÚÐ- ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-!ÐÐ
­ÚÐ-"ÐÐ
­ÚÐ-ÐÐ
­ÚÐ-#ÐÐ
­ÚÐ-$ÐÐ
­ ÚÐ-%ÐÐ
­!ÚÐ-&ÐÐ
­"ÚÐ-'ÐÐ
­#ÚÐ-(ÐÐ
­$ÚÐ-)ÐÐ
­%ÚÐ-*ÐÐ
­&ÚÐ-+ÐÐ
­'ÚÐ-,ÐÐ
­(ÚÐ--ÐÐ
­)ÚÐ-.ÐÐ
­*ÚÐ-/ÐÐ
­+ÚÐ-0ÐÐ
­,ÚÐ-1ÐÐ
­-ÚÐ-+ÐÐ
­.ÚÐ-2ÐÐ
­/ÚÐ-3ÐÐ
­0ÚÐ-4ÐÐ
­1ÚÐ-5ÐÐ
­2ÚÐ-6ÐÐ
­3ÚÐ-7ÐÐ
­4ÚÐ-8ÐÐ
­5ÚÐ-9ÐÐ
­6ÚÐ-:ÐÐ
­7ÚÐ-;ÐÐ
­8ÚÐ-<ÐÐ
­9ÚÐ-8ÐÐ
­:ÚÐ-=ÐÐ
­;ÚÐ->ÐÐ
­<ÚÐ-8ÐÐ
­=ÚÐ-?ÐÐ
­>ÚÐ-@ÐÐ
­?ÚÐ-AÐÐ
­@ÚÐ-BÐÐ
­AÚÐ-CÐÐ
­BÚÐ-DÐÐ
­ÚÐ-+ÐE-FÐGH-IJKÐLM­


	a/branches/develop/mqttsparkplug/mqttsparkplug/Sparkplug™ MQTT edge and host/Function Blocks/FB_Metric/FB_Metric/svnobj		b/branches/develop/mqttsparkplug/mqttsparkplug/Sparkplug™ MQTT edge and host/Function Blocks/FB_Metric/FB_Metric/svnobj
1	Gx_lß!0jüon}¨ÎóI	1	Gx_l›!0…jüoâžÀG‘¹·QaSystem.StringL{6f9dac99-8de1-4efc-8465-68ac443b7d08}SpecialFuncL{0db3d7bb-cde0-4416-9a7b-ce49a0124323}NoneImplementationL{3b83b776-fb25-43b8-99f2-3c507c9143fc}TextDocument L{f3878285-8e4f-490b-bb1b-9acbb7eb04db}
2	Þ·System.StringL{6f9dac99-8de1-4efc-8465-68ac443b7d08}SpecialFuncL{0db3d7bb-cde0-4416-9a7b-ce49a0124323}NoneImplementationL{3b83b776-fb25-43b8-99f2-3c507c9143fc}TextDocument L{f3878285-8e4f-490b-bb1b-9acbb7eb04db}
3	TextLinesL{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}Id longTagTextBIF THIS^.itfMetricOwner <> 0 THENV itfMetricOwner.RegisterMetric( THIS^ );HELSIF THIS^.itfPrimaryHost <> 0 THENl IF __QUERYPOINTER( itfPrimaryHost, pPrimary ) THENT pPrimary^.RegisterMetric( THIS^ ); END_IFEND_IFInterfaceL{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}¦// An instance of FB_Metric represents a "standard" metric for primitive datatypes.// usage: Instance it, ¤// tell it what datatype it should carry (which may NOT change during it's use), 6// provide a proces value // a timestamp.//// Example 0// MyMetric : FB_Metric;!\|// MyMetric.Name := "Bool/B1"; // Choose a name which (static)"®// MyMetric.Datatype := Sparkplug.MetricDataType.Boolean; // Choose a datatype (static)#ê// MyMetric.Value := MyProcesValue(); // Provide a process value. Any proces value changes are detected and signaled for sending automaticly, you don't have to do anything special! $v// MyMetric.TimeStamp := Time.Now(); // Provide a timestamp%&:{attribute 'call_after_init'}'–FUNCTION_BLOCK PUBLIC FB_Metric EXTENDS FBF.InstanceBase IMPLEMENTS IMetric(VAR_INPUT)D itfPrimaryHost : IPrimaryHost;° itfMetricOwner : IMetricOwner; // if this is a pool Metric, it will be set by the primary node. if not then attach it yourself to the correct Owner+END_VAR,VAR_OUTPUT-2 {attribute 'no_copy'}.B itfMetric : IMetric := THIS^;/Œ // FALSE when metric value is representative of the remote value. 0z // TRUE when Edge or Device dies, or when Host is OFFLINE16 isStale : BOOL := TRUE;2VAR3^ pPrimary : POINTER TO FB_PrimaryHost;4: _name : WSTRING;5@ _TS : T_DateTime;6D _Status : MetricStatus;7ì _NotifyThem : BOOL := FALSE; // TRUE if the Value is changed in regard of the previous stored value 8 9 // IElement:0 _itfPrev : IElement;;0 _itfNext : IElement;< _itfList : IList;= //IValue>l _dataType : MetricDataType := MetricDataType.Unknown;?& _uLint : ULINT;@& _lReal : LREAL;Ax _WSTRING : WSTRING(gc_sparkplug.supported_string_lengths);BB //BYTES VALUE IS NOT IMPLEMENTEDC"UniqueIdGeneratorD270EPOULevelFL{8e575c5b-1d37-49c6-941b-5c0ec7874787}GStandardH ChildObjectGuidsI8System.Collections.ArrayListJ,AddAttributeSubsequentKboolÐÐ-ÐÐ E	2	TextLinesL{a5de0b0b-1cb5-4913-ac21-9d70293ec00d}Id longTagTextBIF THIS^.itfMetricOwner <> 0 THENV itfMetricOwner.RegisterMetric( THIS^ );HELSIF THIS^.itfPrimaryHost <> 0 THENl IF __QUERYPOINTER( itfPrimaryHost, pPrimary ) THENT pPrimary^.RegisterMetric( THIS^ ); END_IFEND_IFInterfaceL{a9ed5b7e-75c5-4651-af16-d2c27e98cb94}¦// An instance of FB_Metric represents a "standard" metric for primitive datatypes.// usage: Instance it, ¤// tell it what datatype it should carry (which may NOT change during it's use), 6// provide a proces value // a timestamp.//// Example 0// MyMetric : FB_Metric;!\|// MyMetric.Name := "Bool/B1"; // Choose a name which (static)"®// MyMetric.Datatype := Sparkplug.MetricDataType.Boolean; // Choose a datatype (static)#ê// MyMetric.Value := MyProcesValue(); // Provide a process value. Any proces value changes are detected and signaled for sending automaticly, you don't have to do anything special! $v// MyMetric.TimeStamp := Time.Now(); // Provide a timestamp%&:{attribute 'call_after_init'}'–FUNCTION_BLOCK PUBLIC FB_Metric EXTENDS FBF.InstanceBase IMPLEMENTS IMetric(VAR_INPUT)D itfPrimaryHost : IPrimaryHost;° itfMetricOwner : IMetricOwner; // if this is a pool Metric, it will be set by the primary node. if not then attach it yourself to the correct Owner+END_VAR,VAR_OUTPUT-2 {attribute 'no_copy'}.B itfMetric : IMetric := THIS^;/Œ // FALSE when metric value is representative of the remote value. 0z // TRUE when Edge or Device dies, or when Host is OFFLINE16 isStale : BOOL := TRUE;2VAR3^ pPrimary : POINTER TO FB_PrimaryHost;4: _name : WSTRING;5@ _TS : T_DateTime;6D _Status : MetricStatus;7ì _NotifyThem : BOOL := FALSE; // TRUE if the Value is changed in regard of the previous stored value 8 9 // IElement:0 _itfPrev : IElement;;0 _itfNext : IElement;< _itfList : IList;=$ // IPropertyOwner>L _Properties : LIST; // OF FB_Property? //IValue@l _dataType : MetricDataType := MetricDataType.Unknown;A& _uLint : ULINT;B& _lReal : LREAL;Cx _WSTRING : WSTRING(gc_sparkplug.supported_string_lengths);DB //BYTES VALUE IS NOT IMPLEMENTEDE"UniqueIdGeneratorF324GPOULevelHL{8e575c5b-1d37-49c6-941b-5c0ec7874787}IStandardJ ChildObjectGuidsK8System.Collections.ArrayListL,AddAttributeSubsequentMboolÐÐ-ÐÐ E
4	ÐÐ âÚÐ-ÐÐ åÚÐ-ÐÐ ÚÚÐ-ÐÐ ÛÚÐ-ÐÐ ÝÚÐ-ÐÐ ÞÚÐ-ÐÐ ÚÐ-ÐÐ E	3	ÐÐ âÚÐ-ÐÐ åÚÐ-ÐÐ ÚÚÐ-ÐÐ ÛÚÐ-ÐÐ ÝÚÐ-ÐÐ ÞÚÐ-ÐÐ ÚÐ-ÐÐ E
5	/ÐÐ ôÚÐ-ÐÐ üÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ þÚÐ- ÐÐ ÚÐ-ÐÐ ÚÐ-!ÐÐ ÿÚÐ-"ÐÐ ÚÐ-ÐÐ	4	2ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ-ÐÐ ÚÐ- ÐÐ ÚÐ-ÐÐ ÚÐ-!ÐÐ ÚÐ-"ÐÐ ÚÐ-ÐÐ ÚÐ-#ÐÐ ÚÐ-$ÐÐ ÚÐ-%ÐÐ !ÚÐ-&ÐÐ "ÚÐ-'ÐÐ #ÚÐ-(ÐÐ $ÚÐ-)ÐÐ %ÚÐ-ÐÐ &ÚÐ-+ÐÐ 'ÚÐ-,ÐÐ (ÚÐ--ÐÐ )ÚÐ-.ÐÐ ÚÐ-/ÐÐ +ÚÐ-0ÐÐ ,ÚÐ-1ÐÐ -ÚÐ-+ÐÐ .ÚÐ-2ÐÐ /ÚÐ-3ÐÐ 0ÚÐ-4ÐÐ 1ÚÐ-5ÐÐ 2ÚÐ-6ÐÐ 3ÚÐ-7ÐÐ 4ÚÐ-8ÐÐ 5ÚÐ-9ÐÐ 6ÚÐ-:ÐÐ 7ÚÐ-;ÐÐ 8ÚÐ-<ÐÐ 9ÚÐ-8ÐÐ :ÚÐ-=ÐÐ ;ÚÐ->ÐÐ <ÚÐ-8ÐÐ =ÚÐ-?ÐÐ >ÚÐ-@ÐÐ ?ÚÐ-AÐÐ @ÚÐ-BÐÐ AÚÐ-CÐÐ BÚÐ-DÐÐ ÚÐ-+ÐE-FÐGH-IJKÐLM
6	ÚÐ-#ÐÐ ÚÐ-$ÐÐ ýÚÐ-%ÐÐ µÚÐ-&ÐÐ ¶ÚÐ-'ÐÐ ·ÚÐ-(ÐÐ ¸ÚÐ-)ÐÐ ¹ÚÐ-*ÐÐ ºÚÐ-+ÐÐ »ÚÐ-,ÐÐ ¼ÚÐ--ÐÐ ½ÚÐ-.ÐÐ ¾ÚÐ-/ÐÐ ¿ÚÐ-0ÐÐ ÀÚÐ-1ÐÐ ÁÚÐ-+ÐÐ ÂÚÐ-2ÐÐ ÃÚÐ-3ÐÐ ÄÚÐ-4ÐÐ óÚÐ-5ÐÐ ÌÚÐ-6ÐÐ ÏÚÐ-7ÐÐ ÑÚÐ-8ÐÐ ÖÚÐ-9ÐÐ ×ÚÐ-:ÐÐ ØÚÐ-;ÐÐ ÙÚÐ-<ÐÐ ìÚÐ-8ÐÐ íÚÐ-=ÐÐ òÚÐ->ÐÐ îÚÐ-?ÐÐ ïÚÐ-@ÐÐ ðÚÐ-AÐÐ ñÚÐ-BÐÐ ÚÐ-+ÐC-DÐEF-GHIÐJK