Java 类org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.NoopRequest 实例源码

private Map<byte [], String> noop(final Table table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final Table table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final HTable table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final Table table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          CoprocessorRpcUtils.BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new CoprocessorRpcUtils.BlockingRpcCallback<>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final HTable table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final HTable table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

private Map<byte [], String> noop(final HTable table, final byte [] start,
    final byte [] end)
throws ServiceException, Throwable {
  return table.coprocessorService(PingProtos.PingService.class, start, end,
      new Batch.Call<PingProtos.PingService, String>() {
        @Override
        public String call(PingProtos.PingService instance) throws IOException {
          BlockingRpcCallback<PingProtos.NoopResponse> rpcCallback =
            new BlockingRpcCallback<PingProtos.NoopResponse>();
          PingProtos.NoopRequest.Builder builder = PingProtos.NoopRequest.newBuilder();
          instance.noop(null, builder.build(), rpcCallback);
          rpcCallback.get();
          // Looks like null is expected when void.  That is what the test below is looking for
          return null;
        }
      });
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

@Test (timeout=180000)
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (Region region: rs.getOnlineRegions(TEST_TABLE)) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE, null, null,
    Permission.Action.EXEC);
  try {
    // Create an action for invoking our test endpoint
    AccessTestAction execEndpointAction = new AccessTestAction() {
      @Override
      public Object run() throws Exception {
        try (Connection conn = ConnectionFactory.createConnection(conf);
            Table t = conn.getTable(TEST_TABLE);) {
          BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
          PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
        }
        return null;
      }
    };

    String namespace = TEST_TABLE.getNamespaceAsString();
    // Now grant EXEC to the entire namespace to user B
    grantOnNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // User B should now be allowed also
    verifyAllowed(execEndpointAction, userA, userB);

    revokeFromNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // Verify that EXEC permission is checked correctly
    verifyDenied(execEndpointAction, userB);
    verifyAllowed(execEndpointAction, userA);
  } finally {
    // Cleanup, revoke the userA privileges
    revokeFromTable(TEST_UTIL, userA.getShortName(), TEST_TABLE, null, null,
      Permission.Action.EXEC);
  }
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

@Test
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getOnlineRegions(TEST_TABLE.getTableName())) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE.getTableName(), null, null,
    Permission.Action.EXEC);

  // Create an action for invoking our test endpoint
  AccessTestAction execEndpointAction = new AccessTestAction() {
    @Override
    public Object run() throws Exception {
      Table t = new HTable(conf, TEST_TABLE.getTableName());
      try {
        BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
        PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
      } finally {
        t.close();
      }
      return null;
    }
  };

  // Verify that EXEC permission is checked correctly
  verifyDenied(execEndpointAction, userB);
  verifyAllowed(execEndpointAction, userA);

  // Now grant EXEC to the entire namespace to user B
  grantOnNamespace(TEST_UTIL, userB.getShortName(),
    TEST_TABLE.getTableName().getNamespaceAsString(),
    Permission.Action.EXEC);

  // User B should now be allowed also
  verifyAllowed(execEndpointAction, userA, userB);
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

@Test
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getOnlineRegions(TEST_TABLE.getTableName())) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE.getTableName(), null, null,
    Permission.Action.EXEC);

  // Create an action for invoking our test endpoint
  AccessTestAction execEndpointAction = new AccessTestAction() {
    @Override
    public Object run() throws Exception {
      HTable t = new HTable(conf, TEST_TABLE.getTableName());
      try {
        BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
        PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
      } finally {
        t.close();
      }
      return null;
    }
  };

  // Verify that EXEC permission is checked correctly
  verifyDenied(execEndpointAction, userB);
  verifyAllowed(execEndpointAction, userA);

  // Now grant EXEC to the entire namespace to user B
  grantOnNamespace(TEST_UTIL, userB.getShortName(),
    TEST_TABLE.getTableName().getNamespaceAsString(),
    Permission.Action.EXEC);

  // User B should now be allowed also
  verifyAllowed(execEndpointAction, userA, userB);
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

@Test (timeout=180000)
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getRegions(TEST_TABLE)) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE, null, null,
    Permission.Action.EXEC);
  try {
    // Create an action for invoking our test endpoint
    AccessTestAction execEndpointAction = new AccessTestAction() {
      @Override
      public Object run() throws Exception {
        try (Connection conn = ConnectionFactory.createConnection(conf);
            Table t = conn.getTable(TEST_TABLE)) {
          BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
          PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
        }
        return null;
      }
    };

    String namespace = TEST_TABLE.getNamespaceAsString();
    // Now grant EXEC to the entire namespace to user B
    grantOnNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // User B should now be allowed also
    verifyAllowed(execEndpointAction, userA, userB);

    revokeFromNamespace(TEST_UTIL, userB.getShortName(), namespace, Permission.Action.EXEC);
    // Verify that EXEC permission is checked correctly
    verifyDenied(execEndpointAction, userB);
    verifyAllowed(execEndpointAction, userA);
  } finally {
    // Cleanup, revoke the userA privileges
    revokeFromTable(TEST_UTIL, userA.getShortName(), TEST_TABLE, null, null,
      Permission.Action.EXEC);
  }
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> callback) {
  callback.run(NoopResponse.newBuilder().build());
}

@Test
public void testCoprocessorExec() throws Exception {
  // Set up our ping endpoint service on all regions of our test table
  for (JVMClusterUtil.RegionServerThread thread:
      TEST_UTIL.getMiniHBaseCluster().getRegionServerThreads()) {
    HRegionServer rs = thread.getRegionServer();
    for (HRegion region: rs.getOnlineRegions(TEST_TABLE.getTableName())) {
      region.getCoprocessorHost().load(PingCoprocessor.class,
        Coprocessor.PRIORITY_USER, conf);
    }
  }

  // Create users for testing, and grant EXEC privileges on our test table
  // only to user A
  User userA = User.createUserForTesting(conf, "UserA", new String[0]);
  User userB = User.createUserForTesting(conf, "UserB", new String[0]);

  grantOnTable(TEST_UTIL, userA.getShortName(),
    TEST_TABLE.getTableName(), null, null,
    Permission.Action.EXEC);

  // Create an action for invoking our test endpoint
  AccessTestAction execEndpointAction = new AccessTestAction() {
    @Override
    public Object run() throws Exception {
      HTable t = new HTable(conf, TEST_TABLE.getTableName());
      try {
        BlockingRpcChannel service = t.coprocessorService(HConstants.EMPTY_BYTE_ARRAY);
        PingCoprocessor.newBlockingStub(service).noop(null, NoopRequest.newBuilder().build());
      } finally {
        t.close();
      }
      return null;
    }
  };

  // Verify that EXEC permission is checked correctly
  verifyDenied(execEndpointAction, userB);
  verifyAllowed(execEndpointAction, userA);

  // Now grant EXEC to the entire namespace to user B
  grantOnNamespace(TEST_UTIL, userB.getShortName(),
    TEST_TABLE.getTableName().getNamespaceAsString(),
    Permission.Action.EXEC);

  // User B should now be allowed also
  verifyAllowed(execEndpointAction, userA, userB);
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}

@Override
public void noop(RpcController controller, NoopRequest request,
    RpcCallback<NoopResponse> done) {
  done.run(NoopResponse.newBuilder().build());
}