This is an automated email from the ASF dual-hosted git repository.
sanpwc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new f42ff7229c IGNITE-21040 Placement driver logging enhancement (#2967)
f42ff7229c is described below
commit f42ff7229c15c7539ad9e017c10c741029fc62a2
Author: Denis Chudov <[email protected]>
AuthorDate: Mon Dec 18 19:07:19 2023 +0300
IGNITE-21040 Placement driver logging enhancement (#2967)
---
.../ignite/internal/placementdriver/leases/Leases.java | 16 ++++++++++++++++
.../org/apache/ignite/internal/replicator/Replica.java | 3 +--
2 files changed, 17 insertions(+), 2 deletions(-)
diff --git
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/Leases.java
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/Leases.java
index f5c480ad6d..0fa519c143 100644
---
a/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/Leases.java
+++
b/modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/leases/Leases.java
@@ -19,14 +19,25 @@ package org.apache.ignite.internal.placementdriver.leases;
import java.util.Map;
import org.apache.ignite.internal.replicator.ReplicationGroupId;
+import org.apache.ignite.internal.tostring.IgniteToStringExclude;
+import org.apache.ignite.internal.tostring.S;
/** Leases received from the metastore. */
public class Leases {
private final Map<ReplicationGroupId, Lease> leaseByGroupId;
+ @IgniteToStringExclude
private final byte[] leasesBytes;
+ /**
+ * The constructor.
+ *
+ * @param leaseByGroupId Leases by group map.
+ * @param leasesBytes Serialized leases.
+ */
public Leases(Map<ReplicationGroupId, Lease> leaseByGroupId, byte[]
leasesBytes) {
+ assert leaseByGroupId != null;
+
this.leaseByGroupId = leaseByGroupId;
this.leasesBytes = leasesBytes;
}
@@ -40,4 +51,9 @@ public class Leases {
public byte[] leasesBytes() {
return leasesBytes;
}
+
+ @Override
+ public String toString() {
+ return S.toString(this);
+ }
}
diff --git
a/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
b/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
index 2fdde8028e..3a4c53b2b8 100644
---
a/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
+++
b/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
@@ -231,8 +231,7 @@ public class Replica {
HybridTimestamp leaseStartTime,
HybridTimestamp leaseExpirationTime
) {
- LOG.info("Lease accepted, group=" + groupId() + ", leaseStartTime=" +
leaseStartTime + ", leaseExpirationTime="
- + leaseExpirationTime);
+ LOG.info("Lease accepted [group=" + groupId() + ", leaseStartTime=" +
leaseStartTime + "].");
this.leaseExpirationTime = leaseExpirationTime;