ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
9
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve error handling and logging in polling thread of OpenViduEventManager

v2compatibility
pabloFuente 2026-03-26 13:09:06 +01:00
parent 2d319ac131
commit 3f37b61b0d
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
openvidu-test-e2e/src/main/java/io/openvidu/test/e2e/OpenViduEventManager.java
View File

@ -126,16 +126,21 @@ public class OpenViduEventManager {
} }
this.pollingThread = new Thread(() -> { this.pollingThread = new Thread(() -> {
while (!this.isInterrupted.get()) { try {
this.getEventsFromBrowser(); while (!this.isInterrupted.get()) {
this.emitEvents(); this.getEventsFromBrowser();
try { this.emitEvents();
Thread.sleep(25); try {
} catch (InterruptedException e) { Thread.sleep(25);
} catch (InterruptedException e) {
}
} }
log.info("Polling thread is now interrupted!");
} catch (Exception e) {
log.error("Polling thread crashed: {}", e.getMessage());
} finally {
this.pollingLatch.countDown();
} }
log.info("Polling thread is now interrupted!");
this.pollingLatch.countDown();
}); });
this.pollingThread.setUncaughtExceptionHandler(h); this.pollingThread.setUncaughtExceptionHandler(h);
this.pollingThread.start(); this.pollingThread.start();
@ -261,7 +266,9 @@ public class OpenViduEventManager {
public void resetEventThread(boolean clearData) throws InterruptedException { public void resetEventThread(boolean clearData) throws InterruptedException {
this.stopPolling(true, clearData); this.stopPolling(true, clearData);
this.pollingLatch.await(); if (!this.pollingLatch.await(10, TimeUnit.SECONDS)) {
log.warn("Polling thread did not stop within 10 seconds");
}
this.execService.shutdownNow(); this.execService.shutdownNow();
this.execService.awaitTermination(10, TimeUnit.SECONDS); this.execService.awaitTermination(10, TimeUnit.SECONDS);
this.execService = Executors.newCachedThreadPool(); this.execService = Executors.newCachedThreadPool();