Issue-ID: AAI-3308
Signed-off-by: Niharika Sharma <niharika.sharma@amdocs.com>
Change-Id: I7d2d591928987b9f5f9465325fc1c4d03dee3db2
graphMgmt.setConsistency(propK, ConsistencyModifier.LOCK);
}
}
graphMgmt.setConsistency(propK, ConsistencyModifier.LOCK);
}
}
+ else if (dbPropName.equals("resource-version")) {
+ String aai_rv_lock_enabled = AAIConfig.get(AAIConstants.AAI_LOCK_RV_ENABLED, "false");
+ LOGGER.info(" Info: aai_rv_lock_enabled:" + aai_rv_lock_enabled);
+ if ("true".equals(aai_rv_lock_enabled)) {
+ LOGGER.info(" Lock is being set for resource-version Property.");
+ graphMgmt.setConsistency(propK, ConsistencyModifier.LOCK);
+ }
+ }
seenProps.put(dbPropName, propK);
} else {
propK = seenProps.get(dbPropName);
seenProps.put(dbPropName, propK);
} else {
propK = seenProps.get(dbPropName);
graphMgmt.setConsistency(indexG, ConsistencyModifier.LOCK);
}
}
graphMgmt.setConsistency(indexG, ConsistencyModifier.LOCK);
}
}
+ else if (indexG != null && dbPropName.equals("resource-version")) {
+ String aai_rv_lock_enabled = AAIConfig.get(AAIConstants.AAI_LOCK_RV_ENABLED, "false");
+ LOGGER.info(" Info:: aai_rv_lock_enabled:" + aai_rv_lock_enabled);
+ if ("true".equals(aai_rv_lock_enabled)) {
+ LOGGER.info("Lock is being set for resource-version Index.");
+ graphMgmt.setConsistency(indexG, ConsistencyModifier.LOCK);
+ }
+ }
} else {
LOGGER.info("No index added for PropertyKey: [{}]", dbPropName);
}
} else {
LOGGER.info("No index added for PropertyKey: [{}]", dbPropName);
}
/** Flag to control concurrency lock */
public static final String AAI_LOCK_URI_ENABLED = "aai.lock.uri.enabled";
/** Flag to control concurrency lock */
public static final String AAI_LOCK_URI_ENABLED = "aai.lock.uri.enabled";
+ public static final String AAI_LOCK_RV_ENABLED = "aai.lock.rv.enabled";
+
/**
* Instantiates a new AAI constants.
*/
/**
* Instantiates a new AAI constants.
*/