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

Session recording async start when RecordinMode.ALWAYS

pull/73/head
pabloFuente 2018-04-18 15:23:55 +02:00
parent fa76fab0d2
commit 870600dc6a
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java
View File

@ -268,9 +268,8 @@ public abstract class SessionManager {
public Participant newRecorderParticipant(String sessionId, String participantPrivatetId, Token token, public Participant newRecorderParticipant(String sessionId, String participantPrivatetId, Token token,
String clientMetadata) { String clientMetadata) {
if (this.sessionidParticipantpublicidParticipant.get(sessionId) != null) { if (this.sessionidParticipantpublicidParticipant.get(sessionId) != null) {
String participantPublicId = ProtocolElements.RECORDER_PARTICIPANT_PUBLICID; Participant p = new Participant(participantPrivatetId, ProtocolElements.RECORDER_PARTICIPANT_PUBLICID, token, clientMetadata);
Participant p = new Participant(participantPrivatetId, participantPublicId, token, clientMetadata); this.sessionidParticipantpublicidParticipant.get(sessionId).put(ProtocolElements.RECORDER_PARTICIPANT_PUBLICID, p);
this.sessionidParticipantpublicidParticipant.get(sessionId).put(participantPublicId, p);
return p; return p;
} else { } else {
throw new OpenViduException(Code.ROOM_NOT_FOUND_ERROR_CODE, sessionId); throw new OpenViduException(Code.ROOM_NOT_FOUND_ERROR_CODE, sessionId);

5
openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
View File

@ -233,7 +233,10 @@ public class KurentoSessionManager extends SessionManager {
&& RecordingMode.ALWAYS.equals(session.getSessionProperties().recordingMode()) && RecordingMode.ALWAYS.equals(session.getSessionProperties().recordingMode())
&& !recordingService.sessionIsBeingRecorded(session.getSessionId()) && !recordingService.sessionIsBeingRecorded(session.getSessionId())
&& session.getActivePublishers() == 0) { && session.getActivePublishers() == 0) {
recordingService.startRecording(session, null); // Insecure session recording
new Thread(() -> {
recordingService.startRecording(session, null);
}).start();
} }
session.newPublisher(participant); session.newPublisher(participant);