mirror of https://github.com/OpenVidu/openvidu.git
openvidu-server: docker containers stop and removal process refactoring
parent
c3da6e9b8b
commit
8da682162d
|
@ -261,8 +261,7 @@ public class ComposedRecordingService extends RecordingService {
|
||||||
} else {
|
} else {
|
||||||
log.warn("Removing container {} for closed session {}...", containerIdAux,
|
log.warn("Removing container {} for closed session {}...", containerIdAux,
|
||||||
session.getSessionId());
|
session.getSessionId());
|
||||||
dockerManager.stopDockerContainer(containerIdAux);
|
dockerManager.removeDockerContainer(containerIdAux, true);
|
||||||
dockerManager.removeDockerContainer(containerIdAux, false);
|
|
||||||
containers.remove(containerId);
|
containers.remove(containerId);
|
||||||
containerClosed = true;
|
containerClosed = true;
|
||||||
log.warn("Container {} for closed session {} succesfully stopped and removed", containerIdAux,
|
log.warn("Container {} for closed session {} succesfully stopped and removed", containerIdAux,
|
||||||
|
@ -433,7 +432,6 @@ public class ComposedRecordingService extends RecordingService {
|
||||||
private void failRecordingCompletion(Recording recording, String containerId, OpenViduException e)
|
private void failRecordingCompletion(Recording recording, String containerId, OpenViduException e)
|
||||||
throws OpenViduException {
|
throws OpenViduException {
|
||||||
recording.setStatus(io.openvidu.java.client.Recording.Status.failed);
|
recording.setStatus(io.openvidu.java.client.Recording.Status.failed);
|
||||||
dockerManager.stopDockerContainer(containerId);
|
|
||||||
dockerManager.removeDockerContainer(containerId, true);
|
dockerManager.removeDockerContainer(containerId, true);
|
||||||
containers.remove(containerId);
|
containers.remove(containerId);
|
||||||
throw e;
|
throw e;
|
||||||
|
|
|
@ -152,10 +152,6 @@ public class DockerManager {
|
||||||
dockerClient.removeContainerCmd(containerId).withForce(force).exec();
|
dockerClient.removeContainerCmd(containerId).withForce(force).exec();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void stopDockerContainer(String containerId) {
|
|
||||||
dockerClient.stopContainerCmd(containerId).exec();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void cleanStrandedContainers(String imageName) {
|
public void cleanStrandedContainers(String imageName) {
|
||||||
List<Container> existingContainers = this.dockerClient.listContainersCmd().withShowAll(true).exec();
|
List<Container> existingContainers = this.dockerClient.listContainersCmd().withShowAll(true).exec();
|
||||||
for (Container container : existingContainers) {
|
for (Container container : existingContainers) {
|
||||||
|
|
Loading…
Reference in New Issue