fixed: write consistency

PaloAltoNetworks · Dec 13, 2018 · ea001c6 · ea001c6
1 parent c430ce8
commit ea001c6
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/manipmongo/manipulator.go b/manipmongo/manipulator.go
@@ -442,15 +442,12 @@ func (s *mongoManipulator) makeSession(
 ) (*mgo.Collection, func()) {
 
 	session := s.rootSession.Copy()
-	mrc := convertReadConsistency(readConsistency)
-	if mrc != -1 {
+
+	if mrc := convertReadConsistency(readConsistency); mrc != -1 {
 		session.SetMode(mrc, true)
 	}
 
-	mwc := convertWriteConsistency(writeConsistency)
-	if mrc != -1 {
-		session.SetSafe(mwc)
-	}
+	session.SetSafe(convertWriteConsistency(writeConsistency))
 
 	return session.DB(s.dbName).C(identity.Name), session.Close
 }