Java 类org.apache.hadoop.hbase.procedure.MasterProcedureManager 实例源码

项目：pbase 文件：MasterRpcServices.java

/**
 * Checks if the specified procedure is done.
 * @return true if the procedure is done,
 *   false if the procedure is in the process of completing
 * @throws ServiceException if invalid procedure, or
 *  a failed procedure with progress failure reason.
 */
@Override
public IsProcedureDoneResponse isProcedureDone(RpcController controller,
    IsProcedureDoneRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }
    LOG.debug("Checking to see if procedure from request:"
      + desc.getSignature() + " is done");

    IsProcedureDoneResponse.Builder builder =
      IsProcedureDoneResponse.newBuilder();
    boolean done = mpm.isProcedureDone(desc);
    builder.setDone(done);
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：HIndex 文件：HMaster.java

/**
 * Checks if the specified procedure is done.
 * @return true if the procedure is done,
 *   false if the procedure is in the process of completing
 * @throws ServiceException if invalid procedure, or
 *  a failed procedure with progress failure reason.
 */
@Override
public IsProcedureDoneResponse isProcedureDone(RpcController controller,
    IsProcedureDoneRequest request) throws ServiceException {
  ProcedureDescription desc = request.getProcedure();
  MasterProcedureManager mpm = this.mpmHost.getProcedureManager(desc
      .getSignature());
  if (mpm == null) {
    throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
  }
  LOG.debug("Checking to see if procedure from request:"
      + desc.getSignature() + " is done");

  try {
    IsProcedureDoneResponse.Builder builder = IsProcedureDoneResponse
        .newBuilder();
    boolean done = mpm.isProcedureDone(desc);
    builder.setDone(done);
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：PyroDB 文件：MasterRpcServices.java

/**
 * Checks if the specified procedure is done.
 * @return true if the procedure is done,
 *   false if the procedure is in the process of completing
 * @throws ServiceException if invalid procedure, or
 *  a failed procedure with progress failure reason.
 */
@Override
public IsProcedureDoneResponse isProcedureDone(RpcController controller,
    IsProcedureDoneRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }
    LOG.debug("Checking to see if procedure from request:"
      + desc.getSignature() + " is done");

    IsProcedureDoneResponse.Builder builder =
      IsProcedureDoneResponse.newBuilder();
    boolean done = mpm.isProcedureDone(desc);
    builder.setDone(done);
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：ditb 文件：MasterRpcServices.java

/**
 * Triggers a synchronous attempt to run a distributed procedure and sets
 * return data in response.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedureWithRet(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }

    LOG.info(master.getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

    byte[] data = mpm.execProcedureWithRet(desc);

    ExecProcedureResponse.Builder builder = ExecProcedureResponse.newBuilder();
    // set return data if available
    if (data != null) {
      builder.setReturnData(ByteString.copyFrom(data));
    }
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：pbase 文件：MasterRpcServices.java

/**
 * Triggers an asynchronous attempt to run a distributed procedure.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedure(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }

    LOG.info(master.getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

    mpm.execProcedure(desc);

    // send back the max amount of time the client should wait for the procedure
    // to complete
    long waitTime = SnapshotDescriptionUtils.DEFAULT_MAX_WAIT_TIME;
    return ExecProcedureResponse.newBuilder().setExpectedTimeout(
      waitTime).build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：pbase 文件：MasterRpcServices.java

/**
 * Triggers a synchronous attempt to run a distributed procedure and sets
 * return data in response.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedureWithRet(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }

    LOG.info(master.getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

    byte[] data = mpm.execProcedureWithRet(desc);

    ExecProcedureResponse.Builder builder = ExecProcedureResponse.newBuilder();
    // set return data if available
    if (data != null) {
      builder.setReturnData(ByteString.copyFrom(data));
    }
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：HIndex 文件：HMaster.java

/**
 * Triggers an asynchronous attempt to run a distributed procedure.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedure(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  ProcedureDescription desc = request.getProcedure();
  MasterProcedureManager mpm = this.mpmHost.getProcedureManager(desc
      .getSignature());
  if (mpm == null) {
    throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
  }

  LOG.info(getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

  try {
    mpm.execProcedure(desc);
  } catch (IOException e) {
    throw new ServiceException(e);
  }

  // send back the max amount of time the client should wait for the procedure
  // to complete
  long waitTime = SnapshotDescriptionUtils.DEFAULT_MAX_WAIT_TIME;
  return ExecProcedureResponse.newBuilder().setExpectedTimeout(waitTime)
      .build();
}

项目：hbase 文件：MasterRpcServices.java

/**
 * Triggers a synchronous attempt to run a distributed procedure and sets
 * return data in response.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedureWithRet(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.getMasterProcedureManagerHost().getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }

    LOG.info(master.getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

    byte[] data = mpm.execProcedureWithRet(desc);

    ExecProcedureResponse.Builder builder = ExecProcedureResponse.newBuilder();
    // set return data if available
    if (data != null) {
      builder.setReturnData(UnsafeByteOperations.unsafeWrap(data));
    }
    return builder.build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}

项目：PyroDB 文件：MasterRpcServices.java

/**
 * Triggers an asynchronous attempt to run a distributed procedure.
 * {@inheritDoc}
 */
@Override
public ExecProcedureResponse execProcedure(RpcController controller,
    ExecProcedureRequest request) throws ServiceException {
  try {
    master.checkInitialized();
    ProcedureDescription desc = request.getProcedure();
    MasterProcedureManager mpm = master.mpmHost.getProcedureManager(
      desc.getSignature());
    if (mpm == null) {
      throw new ServiceException("The procedure is not registered: "
        + desc.getSignature());
    }

    LOG.info(master.getClientIdAuditPrefix() + " procedure request for: "
      + desc.getSignature());

    mpm.execProcedure(desc);

    // send back the max amount of time the client should wait for the procedure
    // to complete
    long waitTime = SnapshotDescriptionUtils.DEFAULT_MAX_WAIT_TIME;
    return ExecProcedureResponse.newBuilder().setExpectedTimeout(
      waitTime).build();
  } catch (IOException e) {
    throw new ServiceException(e);
  }
}