@foxglove/rtps
Advanced tools
Comparing version 1.2.3 to 1.2.4
@@ -61,10 +61,10 @@ "use strict"; | ||
expect(dataMsg.serializedData[3]).toEqual(0); | ||
expect(dataMsg.serializedData).toHaveLength(224); | ||
expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 224)); | ||
expect(dataMsg.serializedData).toHaveLength(228); | ||
expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 228)); | ||
expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 1222751420 }); | ||
let params = ParametersView_1.ParametersView.FromCdr(dataMsg.serializedData); | ||
expect(params).toBeDefined(); | ||
expect(params.allParameters().size).toEqual(11); | ||
expect(params.allParameters().size).toEqual(12); | ||
params = ParametersView_1.ParametersView.FromCdr(dataMsg.serializedData); | ||
expect(params.allParameters().size).toEqual(11); | ||
expect(params.allParameters().size).toEqual(12); | ||
const allParams = params.allParameters(); | ||
@@ -71,0 +71,0 @@ const userData = allParams.get(common_1.ParameterId.PID_USER_DATA); |
@@ -58,3 +58,3 @@ "use strict"; | ||
get serializedData() { | ||
const payloadLength = this.octetsToNextHeader - 24; | ||
const payloadLength = this.octetsToNextHeader - 20; | ||
return new Uint8Array(this.view.buffer, this.view.byteOffset + this.offset + 24, payloadLength); | ||
@@ -61,0 +61,0 @@ } |
@@ -282,3 +282,3 @@ "use strict"; | ||
else { | ||
this._log?.info?.(`updating participant ${guidPrefix}`); | ||
this._log?.debug?.(`updating participant ${guidPrefix}`); | ||
participant.update(participantData); | ||
@@ -285,0 +285,0 @@ } |
{ | ||
"name": "@foxglove/rtps", | ||
"version": "1.2.3", | ||
"version": "1.2.4", | ||
"description": "Real-Time Publish Subscribe (DDS-RTPS) protocol implementation with a pluggable transport layer. This is a subset of the complete specification optimized for ROS 2 (Robot Operating System) connections", | ||
@@ -5,0 +5,0 @@ "license": "MIT", |
@@ -75,4 +75,4 @@ import { | ||
expect(dataMsg.serializedData[3]).toEqual(0); | ||
expect(dataMsg.serializedData).toHaveLength(224); | ||
expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 224)); | ||
expect(dataMsg.serializedData).toHaveLength(228); | ||
expect(dataMsg.serializedData).toEqual(data.slice(56, 56 + 228)); | ||
expect(dataMsg.effectiveTimestamp).toEqual({ sec: 1625943731, nsec: 1222751420 }); | ||
@@ -82,5 +82,5 @@ | ||
expect(params).toBeDefined(); | ||
expect(params.allParameters().size).toEqual(11); | ||
expect(params.allParameters().size).toEqual(12); | ||
params = ParametersView.FromCdr(dataMsg.serializedData)!; | ||
expect(params.allParameters().size).toEqual(11); | ||
expect(params.allParameters().size).toEqual(12); | ||
@@ -87,0 +87,0 @@ const allParams = params.allParameters(); |
@@ -86,5 +86,5 @@ import { Time } from "@foxglove/rostime"; | ||
get serializedData(): Uint8Array { | ||
const payloadLength = this.octetsToNextHeader - 24; | ||
const payloadLength = this.octetsToNextHeader - 20; | ||
return new Uint8Array(this.view.buffer, this.view.byteOffset + this.offset + 24, payloadLength); | ||
} | ||
} |
@@ -1185,3 +1185,3 @@ import { CdrReader } from "@foxglove/cdr"; | ||
} else { | ||
this._log?.info?.(`updating participant ${guidPrefix}`); | ||
this._log?.debug?.(`updating participant ${guidPrefix}`); | ||
participant.update(participantData); | ||
@@ -1188,0 +1188,0 @@ } |
Sorry, the diff of this file is not supported yet
699009