in bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/CongestionController.java [163:169]
private InsertMetrics atomicGetAndReplace(InsertMetrics metrics) {
synchronized (aggregateLock) {
InsertMetrics old = this.aggregatedInsertMetrics;
this.aggregatedInsertMetrics = metrics;
return old;
}
}