This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-20177 in repository https://gitbox.apache.org/repos/asf/ignite.git
commit fbe380f6aba736273cc66933fb7396f2c82ed4ad Author: Anton Vinogradov <a...@apache.org> AuthorDate: Tue Aug 8 16:30:34 2023 +0300 WIP --- .../distributed/dht/GridDhtTxFinishFuture.java | 29 ++++++++++------------ 1 file changed, 13 insertions(+), 16 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java index 8330d80ba98..e53eacc2b74 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxFinishFuture.java @@ -44,7 +44,6 @@ import org.apache.ignite.internal.processors.tracing.Span; import org.apache.ignite.internal.util.future.GridFutureAdapter; import org.apache.ignite.internal.util.tostring.GridToStringExclude; import org.apache.ignite.internal.util.tostring.GridToStringInclude; -import org.apache.ignite.internal.util.typedef.C1; import org.apache.ignite.internal.util.typedef.F; import org.apache.ignite.internal.util.typedef.X; import org.apache.ignite.internal.util.typedef.internal.S; @@ -653,23 +652,21 @@ public final class GridDhtTxFinishFuture<K, V> extends GridCacheCompoundIdentity /** {@inheritDoc} */ @Override public String toString() { - Collection<String> futs = F.viewReadOnly(futures(), new C1<IgniteInternalFuture<?>, String>() { - @Override public String apply(IgniteInternalFuture<?> f) { - if (f.getClass() == MiniFuture.class) { - return "[node=" + ((MiniFuture)f).node().id() + - ", loc=" + ((MiniFuture)f).node().isLocal() + - ", done=" + f.isDone() + "]"; - } - else if (f instanceof MvccFuture) { - MvccFuture crdFut = (MvccFuture)f; + Collection<String> futs = F.viewReadOnly(futures(), (IgniteInternalFuture<?> f) -> { + if (f.getClass() == MiniFuture.class) { + return "[node=" + ((MiniFuture)f).node().id() + + ", loc=" + ((MiniFuture)f).node().isLocal() + + ", done=" + f.isDone() + "]"; + } + else if (f instanceof MvccFuture) { + MvccFuture crdFut = (MvccFuture)f; - return "[mvccCrdNode=" + crdFut.coordinatorNodeId() + - ", loc=" + crdFut.coordinatorNodeId().equals(cctx.localNodeId()) + - ", done=" + f.isDone() + "]"; - } - else - return f.toString(); + return "[mvccCrdNode=" + crdFut.coordinatorNodeId() + + ", loc=" + crdFut.coordinatorNodeId().equals(cctx.localNodeId()) + + ", done=" + f.isDone() + "]"; } + else + return f.toString(); }); return S.toString(GridDhtTxFinishFuture.class, this,