changing addindexmutation

dgraph-io · Oct 23, 2024 · 83006e4 · 83006e4
1 parent 6961384
commit 83006e4
Showing 1 changed file with 17 additions and 17 deletions.
diff --git a/posting/index.go b/posting/index.go
@@ -217,26 +217,26 @@ func (txn *Txn) addIndexMutation(ctx context.Context, edge *pb.DirectedEdge, tok
 		return err
 	}
 
-	//if err = plist.addMutation(ctx, txn, edge); err != nil {
-	//	return err
-	//}
-
-	mpost := NewPosting(edge)
-	mpost.StartTs = txn.StartTs
-	if mpost.PostingType != pb.Posting_REF {
-		edge.ValueId = fingerprintEdge(edge)
-		mpost.Uid = edge.ValueId
+	if err = plist.addMutation(ctx, txn, edge); err != nil {
+		return err
 	}
 
-	//fmt.Println("ADDING MUTATION", plist.mutationMap, key, edge)
-	txn.addConflictKey(indexConflicKey(key, edge))
+	//mpost := NewPosting(edge)
+	//mpost.StartTs = txn.StartTs
+	//if mpost.PostingType != pb.Posting_REF {
+	//	edge.ValueId = fingerprintEdge(edge)
+	//	mpost.Uid = edge.ValueId
+	//}
 
-	plist.Lock()
-	defer plist.Unlock()
-	if err != plist.updateMutationLayer(mpost, false) {
-		return errors.Wrapf(err, "cannot update mutation layer of key %s with value %+v",
-			hex.EncodeToString(plist.key), mpost)
-	}
+	////fmt.Println("ADDING MUTATION", plist.mutationMap, key, edge)
+	//txn.addConflictKey(indexConflicKey(key, edge))
+
+	//plist.Lock()
+	//defer plist.Unlock()
+	//if err != plist.updateMutationLayer(mpost, false) {
+	//	return errors.Wrapf(err, "cannot update mutation layer of key %s with value %+v",
+	//		hex.EncodeToString(plist.key), mpost)
+	//}
 
 	//ostats.Record(ctx, x.NumEdges.M(1))
 	return nil