================== WARNING: DATA RACEa P4--- check if we have any other reader who are reading this variable and doing some processing Read by goroutine 60: github.com/couchbase/goxdcr/parts.(*XmemNozzle).StatusSummary() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1958 +0xbb github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).logStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:338 +0x397 github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).updateStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:299 +0x50d Previous write by goroutine 105: sync/atomic.AddInt32() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/race_amd64.s:255 +0xb github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchSetMetaWithRetry() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1057 +0x203 github.com/couchbase/goxdcr/parts.(*XmemNozzle).sendSetMeta_internal() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1210 +0x59a github.com/couchbase/goxdcr/parts.(*XmemNozzle).processBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:995 +0x9a github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:961 +0xc35 Goroutine 60 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:698 +0x486 github.com/couchbase/goxdcr/pipeline_ctx.(*PipelineRuntimeCtx).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_ctx/pipeline_runtimeCtx.go:67 +0x57e github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:195 +0xb3f github.com/couchbase/goxdcr/pipeline_manager.(*pipelineManager).startPipeline() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:300 +0xa9c github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).update() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:627 +0x1388 github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:580 +0x119 Goroutine 105 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:819 +0x73f github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:151 +0x526 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart.func1() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:128 +0xdd ================== ================== WARNING: DATA RACE Read by goroutine 60: github.com/couchbase/goxdcr/parts.(*XmemNozzle).StatusSummary() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1959 +0xdf github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).logStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:338 +0x397 github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).updateStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:299 +0x50d Previous write by goroutine 105: sync/atomic.AddInt32() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/race_amd64.s:255 +0xb github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchSetMetaWithRetry() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1060 +0x318 github.com/couchbase/goxdcr/parts.(*XmemNozzle).sendSetMeta_internal() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1210 +0x59a github.com/couchbase/goxdcr/parts.(*XmemNozzle).processBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:995 +0x9a github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:961 +0xc35 Goroutine 60 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:698 +0x486 github.com/couchbase/goxdcr/pipeline_ctx.(*PipelineRuntimeCtx).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_ctx/pipeline_runtimeCtx.go:67 +0x57e github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:195 +0xb3f github.com/couchbase/goxdcr/pipeline_manager.(*pipelineManager).startPipeline() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:300 +0xa9c github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).update() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:627 +0x1388 github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:580 +0x119 Goroutine 105 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:819 +0x73f github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:151 +0x526 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart.func1() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:128 +0xdd ================== ================== ================== WARNING: DATA RACE Read by goroutine 60: github.com/couchbase/goxdcr/parts.(*XmemNozzle).StatusSummary() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1961 +0x274 github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).logStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:338 +0x397 github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).updateStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:299 +0x50d Previous write by goroutine 116: github.com/couchbase/goxdcr/parts.(*dataBatch).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/outgoing_nozzle_common.go:190 +0x140 github.com/couchbase/goxdcr/parts.(*XmemNozzle).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:933 +0x369 github.com/couchbase/goxdcr/parts.(*XmemNozzle).Receive() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:916 +0xa01 github.com/couchbase/goxdcr/connector.(*Router).Forward() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/connector/router.go:62 +0x32b github.com/couchbase/goxdcr/parts.(*Router).Forward() :69 +0x7f github.com/couchbase/goxdcr/parts.(*DcpNozzle).processData() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:454 +0x273f Goroutine 60 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:698 +0x486 github.com/couchbase/goxdcr/pipeline_ctx.(*PipelineRuntimeCtx).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_ctx/pipeline_runtimeCtx.go:67 +0x57e github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:195 +0xb3f github.com/couchbase/goxdcr/pipeline_manager.(*pipelineManager).startPipeline() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:300 +0xa9c github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).update() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:627 +0x1388 github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:580 +0x119 Goroutine 116 (running) created at: github.com/couchbase/goxdcr/parts.(*DcpNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:270 +0x8bd github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:151 +0x526 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start.func2() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:222 +0x1ea ================== ================== ================== WARNING: DATA RACE Read by goroutine 60: runtime.convT2E() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/iface.go:128 +0x0 github.com/couchbase/goxdcr/parts.(*XmemNozzle).StatusSummary() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1961 +0x4ca github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).logStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:338 +0x397 github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).updateStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:299 +0x50d Previous write by goroutine 116: sync/atomic.AddInt32() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/race_amd64.s:255 +0xb github.com/couchbase/goxdcr/parts.(*XmemNozzle).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:928 +0xf3 github.com/couchbase/goxdcr/parts.(*XmemNozzle).Receive() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:916 +0xa01 github.com/couchbase/goxdcr/connector.(*Router).Forward() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/connector/router.go:62 +0x32b github.com/couchbase/goxdcr/parts.(*Router).Forward() :69 +0x7f github.com/couchbase/goxdcr/parts.(*DcpNozzle).processData() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:454 +0x273f Goroutine 60 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:698 +0x486 github.com/couchbase/goxdcr/pipeline_ctx.(*PipelineRuntimeCtx).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_ctx/pipeline_runtimeCtx.go:67 +0x57e github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:195 +0xb3f github.com/couchbase/goxdcr/pipeline_manager.(*pipelineManager).startPipeline() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:300 +0xa9c github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).update() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:627 +0x1388 github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:580 +0x119 Goroutine 116 (running) created at: github.com/couchbase/goxdcr/parts.(*DcpNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:270 +0x8bd github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:151 +0x526 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start.func2() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:222 +0x1ea ================== ================== WARNING: DATA RACE --- P3 Read by goroutine 60: reflect.maplen() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/hashmap.go:1029 +0x0 reflect.Value.MapKeys() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/reflect/value.go:1073 +0x10f fmt.(*pp).printReflectValue() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/fmt/print.go:893 +0x2eb1 fmt.(*pp).printArg() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/fmt/print.go:810 +0x656 fmt.(*pp).doPrintf() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/fmt/print.go:1238 +0x2a47 fmt.Sprintf() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/fmt/print.go:203 +0x7c github.com/couchbase/goxdcr/parts.(*Router).StatusSummary() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/router.go:238 +0x18f github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).logStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:346 +0x59d github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).updateStats() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:299 +0x50d Previous write by goroutine 116: runtime.mapassign1() /Users/riteshmotlani/.cbdepscache/exploded/x86_64/go-1.6/go/src/runtime/hashmap.go:429 +0x0 github.com/couchbase/goxdcr/parts.(*Router).route() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/router.go:210 +0xee2 github.com/couchbase/goxdcr/parts.(*Router).(github.com/couchbase/goxdcr/parts.route)-fm() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/router.go:72 +0x4f github.com/couchbase/goxdcr/connector.(*Router).Forward() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/connector/router.go:57 +0x17c github.com/couchbase/goxdcr/parts.(*Router).Forward() :69 +0x7f github.com/couchbase/goxdcr/parts.(*DcpNozzle).processData() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:454 +0x273f Goroutine 60 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*StatisticsManager).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/statistics_manager.go:698 +0x486 github.com/couchbase/goxdcr/pipeline_ctx.(*PipelineRuntimeCtx).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_ctx/pipeline_runtimeCtx.go:67 +0x57e github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:195 +0xb3f github.com/couchbase/goxdcr/pipeline_manager.(*pipelineManager).startPipeline() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:300 +0xa9c github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).update() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:627 +0x1388 github.com/couchbase/goxdcr/pipeline_manager.(*pipelineUpdater).start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_manager/pipeline_manager.go:580 +0x119 Goroutine 116 (running) created at: github.com/couchbase/goxdcr/parts.(*DcpNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/dcp_nozzle.go:270 +0x8bd github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).startPart() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:151 +0x526 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).Start.func2() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:222 +0x1ea ================== ==================