Post by hermsen on Ticket #16: Implement SparkPlugB Device discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -12,6 +12,6 @@ - Implements the same dynamic arrays of Sparkplug values as EoN, - The EoN can iterate through the connected FB_Devices via a list and sends all relevant Data to Primary SCADA -[x] v1.1.x.x solution implements the basis for a List of Devices -[ ] V1.4.x.x solution sends all Device Data too -[ ] V1.7.x.x solution can receive, digest and follow up DCMD's +* [x] v1.1.x.x solution implements the basis for a List of Devices +* [ ] V1.4.x.x solution sends all Device Data too +* [ ] V1.7.x.x solution can receive, digest and follow up DCMD's
Last updated: 2021-08-10
Post by hermsen on Ticket #136: Edge seems to publish "empty" payloads discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -1,5 +1,7 @@ The edge publishes somehow publishes payloads that are valid but empty i.e; Payloads contain timestamp and a valid seqnum, but the metrics section is empty; + +NDATA ~~~ {"timestamp":1619874081095,"metrics":[],"seq":218} ~~~
Last updated: 2021-08-10
Post by i-campbell on Ticket #3: Build a SparkplugB scada in CODESYS discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Milestone: 2.0.0.0: Primary Server Application --> 2.0.0.0: SparkplugB Primary Node
Last updated: 2021-08-10
Post by i-campbell on Ticket #11: FB_Payload discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -22,17 +22,17 @@ [x] [x] [x] [x] Payload.metrics[].metadata.md5 [x] [x] [x] [x] Payload.metrics[].metadata.description Payload.metrics[].metadata.extensions[] //none -[x] [x] [ ] [ ] Payload.metrics[].properties.keys[] -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].type -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].is_null -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].int_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].long_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].float_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].double_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].boolean_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].string_value -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].propertyset_value. //(RECURSIVE PROPERTIES) -[x] [x] [ ] [ ] Payload.metrics[].properties.values[].propertysets_value.propertyset[]. //(RECURSIVE PROPERTIES) +[x] [x] [x] [ ] Payload.metrics[].properties.keys[] +[x] [x] [x] [ ] Payload.metrics[].properties.values[].type +[x] [x] [x] [ ] Payload.metrics[].properties.values[].is_null +[x] [x] [x] [ ] Payload.metrics[].properties.values[].int_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].long_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].float_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].double_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].boolean_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].string_value +[x] [x] [x] [ ] Payload.metrics[].properties.values[].propertyset_value. //(RECURSIVE PROPERTIES) +[x] [x] [x] [ ] Payload.metrics[].properties.values[].propertysets_value.propertyset[]. //(RECURSIVE PROPERTIES) Payload.metrics[].properties.values[].extension_value //none Payload.metrics[].properties.extensions[] //none [x] [x] [x] [x] Payload.metrics[].int_value
Last updated: 2021-08-10
Post by aliazzz on Ticket #54: FB_EoN: PublishNodeData topic error discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
FIxed all topics accordingly in v0.0.0.21
Last updated: 2021-08-10
Post by hermsen on Ticket #135: Project Homepage: Update guides discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
assigned_to: h-hermsen
Last updated: 2021-08-10
Post by hermsen on Ticket #100: EoN state machine should return to offline when an MQTT error occurs discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: accepted --> closed
Last updated: 2021-08-10
Post by aliazzz on Ticket #4: Create session state management for EoN Node discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: open --> accepted assigned_to: aliazzz
Last updated: 2021-08-10
Post by aliazzz on Ticket #1: Create Introductionpage discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: accepted --> closed
Last updated: 2021-08-10
Post by aliazzz on Ticket #63: EoN: NDATA puts elements into a second list discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
This ticket is implemented but also bring hurdles we did not see. Problem: 1) The NDATA Encoder is not initialised(!) so when we detect changes to data we add them to the not initialised encoder. 2) The encoder thus throws a "NotEnoughPayload..." 3) more issue's down the road which involve wrong order initialisation. Solution: Revision of (NDATA) sending strategy: BEFORE detection of changed data we must initialise the NDATA payload to accept data. Add a new method named (some suggestions) might be SparkPlugBSimple.PrepareNDATA( AllMetricsList ); or SparkPlugBSimple.InitNDATA( AllMetricsList ); Then, if data CHANGES are detected we accept the changed values during this single cycle into the encoder (we take a 'data snapshot') during this cycle. After this we BLOCK the change detection during the "Publish Period Blocking Time" so the Encoder will not receive changes during the block period(!) Then we SEND the payload immediately also DURING this BLOCK period (at start of) via the excisting albeit refactored method: SparkPlugBSimple.PublishNDATA( Enable, AllMetricsList ); Summed up in short 1) Init Encoder in ususual way, 2) ChangeDetection (adds data to internal encoder), 3) Block ChangeDetection and immediately Send Payload, 4) Repeat from step 1.
Last updated: 2021-08-10
Post by aliazzz on Ticket #39: FB_SparkplugB_SimpleEncoder discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Good Catch! I plugged this hole.
Last updated: 2021-08-10
Post by hermsen on Ticket #69: MQTT: ping interval should = keep alive time discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Just slap 1000* in between the TO_TIME conversion, problem solved.
Last updated: 2021-08-10
Post by aliazzz on Ticket #32: FB_MQTT_PubSub Considerations discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -8,5 +8,7 @@ To mitigate send/receive issues, maybe we should implement a send/receive message buffer? This buffer then can act as LIFO on and ideally isn't filled (the contents is sent/received directly), but when many events occur at once, the buffer gets utilized. -If we implement this buffer, where should it be implemented? +Is such a buffer allready implemented within the MQTT lib? +If not, and we should implement this buffer, where should it be implemented? My guts say it should be in the vicinity of the Payload either before/after or embedded into. +Ideas?
Last updated: 2021-08-10
Post by i-campbell on Ticket #3: Build a SparkplugB scada in CODESYS discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Milestone: SFP: SCADA --> 2.0.0.0: SCADA
Last updated: 2021-08-10
Post by i-campbell on Ticket #31: Define how Store & Forward should be implemented (historical data) discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Sending: There is a field "isHistorical". Basically send the payload as normal
Last updated: 2021-08-10
Post by hermsen on Ticket #136: Edge seems to publish "empty" payloads discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Fixed in v1.4.2.10
Last updated: 2021-08-10
Post by i-campbell on Ticket #11: FB_Payload discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -42,15 +42,15 @@ [x] [x] [x] [x] Payload.metrics[].boolean_value [x] [x] [x] [x] Payload.metrics[].string_value [x] [x] [x] [x] Payload.metrics[].bytes_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.num_of_columns -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.columns[] -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.types[] -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].int_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].long_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].float_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].double_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].boolean_value -[x] [x] [ ] [ ] Payload.metrics[].dataset_value.rows[].elements[].string_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.num_of_columns +[x] [x] [x] [x] Payload.metrics[].dataset_value.columns[] +[x] [x] [x] [x] Payload.metrics[].dataset_value.types[] +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].int_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].long_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].float_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].double_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].boolean_value +[x] [x] [x] [x] Payload.metrics[].dataset_value.rows[].elements[].string_value Payload.metrics[].dataset_value.rows[].elements[].extension_value //none Payload.metrics[].dataset_value.rows[].extensions[] //none Payload.metrics[].dataset_value.extensions[] //none
Last updated: 2021-08-10
Post by aliazzz on Ticket #26: LibCat.xml discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Milestone: 2.0 EoN --> 999.0 Backlog
Last updated: 2021-08-10
Post by hermsen on Ticket #105: Lowering Device CPU consumption discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
How do we check if the sending has been successfully completed? I bet you want to introduce some asynchronously task? I cannot think of another simpler solution?
Last updated: 2021-08-10
Post by aliazzz on Ticket #64: EoN: repeatedly publising NDATA or missing NDATA discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Solved in v0.0.0.35; This ticket is closed
Last updated: 2021-08-10
Post by aliazzz on Ticket #39: FB_SparkplugB_SimpleEncoder discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
Description has changed: Diff: --- old +++ new @@ -33,10 +33,8 @@ Last but not least it should provide the end user with a way to obtain the protobuf encoded blob in order to publish it under the correct Sparkplug Topic -* [x] GetEncodedBlobViaAdress( BlobAdr, BlobSize ) -* [ ] GetEncodedBlobVia** +* [x] GetEncodedBlob( BlobAdr, BlobSize ) -** Think of simple ways to return the blob ** NOTE 1 When this FB is finished we can take a look to separate it's design into a Core and an extension for the Simple part. That way we can expand without code duplication for the 'Advanced metrics' part
Last updated: 2021-08-10
Post by i-campbell on Ticket #95: Versions: Downgrade to 3.5.14.0 discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: pending --> closed Milestone: 9.9.9.9: Backlog --> 2.0.0.0 Standard Feature Product (SFP)
Last updated: 2021-08-10
Post by i-campbell on Ticket #18: SVN: use 'standard' cforge folder structure discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: pending --> closed
Last updated: 2021-08-10
Post by hermsen on Ticket #83: EoN: Retry connect timer discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
status: open --> accepted
Last updated: 2021-08-10
Post by i-campbell on Ticket #57: EoN / Metrics: The final Metric of the example project is not showing up in ignition discussion
co⚡e: Sparkplug™ MQTT edge and host
tickets
(Post)
AddMetricList always logs "Success" even if adding a metric fails. Total number of metrics in AllMetricList = 38 but getNBIRTHCertificate adds 39 metrics getNBIRTHCertificate line 14: AddMetricSimple(NBirth); getNBIRTHCertificate line 20: AddMetricList(AllMetricList); This leads to an ERROR.PayloadNotEnoughMetrics ==> SHOULD: remove the AddMetricSimple and just add the NBirth to the AllMetricList any errors returned by AddMetricsList are not passed on, eg with getNBIRTHCertificate line 23: getNBIRTHCertificate := AddAllMetricsListErr;
Last updated: 2021-08-10