Looking for issues with buffering.

MihaelBercic · MihaelBercic · commit aeabd59d86f7 · 2026-01-15T12:27:22.000+01:00
diff --git a/src/main/kotlin/docker/DockerProxy.kt b/src/main/kotlin/docker/DockerProxy.kt
@@ -97,7 +97,7 @@ abstract class DockerProxy(configuration: Configuration) : MigrationStrategy(con
         while (true) {
             // TODO: I believe this could be optimised
             val process = ProcessBuilder()
-                .command("docker", "stats", "--no-trunc", "--format", "{{ json . }}")
+                .command("docker", "stats", "--no-stream", "--no-trunc", "--format", "{{ json . }}")
                 .redirectErrorStream(true)
                 .start()
             val reader = process.inputStream.bufferedReader()
@@ -118,6 +118,7 @@ abstract class DockerProxy(configuration: Configuration) : MigrationStrategy(con
                     updated = System.currentTimeMillis()
                 }
             }
+            Thread.sleep(5000)
         }
 
 

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ abstract class DockerProxy(configuration: Configuration) : MigrationStrategy(con`
`97`	`97`	`while (true) {`
`98`	`98`	`// TODO: I believe this could be optimised`
`99`	`99`	`val process = ProcessBuilder()`
`100`		`- .command("docker", "stats", "--no-trunc", "--format", "{{ json . }}")`
	`100`	`+ .command("docker", "stats", "--no-stream", "--no-trunc", "--format", "{{ json . }}")`
`101`	`101`	`.redirectErrorStream(true)`
`102`	`102`	`.start()`
`103`	`103`	`val reader = process.inputStream.bufferedReader()`
`@@ -118,6 +118,7 @@ abstract class DockerProxy(configuration: Configuration) : MigrationStrategy(con`
`118`	`118`	`updated = System.currentTimeMillis()`
`119`	`119`	`}`
`120`	`120`	`}`
	`121`	`+ Thread.sleep(5000)`
`121`	`122`	`}`
`122`	`123`
`123`	`124`