Method addPointInternal

src/core/IncomingDataPoints.java:273–375

Implements #addPoint by storing a value with a specific flag. @param timestamp The timestamp to associate with the value. @param value The value to store. @param flags Flags to store in the qualifier (size and type of the data point). @return A deferred object tha

(final long timestamp,
      final byte[] value, final short flags)

   * @return A deferred object that indicates the completion of the request.
   */
  private Deferred<Object> addPointInternal(final long timestamp,
      final byte[] value, final short flags) {
    if (row == null) {
      throw new IllegalStateException("setSeries() never called!");
    }
    final boolean ms_timestamp = (timestamp & Const.SECOND_MASK) != 0;

    // we only accept unix epoch timestamps in seconds or milliseconds
    if (timestamp < 0 || (ms_timestamp && timestamp > 9999999999999L)) {
      throw new IllegalArgumentException((timestamp < 0 ? "negative " : "bad")
          + " timestamp=" + timestamp + " when trying to add value="
          + Arrays.toString(value) + " to " + this);
    }

    // always maintain last_ts in milliseconds
    if ((ms_timestamp ? timestamp : timestamp * 1000) <= last_ts) {
      if (allow_out_of_order_data) {
        // as we don't want to perform any funky calculations to find out if
        // we're still in the same time range, just pass it off to the regular
        // TSDB add function.
        return tsdb.addPointInternal(metric, timestamp, value, tags, flags);
      } else {
        throw new IllegalArgumentException("New timestamp=" + timestamp
            + " is less than or equal to previous=" + last_ts
            + " when trying to add value=" + Arrays.toString(value) + " to "
            + this);
      }
    }
    
    /** Callback executed for chaining filter calls to see if the value
     * should be written or not. */
    final class WriteCB implements Callback<Deferred<Object>, Boolean> {
      @Override
      public Deferred<Object> call(final Boolean allowed) throws Exception {
        if (!allowed) {
          return Deferred.fromResult(null);
        }
        

        last_ts = (ms_timestamp ? timestamp : timestamp * 1000);

        long base_time = baseTime();
        long incoming_base_time;
        if (ms_timestamp) {
          // drop the ms timestamp to seconds to calculate the base timestamp
          incoming_base_time = ((timestamp / 1000) - ((timestamp / 1000) % Const.MAX_TIMESPAN));
        } else {
          incoming_base_time = (timestamp - (timestamp % Const.MAX_TIMESPAN));
        }

        if (incoming_base_time - base_time >= Const.MAX_TIMESPAN) {
          // Need to start a new row as we've exceeded Const.MAX_TIMESPAN.
          base_time = updateBaseTime((ms_timestamp ? timestamp / 1000 : timestamp));
        }

        // Java is so stupid with its auto-promotion of int to float.
        final byte[] qualifier = Internal.buildQualifier(timestamp, flags);