xssnick / safe-amqp Goto Github PK

WARNING: DATA RACE
Write at 0x00c00039b40c by goroutine 22:
  sync/atomic.CompareAndSwapInt32()
      /usr/local/Cellar/go/1.15.2/libexec/src/runtime/race_amd64.s:293 +0xb
  sync.(*Mutex).Lock()
      /usr/local/Cellar/go/1.15.2/libexec/src/sync/mutex.go:74 +0x4d
  github.com/streadway/amqp.(*Connection).send()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/connection.go:363 +0x84
  github.com/streadway/amqp.(*Channel).sendOpen()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/channel.go:263 +0x9bd
  github.com/streadway/amqp.(*Channel).send()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/channel.go:161 +0xc6
  github.com/streadway/amqp.(*Channel).call()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/channel.go:171 +0x6f
  github.com/streadway/amqp.(*Channel).Consume()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/channel.go:1080 +0x351
  github.com/xssnick/amqp-safe.(*Connector).Consume.func1()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/consume.go:35 +0x4f6

Previous write at 0x00c00039b408 by goroutine 20:
  github.com/streadway/amqp.Open()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/connection.go:224 +0x1ac
  github.com/streadway/amqp.DialConfig()
      /Users/shubhang/go/pkg/mod/github.com/streadway/[email protected]/connection.go:214 +0x3b7
  github.com/xssnick/amqp-safe.(*Connector).initConnection()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:117 +0x17d
  github.com/xssnick/amqp-safe.(*Connector).initConnection.func1.1()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:149 +0x3f4

Goroutine 22 (running) created at:
  github.com/xssnick/amqp-safe.(*Connector).Consume()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/consume.go:27 +0xa4
  github.com/gojekfarm/ziggurat-go/rmq.createSetupCallback.func1()
      /Users/shubhang/gojek/ziggurat-golang/rmq/cb.go:31 +0x73d
  github.com/xssnick/amqp-safe.(*Connector).initChannel.func2()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:248 +0x8e
  sync.(*Once).doSlow()
      /usr/local/Cellar/go/1.15.2/libexec/src/sync/once.go:66 +0x109
  sync.(*Once).Do()
      /usr/local/Cellar/go/1.15.2/libexec/src/sync/once.go:57 +0x68
  github.com/xssnick/amqp-safe.(*Connector).initChannel()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:243 +0x2b0
  github.com/xssnick/amqp-safe.(*Connector).startChannel()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:82 +0x164
  github.com/xssnick/amqp-safe.(*Connector).Start.func1()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:72 +0x46

Goroutine 20 (finished) created at:
  github.com/xssnick/amqp-safe.(*Connector).initConnection.func1()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:129 +0x70
  github.com/xssnick/amqp-safe.(*Connector).initConnection()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:162 +0x204
  github.com/xssnick/amqp-safe.(*Connector).startConnection()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:98 +0x204
  github.com/xssnick/amqp-safe.(*Connector).Start.func1()
      /Users/shubhang/go/pkg/mod/github.com/xssnick/[email protected]/connector.go:71 +0x38