WARNING: DATA RACE----- P2 Write by goroutine 16: github.com/couchbase/goxdcr/parts.(*XmemNozzle).UpdateSettings() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2174 +0xa6 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).UpdateSettings() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:647 +0x3c4 github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).setTimestampForVB() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:383 +0xccd github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).startSeqnoGetter() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:448 +0xc78 Previous write by goroutine 85: github.com/couchbase/goxdcr/parts.(*XmemNozzle).UpdateSettings() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2174 +0xa6 github.com/couchbase/goxdcr/pipeline.(*GenericPipeline).UpdateSettings() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline/generic_pipeline.go:647 +0x3c4 github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).setTimestampForVB() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:383 +0xccd github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).startSeqnoGetter() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:448 +0xc78 Goroutine 16 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).SetVBTimestamps() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:344 +0x11b7 github.com/couchbase/goxdcr/factory.(*XDCRFactory).SetStartSeqno() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/factory/xdcr_factory.go:632 +0x496 github.com/couchbase/goxdcr/factory.(*XDCRFactory).SetStartSeqno-fm() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/factory/xdcr_factory.go:163 +0x4f Goroutine 85 (running) created at: github.com/couchbase/goxdcr/pipeline_svc.(*CheckpointManager).SetVBTimestamps() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/pipeline_svc/checkpoint_manager.go:344 +0x11b7 github.com/couchbase/goxdcr/factory.(*XDCRFactory).SetStartSeqno() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/factory/xdcr_factory.go:632 +0x496 github.com/couchbase/goxdcr/factory.(*XDCRFactory).SetStartSeqno-fm() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/factory/xdcr_factory.go:163 +0x4f ==================G WARNING: DATA RAC --- P2 Read by goroutine 244: github.com/couchbase/goxdcr/parts.(*xmemClient).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:578 +0x1e3 github.com/couchbase/goxdcr/parts.(*XmemNozzle).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1989 +0xd6 github.com/couchbase/goxdcr/parts.(*XmemNozzle).readFromClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2038 +0x204 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta.func1() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1309 +0x315 Previous write by goroutine 105: github.com/couchbase/goxdcr/parts.(*xmemClient).reportOpSuccess() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:565 +0x2ca github.com/couchbase/goxdcr/parts.(*XmemNozzle).writeToClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2012 +0x189 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1359 +0x194b github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:954 +0x99d Goroutine 244 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1355 +0x1773 github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:954 +0x99d 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 Write by goroutine 244: github.com/couchbase/goxdcr/parts.(*xmemClient).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:582 +0x2ab github.com/couchbase/goxdcr/parts.(*XmemNozzle).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1989 +0xd6 github.com/couchbase/goxdcr/parts.(*XmemNozzle).readFromClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2038 +0x204 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta.func1() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1309 +0x315 Previous write by goroutine 105: github.com/couchbase/goxdcr/parts.(*xmemClient).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:582 +0x2ab github.com/couchbase/goxdcr/parts.(*XmemNozzle).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1989 +0xd6 github.com/couchbase/goxdcr/parts.(*XmemNozzle).writeToClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2004 +0xbe github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1359 +0x194b github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:954 +0x99d Goroutine 244 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchGetMeta() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1355 +0x1773 github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:954 +0x99d 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 --- P2 Read by goroutine 102: github.com/couchbase/goxdcr/parts.(*xmemClient).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:578 +0x1e3 github.com/couchbase/goxdcr/parts.(*XmemNozzle).getConn() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1989 +0xd6 github.com/couchbase/goxdcr/parts.(*XmemNozzle).readFromClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2038 +0x204 github.com/couchbase/goxdcr/parts.(*XmemNozzle).receiveResponse() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1585 +0x61e Previous write by goroutine 105: github.com/couchbase/goxdcr/parts.(*xmemClient).reportOpSuccess() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:565 +0x2ca github.com/couchbase/goxdcr/parts.(*XmemNozzle).writeToClient() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2012 +0x189 github.com/couchbase/goxdcr/parts.(*XmemNozzle).sendWithRetry() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1192 +0xaf github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchSetMetaWithRetry() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1118 +0x10d3 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 102 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:813 +0x61d 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 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 Write by goroutine 116: github.com/couchbase/goxdcr/parts.(*XmemNozzle).initNewBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1534 +0x371 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchReady() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:885 +0x570 github.com/couchbase/goxdcr/parts.(*XmemNozzle).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:935 +0x384 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 Previous read by goroutine 105: [failed to restore the stack] 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 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 Write by goroutine 164: github.com/couchbase/goxdcr/parts.(*XmemNozzle).initNewBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1534 +0x371 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchReady() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:885 +0x570 github.com/couchbase/goxdcr/parts.(*XmemNozzle).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:935 +0x384 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 Previous read by goroutine 119: github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:970 +0x47a Goroutine 164 (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 Goroutine 119 (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 Write by goroutine 119: github.com/couchbase/goxdcr/parts.(*requestBuffer).flowControl() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:200 +0x14b github.com/couchbase/goxdcr/parts.(*XmemNozzle).processBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:994 +0x82 github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:961 +0xc35 Previous read by goroutine 77: github.com/couchbase/goxdcr/parts.(*requestBuffer).evictSlot() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:294 +0x53d github.com/couchbase/goxdcr/parts.(*XmemNozzle).receiveResponse() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1668 +0x2ced Goroutine 119 (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 Goroutine 77 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:813 +0x61d 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 Write by goroutine 102: github.com/couchbase/goxdcr/parts.(*XmemNozzle).adjustMaxIdleCount() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1699 +0xd0 github.com/couchbase/goxdcr/parts.(*XmemNozzle).adjustRespTimeout() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1694 +0x19a github.com/couchbase/goxdcr/parts.(*XmemNozzle).receiveResponse() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1665 +0x2cb1 Previous read by goroutine 100: github.com/couchbase/goxdcr/parts.(*XmemNozzle).getMaxIdleCount() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1745 +0x3f github.com/couchbase/goxdcr/parts.(*XmemNozzle).selfMonitor() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1796 +0x134e Goroutine 102 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:813 +0x61d 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 Goroutine 100 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:810 +0x58c 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 104: github.com/couchbase/goxdcr/parts.(*XmemNozzle).timeoutDuration() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1869 +0x42 github.com/couchbase/goxdcr/parts.(*XmemNozzle).checkTimeout() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1860 +0x718 github.com/couchbase/goxdcr/parts.(*XmemNozzle).(github.com/couchbase/goxdcr/parts.checkTimeout)-fm() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1829 +0x50 github.com/couchbase/goxdcr/parts.(*requestBuffer).modSlot() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:253 +0x1b8 github.com/couchbase/goxdcr/parts.(*XmemNozzle).check() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1831 +0x2d4 Previous write by goroutine 102: github.com/couchbase/goxdcr/parts.(*XmemNozzle).adjustRespTimeout() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1692 +0x174 github.com/couchbase/goxdcr/parts.(*XmemNozzle).receiveResponse() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1665 +0x2cb1 Goroutine 104 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:816 +0x6ae 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 Goroutine 102 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:813 +0x61d 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 95: github.com/couchbase/goxdcr/parts.(*XmemNozzle).selfMonitor() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1779 +0x608 Previous write by goroutine 96: [failed to restore the stack] Goroutine 95 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:810 +0x58c 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 Goroutine 96 (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 Write by goroutine 105: github.com/couchbase/goxdcr/parts.(*XmemNozzle).recordBatchSize() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:2222 +0x94 github.com/couchbase/goxdcr/parts.(*XmemNozzle).processData_sendbatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:969 +0xd3c Previous read by goroutine 60: [failed to restore the stack] 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 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 ================== WARNING: DATA RACE Write by goroutine 84: github.com/couchbase/goxdcr/parts.(*XmemNozzle).initNewBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1534 +0x371 github.com/couchbase/goxdcr/parts.(*XmemNozzle).batchReady() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:885 +0x570 github.com/couchbase/goxdcr/parts.(*XmemNozzle).accumuBatch() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:935 +0x384 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 Previous read by goroutine 142: github.com/couchbase/goxdcr/parts.(*XmemNozzle).selfMonitor() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:1792 +0x8cf Goroutine 84 (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 Goroutine 142 (running) created at: github.com/couchbase/goxdcr/parts.(*XmemNozzle).Start() /Users/riteshmotlani/cbwatson/goproj/src/github.com/couchbase/goxdcr/parts/xmem_nozzle.go:810 +0x58c 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