Method execute

test/Test.java:339–364

(final HBaseClient client, String[] args)

  private static final class cas implements Cmd {
    public void execute(final HBaseClient client, String[] args) throws Exception {
      ensureArguments(args, 8, 8);
      RowLock lock = null;
      if (args[1].charAt(0) == 'l') {  // locked version of the command
        final RowLockRequest rlr = new RowLockRequest(args[2], args[3]);
        lock = client.lockRow(rlr).joinUninterruptibly();
        LOG.info("Acquired explicit row lock: " + lock);
      }
      final PutRequest put = lock == null
        ? new PutRequest(args[2], args[3], args[4], args[5], args[7])
        : new PutRequest(args[2], args[3], args[4], args[5], args[7], lock);
      final String expected = args[6];
      args = null;
      try {
        final boolean ok = client.compareAndSet(put, expected).joinUninterruptibly();
        LOG.info("CAS "
                 + (ok ? "succeeded" : "failed: value wasn't " + expected));
      } catch (Exception e) {
        LOG.error("CAS failed", e);
      } finally {
        if (lock != null) {
          client.unlockRow(lock).joinUninterruptibly();
          LOG.info("Released explicit row lock: " + lock);
        }
      }
    }
  }

}