Showing the changes to Source/Libraries/TimeSeriesJavaLibrary (1 of 1 file). Show all
Unified · Split
| @@ -895,15 +895,15 @@ public class DataSubscriber · 894 unmodified lines | |||
| 895 | compactFlag = (dataPacketFlags & DataPacketFlags.Compact) != 0; | 895 | compactFlag = (dataPacketFlags & DataPacketFlags.Compact) != 0; |
| 896 | syncFlag = (dataPacketFlags & DataPacketFlags.Synchronized) != 0; | 896 | syncFlag = (dataPacketFlags & DataPacketFlags.Synchronized) != 0; |
| 897 | 897 | ||
| 898 | // Gather statistics | ||
| 899 | m_totalMeasurementsReceived += buffer.getInt(); | ||
| 900 | |||
| 901 | if (syncFlag) | 898 | if (syncFlag) |
| 902 | { | 899 | { |
| 903 | frameLevelTimestamp = buffer.getLong(); | 900 | frameLevelTimestamp = buffer.getLong(); |
| 904 | includeTime = false; | 901 | includeTime = false; |
| 905 | } | 902 | } |
| 906 | 903 | ||
| 904 | // Gather statistics | ||
| 905 | m_totalMeasurementsReceived += buffer.getInt(); | ||
| 906 | |||
| 907 | if (compactFlag) | 907 | if (compactFlag) |
| 908 | { | 908 | { |
| 909 | // If signal index cache is null, we | 909 | // If signal index cache is null, we |