Examples of MasterProtocol

com.alibaba.wasp.master.MasterProtocol
org.apache.hadoop.hbase.MasterProtocol
Functions implemented by all the master protocols: e.g. {@link MasterAdminProtocol}and {@link MasterMonitorProtocol}. Currently, the only shared method {@link #isMasterRunning(com.google.protobuf.RpcController,org.apache.hadoop.hbase.protobuf.generated.MasterProtos.IsMasterRunningRequest)}which is used on connection setup to check if the master has been stopped.

Examples of com.alibaba.wasp.master.MasterProtocol

          throw new MasterNotRunningException(msg);
        }


        InetSocketAddress isa = new InetSocketAddress(sn.getHostname(),
            sn.getPort());
        MasterProtocol tryMaster = (MasterProtocol) WaspRPC.getProxy(
            masterProtocolState.protocolClass, masterProtocolState.version,
            isa, this.conf, this.rpcTimeout);


        if (tryMaster.isMasterRunning(null,
            RequestConverter.buildIsMasterRunningRequest())
            .getIsMasterRunning()) {
          return tryMaster;
        } else {
          WaspRPC.stopProxy(tryMaster);

View Full Code Here

Examples of com.alibaba.wasp.master.MasterProtocol


      // The lock must be at the beginning to prevent multiple master creation
      // (and leaks) in a multithread context
      synchronized (this.masterAndZKLock) {
        Exception exceptionCaught = null;
        MasterProtocol master = null;
        int tries = 0;
        while (!this.closed && master == null) {
          tries++;
          try {
            master = createMasterInterface(masterProtocolState);

View Full Code Here

Examples of org.apache.hadoop.hbase.MasterProtocol

        }




        InetSocketAddress isa =
          new InetSocketAddress(sn.getHostname(), sn.getPort());
        MasterProtocol tryMaster = rpcEngine.getProxy(
            masterProtocolState.protocolClass,
            isa, this.conf, this.rpcTimeout);


        if (tryMaster.isMasterRunning(
            null, RequestConverter.buildIsMasterRunningRequest()).getIsMasterRunning()) {
          return tryMaster;
        } else {
          String msg = "Can create a proxy to master, but it is not running";
          LOG.info(msg);

View Full Code Here

Examples of org.apache.hadoop.hbase.MasterProtocol

      // The lock must be at the beginning to prevent multiple master creation
      //  (and leaks) in a multithread context


      synchronized (this.masterAndZKLock) {
        Exception exceptionCaught = null;
        MasterProtocol master = null;
        int tries = 0;
        while (
          !this.closed && master == null
          ) {
          tries++;

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.