vldpyatkov commented on code in PR #13264:
URL: https://github.com/apache/ignite/pull/13264#discussion_r3481428596
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocalAdapter.java:
##########
@@ -767,27 +771,49 @@ private IgniteInternalFuture<GridCacheReturn>
obtainLockAsync(
return new GridEmbeddedFuture<>(
fut,
- new PLC1<GridCacheReturn>(ret) {
+ new PLC1<GridCacheReturn>(ret, true,
!waitTimeoutExpiresFirst(waitTimeout, timeout)) {
@Override protected GridCacheReturn postLock(GridCacheReturn
ret) throws IgniteCheckedException {
- if (log.isDebugEnabled())
- log.debug("Acquired transaction lock on keys: " +
passedKeys);
-
- postLockWrite(cacheCtx,
- passedKeys,
- ret,
- /*remove*/false,
- /*retval*/false,
- /*read*/read,
- accessTtl,
- CU.empty0(),
- /*computeInvoke*/false);
+ assert fut.error() == null;
+
+ boolean success = Boolean.TRUE.equals(fut.get());
Review Comment:
It is not necessary because it is a part of GridEmbeddedFuture which is used
to execute code after the nested future. So you can take a future value when
the code is executing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
