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

openvidu-server: clean activeRecorders map of SingleStreamRecordingService

pull/391/head
pabloFuente 2020-02-02 20:34:11 +01:00
parent fac8693e2f
commit 3e9eef2d27
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
openvidu-server/src/main/java/io/openvidu/server/recording/service/SingleStreamRecordingService.java
View File

@ -184,7 +184,7 @@ public class SingleStreamRecordingService extends RecordingService {
cdr.recordRecordingStatusChanged(finalRecordingArray[0], reason, timestamp, cdr.recordRecordingStatusChanged(finalRecordingArray[0], reason, timestamp,
finalRecordingArray[0].getStatus()); finalRecordingArray[0].getStatus());
storedRecorders.remove(finalRecordingArray[0].getSessionId()); cleanRecordingWrappers(finalRecordingArray[0].getSessionId());
// Decrement active recordings once it is downloaded // Decrement active recordings once it is downloaded
((KurentoSession) session).getKms().getActiveRecordings().decrementAndGet(); ((KurentoSession) session).getKms().getActiveRecordings().decrementAndGet();
@ -195,7 +195,7 @@ public class SingleStreamRecordingService extends RecordingService {
}); });
} catch (IOException e) { } catch (IOException e) {
log.error("Error while downloading recording {}", finalRecordingArray[0].getName()); log.error("Error while downloading recording {}", finalRecordingArray[0].getName());
storedRecorders.remove(finalRecordingArray[0].getSessionId()); cleanRecordingWrappers(finalRecordingArray[0].getSessionId());
} }
if (reason != null && session != null) { if (reason != null && session != null) {
@ -504,4 +504,9 @@ public class SingleStreamRecordingService extends RecordingService {
} }
} }
private void cleanRecordingWrappers(String sessionId) {
this.storedRecorders.remove(sessionId);
this.activeRecorders.remove(sessionId);
}
} }