Skip to content

Commit 9bb8dad

Browse files
committed
Looking for issues with buffering.
1 parent 20ca1ac commit 9bb8dad

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/main/kotlin/docker/DockerProxy.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,8 @@ abstract class DockerProxy(configuration: Configuration) : MigrationStrategy(con
6565
fun sendDockerStatistics(block: Block, blockProducer: String, clusters: Map<String, Cluster<String>>) {
6666
val slot = block.slot
6767
val currentTime = System.currentTimeMillis()
68-
localContainers.entries.removeIf { (_, container) -> currentTime - container.updated >= 1000 }
68+
println("Containers length before remove: ${localContainers.size}")
69+
localContainers.entries.removeIf { (_, container) -> currentTime - container.updated >= 30_000 }
6970

7071
val mapped: List<DockerContainer> = localContainers.values.map { it.copy(id = networkMappings[it.id] ?: it.id) }
7172
val localStatistics = DockerStatistics(localNode.publicKey, mapped, slot)

0 commit comments

Comments
 (0)