viki-org/amqp

Go client for AMQP 0.9.1

amqp's Issues

Data race

Found this while running some tests

Write at 0x00c4a0acc0f0 by goroutine 63:
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).shutdown.func1()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:104 +0xcb
 sync.(*Once).Do()
     /usr/local/go/src/sync/once.go:44 +0xf2
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).shutdown()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:146 +0x92
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).dispatch()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:257 +0x467
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).recvMethod()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:310 +0x5a2
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Connection).dispatchN()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:341 +0xa8
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Connection).demux()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:304 +0x9f
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Connection).reader()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:392 +0x2c6

Previous read at 0x00c4a0acc0f0 by goroutine 93:
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).call()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:156 +0x6d
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.(*Channel).Close()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/channel.go:399 +0x16f
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.glob..func1()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/client.go:78 +0x2a2
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.(*Client).deliver()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/client.go:58 +0x8b
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.(*Client).write()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/client.go:54 +0x19d
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.(*Client).CreateMessage()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/client.go:35 +0xc2
 vikipass/modules/androidsub/androidsub.(*Service).sendPlanSubscriberCreateMsg()
     /root/go/src/vikipass/modules/androidsub/androidsub/queue.go:28 +0xe7
 vikipass/modules/androidsub/androidsub.(*Service).track()
     /root/go/src/vikipass/modules/androidsub/androidsub/transition.go:86 +0x119f
 vikipass/modules/androidsub/androidsub.(*Service).update()
     /root/go/src/vikipass/modules/androidsub/androidsub/service.go:338 +0x49e
 vikipass/modules/androidsub/androidsub.(*Service).UpdateCurrents()
     /root/go/src/vikipass/modules/androidsub/androidsub/service.go:302 +0x7da
 main.UpdateCurrent.func1()
     /root/go/src/vikipass/modules/androidsub/handlers.go:209 +0x28c
 net/http.HandlerFunc.ServeHTTP()
     /usr/local/go/src/net/http/server.go:1726 +0x51
 vikipass/modules/androidsub/vendor/github.com/gorilla/mux.(*Router).ServeHTTP()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/gorilla/mux/mux.go:107 +0x184
 net/http.(*ServeMux).ServeHTTP()
     /usr/local/go/src/net/http/server.go:2022 +0xa1
 net/http.serverHandler.ServeHTTP()
     /usr/local/go/src/net/http/server.go:2202 +0xbb
 net/http.(*conn).serve()
     /usr/local/go/src/net/http/server.go:1579 +0x5f6

Goroutine 63 (running) created at:
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.Open()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:155 +0x56c
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.DialTLS()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:136 +0x4f8
 vikipass/modules/androidsub/vendor/github.com/viki-org/amqp.Dial()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/amqp/connection.go:78 +0x4f
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.NewConnection()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/pool.go:30 +0x42
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.NewConnectionPool()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/pool.go:21 +0x19f
 vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go.NewClient()
     /root/go/src/vikipass/modules/androidsub/vendor/github.com/viki-org/queue-client-go/client.go:17 +0x50
 vikipass/modules/androidsub/androidsub.New()
     /root/go/src/vikipass/modules/androidsub/androidsub/service.go:121 +0x4d4
 main.main()
     /root/go/src/vikipass/modules/androidsub/main.go:23 +0xf6

Goroutine 93 (running) created at:
 net/http.(*Server).Serve()
     /usr/local/go/src/net/http/server.go:2293 +0x540
 net/http.(*Server).ListenAndServe()
     /usr/local/go/src/net/http/server.go:2219 +0x122
 net/http.ListenAndServe()
     /usr/local/go/src/net/http/server.go:2351 +0xee
 main.main()
     /root/go/src/vikipass/modules/androidsub/main.go:34 +0x20f