diff options
author | valerijf <valerijf@yahoo-inc.com> | 2017-05-12 09:28:06 +0200 |
---|---|---|
committer | valerijf <valerijf@yahoo-inc.com> | 2017-05-12 09:40:38 +0200 |
commit | 09be694323fbe1955c345e183d807d7c60e80c51 (patch) | |
tree | 71dd6c36587e0d256b6c57ec05a7faf17abbaaba /vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java | |
parent | bd6bb3b7518e3da3869d1f45741c0cd86795308a (diff) |
Code review fixes
Diffstat (limited to 'vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java')
-rw-r--r-- | vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java index 218d1779bb5..dbcb55cfd06 100644 --- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java @@ -16,7 +16,7 @@ import com.yahoo.documentapi.VisitorParameters; import com.yahoo.documentapi.VisitorSession; import com.yahoo.documentapi.messagebus.MessageBusSyncSession; import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol; -import com.yahoo.documentapi.metrics.DocumentApiMetricsHelper; +import com.yahoo.documentapi.metrics.DocumentApiMetrics; import com.yahoo.documentapi.metrics.DocumentOperationStatus; import com.yahoo.documentapi.metrics.DocumentOperationType; import com.yahoo.messagebus.StaticThrottlePolicy; @@ -32,6 +32,7 @@ import org.apache.commons.lang3.exception.ExceptionUtils; import java.io.ByteArrayOutputStream; import java.nio.charset.StandardCharsets; +import java.time.Instant; import java.util.List; import java.util.Optional; import java.util.Set; @@ -49,7 +50,7 @@ public class OperationHandlerImpl implements OperationHandler { public static final int VISIT_TIMEOUT_MS = 120000; private final DocumentAccess documentAccess; - private final DocumentApiMetricsHelper metricsHelper; + private final DocumentApiMetrics metricsHelper; private final ClusterEnumerator clusterEnumerator; private static final class SyncSessionFactory extends ResourceFactory<SyncSession> { @@ -73,7 +74,7 @@ public class OperationHandlerImpl implements OperationHandler { this.documentAccess = documentAccess; this.clusterEnumerator = clusterEnumerator; syncSessions = new ConcurrentResourcePool<>(new SyncSessionFactory(documentAccess)); - metricsHelper = new DocumentApiMetricsHelper(metricReceiver, "documentV1"); + metricsHelper = new DocumentApiMetrics(metricReceiver, "documentV1"); } @Override @@ -188,7 +189,7 @@ public class OperationHandlerImpl implements OperationHandler { SyncSession syncSession = syncSessions.alloc(); Response response; try { - long startTime = System.currentTimeMillis(); + Instant startTime = Instant.now(); DocumentPut put = new DocumentPut(data.getDocument()); put.setCondition(data.getCondition()); setRoute(syncSession, route); @@ -212,7 +213,7 @@ public class OperationHandlerImpl implements OperationHandler { SyncSession syncSession = syncSessions.alloc(); Response response; try { - long startTime = System.currentTimeMillis(); + Instant startTime = Instant.now(); setRoute(syncSession, route); syncSession.update(data.getDocumentUpdate()); metricsHelper.reportSuccessful(DocumentOperationType.UPDATE, startTime); @@ -234,7 +235,7 @@ public class OperationHandlerImpl implements OperationHandler { SyncSession syncSession = syncSessions.alloc(); Response response; try { - long startTime = System.currentTimeMillis(); + Instant startTime = Instant.now(); DocumentId id = new DocumentId(restUri.generateFullId()); DocumentRemove documentRemove = new DocumentRemove(id); setRoute(syncSession, route); |