From f0a7aa5ec4f43ecb1bff33f552bfa7d6a0662cb2 Mon Sep 17 00:00:00 2001 From: Enrico Risa Date: Tue, 17 Dec 2019 17:11:01 +0100 Subject: [PATCH] Added keys in ha status -locks --- .../orient/server/distributed/impl/ODistributedOutput.java | 1 + .../server/distributed/impl/ONewDistributedTxContextImpl.java | 3 +++ 2 files changed, 4 insertions(+) diff --git a/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ODistributedOutput.java b/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ODistributedOutput.java index 1e69f99d679..250b434059f 100755 --- a/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ODistributedOutput.java +++ b/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ODistributedOutput.java @@ -738,6 +738,7 @@ public static List getRequestsStatus(final ODistributedAbstractPlugin row.field("startedOn", dateFormat.format(new Date(entries.getValue().getStartedOn()))); row.field("status", context.getStatus().toString()); row.field("records", context.getLockedRids().stream().map(Object::toString).collect(Collectors.toList())); + row.field("keys", context.getLockedKeys().stream().map(Object::toString).collect(Collectors.toList())); rows.add(row); } diff --git a/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ONewDistributedTxContextImpl.java b/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ONewDistributedTxContextImpl.java index 2773341144e..647eef8fbca 100644 --- a/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ONewDistributedTxContextImpl.java +++ b/distributed/src/main/java/com/orientechnologies/orient/server/distributed/impl/ONewDistributedTxContextImpl.java @@ -162,4 +162,7 @@ public List getLockedRids() { return lockedRids; } + public List getLockedKeys() { + return lockedKeys; + } }