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

openvidu-server: single stream recording updates file permissions on recording stop

pull/203/head
pabloFuente 2019-01-22 10:51:45 +01:00
parent a83fef15f1
commit 339eadd8e4
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -58,6 +58,7 @@ import io.openvidu.server.kurento.core.KurentoParticipant;
import io.openvidu.server.kurento.endpoint.PublisherEndpoint; import io.openvidu.server.kurento.endpoint.PublisherEndpoint;
import io.openvidu.server.recording.RecorderEndpointWrapper; import io.openvidu.server.recording.RecorderEndpointWrapper;
import io.openvidu.server.recording.Recording; import io.openvidu.server.recording.Recording;
import io.openvidu.server.utils.CommandExecutor;
import io.openvidu.server.utils.CustomFileWriter; import io.openvidu.server.utils.CustomFileWriter;
public class SingleStreamRecordingService extends RecordingService { public class SingleStreamRecordingService extends RecordingService {
@ -445,11 +446,25 @@ public class SingleStreamRecordingService extends RecordingService {
try { try {
zipOut.close(); zipOut.close();
fos.close(); fos.close();
this.updateFilePermissions(folder);
} catch (IOException e) { } catch (IOException e) {
log.error("Error closing FileOutputStream or ZipOutputStream. Error: {}", e.getMessage()); log.error("Error closing FileOutputStream or ZipOutputStream. Error: {}", e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
}
}
private void updateFilePermissions(String folder) {
String command = "chmod -R 777 " + folder;
try {
String response = CommandExecutor.execCommand("/bin/sh", "-c", command);
if ("".equals(response)) {
log.info("Individual recording file permissions successfully updated");
} else {
log.error("Individual recording file permissions failed to update: {}", response);
}
} catch (IOException | InterruptedException e) {
log.error("Individual recording file permissions failed to update. Error: {}", e.getMessage());
} }
} }