hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/states/endpoint/VersionEndpointTask.java
@Override
  public EndpointStateMachine.EndPointStates call() throws Exception {
    rpcEndPoint.lock();
    try{
      SCMVersionResponseProto versionResponse =
          rpcEndPoint.getEndPoint().getVersion(null);
      rpcEndPoint.setVersion(VersionResponse.getFromProtobuf(versionResponse));

      EndpointStateMachine.EndPointStates nextState =
          rpcEndPoint.getState().getNextState();
      rpcEndPoint.setState(nextState);
      rpcEndPoint.zeroMissedCount();
    } catch (IOException ex) {
      rpcEndPoint.logIfNeeded(ex);
    } finally {
      rpcEndPoint.unlock();
    }
    return rpcEndPoint.getState();
  }
/**
   * Computes a result, or throws an exception if unable to do so.
   *
   * @return computed result
   * @throws Exception if unable to compute a result
   */
Computes a result, or throws an exception if unable to do so.
@return computed result
@throws Exception if unable to compute a result
Computes a result or throws an exception if unable to do so . @return computed result @throws Exception if unable to compute a result
@Override
  public EndpointStateMachine.EndPointStates call() throws Exception {
    rpcEndPoint.lock();
    try{
      SCMVersionResponseProto versionResponse =
          rpcEndPoint.getEndPoint().getVersion(null);
      rpcEndPoint.setVersion(VersionResponse.getFromProtobuf(versionResponse));
      EndpointStateMachine.EndPointStates nextState =
          rpcEndPoint.getState().getNextState();
      rpcEndPoint.setState(nextState);
      rpcEndPoint.zeroMissedCount();
    } catch (IOException ex) {
      rpcEndPoint.logIfNeeded(ex);
    } finally {
      rpcEndPoint.unlock();
    }
    return rpcEndPoint.getState();
  }
@ Override public EndpointStateMachine . EndPointStates call ( ) throws Exception { rpcEndPoint . lock ( ) ; try { SCMVersionResponseProto versionResponse = rpcEndPoint . getEndPoint ( ) . getVersion ( null ) ; rpcEndPoint . setVersion ( VersionResponse . getFromProtobuf ( versionResponse ) ) ; EndpointStateMachine . EndPointStates nextState = rpcEndPoint . getState ( ) . getNextState ( ) ; rpcEndPoint . setState ( nextState ) ; rpcEndPoint . zeroMissedCount ( ) ; } catch ( IOException ex ) { rpcEndPoint . logIfNeeded ( ex ) ; } finally { rpcEndPoint . unlock ( ) ; } return rpcEndPoint . getState ( ) ; }
Computes a result, or throws an exception if unable to do so.
Computes a result or throws an exception if unable to do so .