==================
|
WARNING: DATA RACE
|
Read at 0x00c000b91218 by goroutine 236:
|
github.com/couchbase/gomemcached/client.(*UprFeed).GetUprEventCh()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/gomemcached/client/upr_feed.go:733 +0x3e
|
github.com/couchbase/goxdcr/parts.(*DcpNozzle).getDcpDataChanLen()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:1902 +0x2a5
|
github.com/couchbase/goxdcr/parts.(*DcpNozzle).collectDcpDataChanLen()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:1891 +0x2d6
|
|
Previous write at 0x00c000b91218 by goroutine 153:
|
github.com/couchbase/gomemcached/client.(*UprFeed).StartFeedWithConfig()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/gomemcached/client/upr_feed.go:772 +0x6b
|
github.com/couchbase/goxdcr/parts.(*DcpNozzle).Start()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:769 +0x989
|
github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:229 +0x301
|
github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPartsWithTimeout.func1.1()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:149 +0x13a
|
|
Goroutine 236 (running) created at:
|
github.com/couchbase/goxdcr/parts.(*DcpNozzle).Start()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:765 +0x56b
|
github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:229 +0x301
|
github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPartsWithTimeout.func1.1()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:149 +0x13a
|
==================
|
|
|