Merge pull request #2247 from subutai-io/base-2226

#2226 skip stopped containers, added logs
subutai-io · Feb 7, 2018 · f08a7f7 · f08a7f7
2 parents d5b38f2 + 6bd38b4
commit f08a7f7
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/...mpl/src/main/java/io/subutai/core/environment/impl/tasks/ContainerDiskUsageCheckTask.java b/...mpl/src/main/java/io/subutai/core/environment/impl/tasks/ContainerDiskUsageCheckTask.java
@@ -11,6 +11,7 @@
 import io.subutai.common.command.RequestBuilder;
 import io.subutai.common.environment.ContainerDto;
 import io.subutai.common.environment.EnvironmentDto;
+import io.subutai.common.host.ContainerHostState;
 import io.subutai.common.peer.ContainerHost;
 import io.subutai.common.peer.LocalPeer;
 import io.subutai.common.peer.ResourceHost;
@@ -66,6 +67,12 @@ private void checkDiskUsage( ContainerDto containerDto )
         //  b.b if du is >= 150 %  of quota -> stop container, notify Hub
         try
         {
+
+            if ( containerDto.getState() != ContainerHostState.RUNNING )
+            {
+                return;
+            }
+
             ResourceHost resourceHost = localPeer.getResourceHostById( containerDto.getRhId() );
 
             ContainerHost containerHost = localPeer.getContainerHostById( containerDto.getId() );
@@ -80,12 +87,17 @@ private void checkDiskUsage( ContainerDto containerDto )
 
             if ( diskUsed >= diskLimit * 0.9 )
             {
+                LOG.info( "Container {} is exceeding disk quota: limit {}, actual usage {}",
+                        containerDto.getContainerName(), diskLimit, diskUsed );
+
                 boolean stop = diskUsed >= diskLimit * 1.5;
 
                 if ( stop )
                 {
                     //stop container
                     containerHost.stop();
+
+                    LOG.info( "Container {} is stopped due to disk quota excess", containerDto.getContainerName() );
                 }
 
                 //notify Hub