==================
|
WARNING: DATA RACE
|
Write at 0x00c0012cc060 by goroutine 336:
|
github.com/couchbase/goxdcr/metadata.(*BackfillReplicationSpec).SetReplicationSpec()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata/backfill_replication.go:78 +0x1f9
|
2021-11-24T10:32:12.625-08:00 INFO GOXDCR.PipelineMgr: PipelineOpSerializer 3efc20591cbdde205d48f036424c77df/B0/B1 handling job: Job for 3efc20591cbdde205d48f036424c77df/B0/B1 Type: PipelineUpdate
|
github.com/couchbase/goxdcr/metadata_svc.(*BackfillReplicationService).ReplicationSpecChangeCallback()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/backfill_repl_service.go:681 +0x1e4
|
github.com/couchbase/goxdcr/service_def.BackfillReplSvc.ReplicationSpecChangeCallback-fm()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/service_def/backfill_repl_svc.go:27 +0xb0
|
github.com/couchbase/goxdcr/metadata_svc.(*ReplicationSpecService).executeCallbackWithPriority()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/replication_spec_service.go:1293 +0x27b
|
github.com/couchbase/goxdcr/metadata_svc.(*ReplicationSpecService).callMetadataChangeCb()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/replication_spec_service.go:1264 +0x21e
|
github.com/couchbase/goxdcr/metadata_svc.(*ReplicationSpecService).updateCacheInternal()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/replication_spec_service.go:1161 +0x16e
|
github.com/couchbase/goxdcr/metadata_svc.(*ReplicationSpecService).updateCache()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/replication_spec_service.go:1125 +0x364
|
github.com/couchbase/goxdcr/metadata_svc.(*ReplicationSpecService).ReplicationSpecServiceCallback()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata_svc/replication_spec_service.go:1088 +0x365
|
github.com/couchbase/goxdcr/service_def.ReplicationSpecSvc.ReplicationSpecServiceCallback-fm()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/service_def/replication_spec_svc.go:49 +0xb3
|
github.com/couchbase/goxdcr/replication_manager.(*MetakvChangeListener).metakvCallback_async()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/replication_manager/metakv_change_listener.go:97 +0xc6
|
|
Previous read at 0x00c0012cc060 by goroutine 55:
|
github.com/couchbase/goxdcr/metadata.(*BackfillReplicationSpec).ReplicationSpec()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata/backfill_replication.go:90 +0x3e
|
github.com/couchbase/goxdcr/metadata.(*BackfillReplicationSpec).GetReplicationSpec()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/metadata/backfill_replication.go:70 +0x4d
|
github.com/couchbase/goxdcr/resource_manager.(*ResourceManager).getStatsFromReplication()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/resource_manager/resource_manager.go:1123 +0x250
|
github.com/couchbase/goxdcr/resource_manager.(*ResourceManager).collectReplStats()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/resource_manager/resource_manager.go:641 +0x158
|
github.com/couchbase/goxdcr/resource_manager.(*ResourceManager).manageResourcesOnce()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/resource_manager/resource_manager.go:536 +0x59a
|
github.com/couchbase/goxdcr/resource_manager.(*ResourceManager).manageResources()
|
/Users/neil.huang/source/couchbase/goproj/src/github.com/couchbase/goxdcr/resource_manager/resource_manager.go:514 +0x1c8
|
|
|
Minor