Method execute

src/tsd/PutDataPointRpc.java:128–260

(final TSDB tsdb, final Channel chan,
                                  final String[] cmd)

  }
  
  @Override
  public Deferred<Object> execute(final TSDB tsdb, final Channel chan,
                                  final String[] cmd) {
    telnet_requests.incrementAndGet();
    final DataPointType type;
    final String command = cmd[0].toLowerCase();

    if (command.equals("put")) {
      type = DataPointType.PUT;
      raw_dps.incrementAndGet();
    } else if (command.equals("rollup")) {
      type = DataPointType.ROLLUP;
      rollup_dps.incrementAndGet();
    } else if (command.equals("histogram")) {
      type = DataPointType.HISTOGRAM;
      raw_histograms.incrementAndGet();
    } else {
      throw new IllegalArgumentException("Unrecognized command: " + cmd[0]);
    }

    String errmsg = null;
    try {

      checkAuthorization(tsdb, chan, command);

      /**
       * Error callback that handles passing a data point to the storage 
       * exception handler as well as responding to the client when HBase
       * is unable to write the data.
       */
      final class PutErrback implements Callback<Object, Exception> {
        @Override
        public Object call(final Exception arg) {
          String errmsg = null;
          if (arg instanceof PleaseThrottleException) {
            if (send_telnet_errors) {
              errmsg = type + ": Please throttle writes: " + arg.getMessage() + '\n';
            }
            inflight_exceeded.incrementAndGet();
          } else {
            if (send_telnet_errors) {
              errmsg = type + ": HBase error: " + arg.getMessage()+ '\n';
            }
            if (arg instanceof HBaseException) {
              hbase_errors.incrementAndGet();
            } else if (arg instanceof IllegalArgumentException) {
              illegal_arguments.incrementAndGet();
            } else {
              unknown_errors.incrementAndGet();
            }
          }
          
          // we handle the storage exceptions here so as to avoid creating yet
          // another callback object on every data point.
          handleStorageException(tsdb, getDataPointFromString(tsdb, cmd), arg);
          
          if (send_telnet_errors) {
            if (chan.isConnected()) {