[jira] [Created] (GEODE-5953) TXStateProxyImpl target needs to be set to local member if it contains TXState

["Eric Shu (JIRA)" <ji...@apache.org>]

Eric Shu created GEODE-5953:
-------------------------------

             Summary: TXStateProxyImpl target needs to be set to local member if it contains TXState
                 Key: GEODE-5953
                 URL: https://issues.apache.org/jira/browse/GEODE-5953
             Project: Geode
          Issue Type: Bug
          Components: transactions
            Reporter: Eric Shu


If target is not set earlier, it will be set in function execution code. It could cause issue when rebalance occurs during function execution by setting target to another node when the local member already hosts the transaction. If target was set earlier, the following code can detect it and throw TransactionDataRebalancedException.

  public void validateExecution(Function function, Set targetMembers) {
    InternalCache cache = pr.getGemFireCache();
    if (cache.getTxManager().getTXState() != null) {
      if (targetMembers.size() > 1) {
        throw new TransactionException(
            "Function inside a transaction cannot execute on more than one node");
      } else {
        assert targetMembers.size() == 1;
        DistributedMember funcTarget = (DistributedMember) targetMembers.iterator().next();
        DistributedMember target = cache.getTxManager().getTXState().getTarget();
        if (target == null) {
          cache.getTxManager().getTXState().setTarget(funcTarget);
        } else if (!target.equals(funcTarget)) {
          throw new TransactionDataRebalancedException(
              String.format(
                  "Function execution is not colocated with transaction. The transactional data is hosted on node %s, but you are trying to target node %s",
                  target, funcTarget));
        }
      }
    }
    cache.getInternalResourceManager().getHeapMonitor().checkForLowMemory(function, targetMembers);
  }



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)