fix

NamanJain8 · NamanJain8 · commit e978b65e0043 · 2021-02-24T22:30:57.000+05:30
diff --git a/dgraph/cmd/zero/oracle.go b/dgraph/cmd/zero/oracle.go
@@ -263,15 +263,12 @@ func (o *Oracle) sendDeltasToSubscribers() {
 }
 
 func (o *Oracle) updateCommitStatusHelper(index uint64, src *api.TxnContext) bool {
-	if _, ok := o.commits.Load(src.StartTs); ok {
-		return true
-	}
+	ts := src.CommitTs
 	if src.Aborted {
-		o.commits.Store(src.StartTs, 0)
-	} else {
-		o.commits.Store(src.StartTs, src.CommitTs)
+		ts = 0
 	}
-	return true
+	_, exist := o.commits.LoadOrStore(src.StartTs, ts)
+	return !exist
 }
 
 func (o *Oracle) updateCommitStatus(index uint64, src *api.TxnContext) {

Original file line number	Diff line number	Diff line change
`@@ -263,15 +263,12 @@ func (o *Oracle) sendDeltasToSubscribers() {`
`263`	`263`	`}`
`264`	`264`
`265`	`265`	`func (o Oracle) updateCommitStatusHelper(index uint64, src api.TxnContext) bool {`
`266`		`- if _, ok := o.commits.Load(src.StartTs); ok {`
`267`		`- return true`
`268`		`- }`
	`266`	`+ ts := src.CommitTs`
`269`	`267`	`if src.Aborted {`
`270`		`- o.commits.Store(src.StartTs, 0)`
`271`		`- } else {`
`272`		`- o.commits.Store(src.StartTs, src.CommitTs)`
	`268`	`+ ts = 0`
`273`	`269`	`}`
`274`		`- return true`
	`270`	`+ _, exist := o.commits.LoadOrStore(src.StartTs, ts)`
	`271`	`+ return !exist`
`275`	`272`	`}`
`276`	`273`
`277`	`274`	`func (o Oracle) updateCommitStatus(index uint64, src api.TxnContext) {`