thingsboard

Open-source IoT Platform - Device management, data collection, processing and visualization.

dashboard java cloud coap iot iot-analytics iot-platform iot-solutions kafka lwm2m microservices middleware mqtt netty platform snmp thingsboard visualization websockets widgets

History

Sergey Matvienko 25d3394e9f Fix race condition in notification deduplication check The alreadyProcessed() method used separate get() and put() calls on the local cache, allowing concurrent threads in the notification executor pool to both read null and bypass deduplication, creating duplicate notifications. Replace with a single compute() call that atomically checks and updates the cache entry, preventing the race between concurrent trigger processing. Also fix: discard external cache timestamps that are more than 1 hour in the future (clock skew protection), and avoid reading back from the SOFT ref local cache when writing to external cache (GC could null it out).	2 months ago
..
main/java/org/thingsboard/server/queue	Fix race condition in notification deduplication check	2 months ago
test	Fix race condition in notification deduplication check	2 months ago

Sergey Matvienko 25d3394e9f Fix race condition in notification deduplication check

The alreadyProcessed() method used separate get() and put() calls on the
local cache, allowing concurrent threads in the notification executor pool
to both read null and bypass deduplication, creating duplicate notifications.

Replace with a single compute() call that atomically checks and updates
the cache entry, preventing the race between concurrent trigger processing.

Also fix: discard external cache timestamps that are more than 1 hour in
the future (clock skew protection), and avoid reading back from the SOFT
ref local cache when writing to external cache (GC could null it out).

2 months ago

main/java/org/thingsboard/server/queue

Fix race condition in notification deduplication check

2 months ago

test

Fix race condition in notification deduplication check

2 months ago