Concurrent map write / read / iteration

[practo]

Concurrent map write / read / iteration

[alok87]

One more

fatal error: concurrent map read and map write

goroutine 63 [running]:
runtime.throw(0x17095bf, 0x21)
        /usr/local/go/src/runtime/panic.go:617 +0x72 fp=0xc0019e7930 sp=0xc0019e7900 pc=0x42c042
runtime.mapaccess1_faststr(0x1523640, 0xc0004642d0, 0xc0005e3100, 0x34, 0xc0014a82f8)
        /usr/local/go/src/runtime/map_faststr.go:21 +0x469 fp=0xc0019e79a0 sp=0xc0019e7930 pc=0x412249
github.com/practo/k8s-worker-pod-autoscaler/pkg/queue.(*Queues).ListQueue(...)
        /src/pkg/queue/queue.go:162
github.com/practo/k8s-worker-pod-autoscaler/pkg/queue.(*Queues).listQueueByNamespace(...)
        /src/pkg/queue/queue.go:166
github.com/practo/k8s-worker-pod-autoscaler/pkg/queue.(*Queues).Add(0xc000464300, 0xc0005e2fc0, 0xc, 0xc0005e2fcd, 0x27, 0xc00115d3b0, 0x64, 0x1, 0x20, 0x0)
        /src/pkg/queue/queue.go:123 +0x5af fp=0xc0019e7ae0 sp=0xc0019e79a0 pc=0x13ed67f
github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).syncHandler(0xc000462c80, 0xc0005e2fc0, 0x34, 0x16ecd35, 0x6, 0xc0019e7d98, 0xc000412710)
        /src/pkg/controller/controller.go:277 +0xbbb fp=0xc0019e7d30 sp=0xc0019e7ae0 pc=0x13f257b
github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).processNextWorkItem.func1(0xc000462c80, 0x15aff80, 0xc0005282e0, 0x0, 0x0)
        /src/pkg/controller/controller.go:204 +0x13f fp=0xc0019e7e38 sp=0xc0019e7d30 pc=0x13f347f
github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).processNextWorkItem(0xc000462c80, 0xc0003c8101)
        /src/pkg/controller/controller.go:214 +0x4d fp=0xc0019e7e70 sp=0xc0019e7e38 pc=0x13f195d
github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).runWorker(0xc000462c80)
        /src/pkg/controller/controller.go:164 +0x2b fp=0xc0019e7e90 sp=0xc0019e7e70 pc=0x13f18eb
github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).runWorker-fm()
        /src/pkg/controller/controller.go:163 +0x2a fp=0xc0019e7ea8 sp=0xc0019e7e90 pc=0x13f3f9a
k8s.io/apimachinery/pkg/util/wait.JitterUntil.func1(0xc0007bd600)
        /src/vendor/k8s.io/apimachinery/pkg/util/wait/wait.go:152 +0x54 fp=0xc0019e7ee0 sp=0xc0019e7ea8 pc=0x114fe34
k8s.io/apimachinery/pkg/util/wait.JitterUntil(0xc0007bd600, 0x3b9aca00, 0x0, 0x1, 0xc000088660)
        /src/vendor/k8s.io/apimachinery/pkg/util/wait/wait.go:153 +0xf8 fp=0xc0019e7f90 sp=0xc0019e7ee0 pc=0x114f418
k8s.io/apimachinery/pkg/util/wait.Until(0xc0007bd600, 0x3b9aca00, 0xc000088660)
        /src/vendor/k8s.io/apimachinery/pkg/util/wait/wait.go:88 +0x4d fp=0xc0019e7fc8 sp=0xc0019e7f90 pc=0x114f30d
runtime.goexit()
        /usr/local/go/src/runtime/asm_amd64.s:1337 +0x1 fp=0xc0019e7fd0 sp=0xc0019e7fc8 pc=0x458671
created by github.com/practo/k8s-worker-pod-autoscaler/pkg/controller.(*Controller).Run
        /src/pkg/controller/controller.go:152 +0x262