/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.cassandra.utils;

import java.util.concurrent.CancellationException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;

import com.google.common.annotations.VisibleForTesting;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import org.apache.cassandra.concurrent.ScheduledExecutors;
import org.apache.cassandra.config.Config;

import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static org.apache.cassandra.utils.ApproximateTime.Measurement.ALMOST_NOW;
import static org.apache.cassandra.utils.ApproximateTime.Measurement.ALMOST_SAME_TIME;

/**
 * This class provides approximate time utilities:
 *   - An imprecise nanoTime (monotonic) and currentTimeMillis (non-monotonic), that are faster than their regular counterparts
 *     They have a configured approximate precision (default of 10ms), which is the cadence they will be updated if the system is healthy
 *   - A mechanism for converting between nanoTime and currentTimeMillis measurements.
 *     These conversions may have drifted, and they offer no absolute guarantees on precision
 */
public class ApproximateTime
{
    private static final Logger logger = LoggerFactory.getLogger(ApproximateTime.class);
    private static final int ALMOST_NOW_UPDATE_INTERVAL_MS = Math.max(1, Integer.parseInt(System.getProperty(Config.PROPERTY_PREFIX + "approximate_time_precision_ms", "2")));
    private static final String CONVERSION_UPDATE_INTERVAL_PROPERTY = Config.PROPERTY_PREFIX + "NANOTIMETOMILLIS_TIMESTAMP_UPDATE_INTERVAL";
    private static final long ALMOST_SAME_TIME_UPDATE_INTERVAL_MS = Long.getLong(CONVERSION_UPDATE_INTERVAL_PROPERTY, 10000);

    public static class AlmostSameTime
    {
        final long millis;
        final long nanos;
        final long error; // maximum error of millis measurement (in nanos)

        private AlmostSameTime(long millis, long nanos, long error)
        {
            this.millis = millis;
            this.nanos = nanos;
            this.error = error;
        }

        public long toCurrentTimeMillis(long nanoTime)
        {
            return millis + TimeUnit.NANOSECONDS.toMillis(nanoTime - nanos);
        }

        public long toNanoTime(long currentTimeMillis)
        {
            return nanos + MILLISECONDS.toNanos(currentTimeMillis - millis);
        }
    }

    public enum Measurement { ALMOST_NOW, ALMOST_SAME_TIME }

    private static volatile Future<?> almostNowUpdater;
    private static volatile Future<?> almostSameTimeUpdater;

    private static volatile long almostNowMillis;
    private static volatile long almostNowNanos;

    private static volatile AlmostSameTime almostSameTime = new AlmostSameTime(0L, 0L, Long.MAX_VALUE);
    private static double failedAlmostSameTimeUpdateModifier = 1.0;

    private static final Runnable refreshAlmostNow = () -> {
        almostNowMillis = System.currentTimeMillis();
        almostNowNanos = System.nanoTime();
    };

    private static final Runnable refreshAlmostSameTime = () -> {
        final int tries = 3;
        long[] samples = new long[2 * tries + 1];
        samples[0] = System.nanoTime();
        for (int i = 1 ; i < samples.length ; i += 2)
        {
            samples[i] = System.currentTimeMillis();
            samples[i + 1] = System.nanoTime();
        }

        int best = 1;
        // take sample with minimum delta between calls
        for (int i = 3 ; i < samples.length - 1 ; i += 2)
        {
            if ((samples[i+1] - samples[i-1]) < (samples[best+1]-samples[best-1]))
                best = i;
        }

        long millis = samples[best];
        long nanos = (samples[best+1] / 2) + (samples[best-1] / 2);
        long error = (samples[best+1] / 2) - (samples[best-1] / 2);

        AlmostSameTime prev = almostSameTime;
        AlmostSameTime next = new AlmostSameTime(millis, nanos, error);

        if (next.error > prev.error && next.error > prev.error * failedAlmostSameTimeUpdateModifier)
        {
            failedAlmostSameTimeUpdateModifier *= 1.1;
            return;
        }

        failedAlmostSameTimeUpdateModifier = 1.0;
        almostSameTime = next;
    };

    static
    {
        start(ALMOST_NOW);
        start(ALMOST_SAME_TIME);
    }

    public static synchronized void stop(Measurement measurement)
    {
        switch (measurement)
        {
            case ALMOST_NOW:
                almostNowUpdater.cancel(true);
                try { almostNowUpdater.get(); } catch (Throwable t) { }
                almostNowUpdater = null;
                break;
            case ALMOST_SAME_TIME:
                almostSameTimeUpdater.cancel(true);
                try { almostSameTimeUpdater.get(); } catch (Throwable t) { }
                almostSameTimeUpdater = null;
                break;
        }
    }

    public static synchronized void start(Measurement measurement)
    {
        switch (measurement)
        {
            case ALMOST_NOW:
                if (almostNowUpdater != null)
                    throw new IllegalStateException("Already running");
                refreshAlmostNow.run();
                logger.info("Scheduling approximate time-check task with a precision of {} milliseconds", ALMOST_NOW_UPDATE_INTERVAL_MS);
                almostNowUpdater = ScheduledExecutors.scheduledFastTasks.scheduleWithFixedDelay(refreshAlmostNow, ALMOST_NOW_UPDATE_INTERVAL_MS, ALMOST_NOW_UPDATE_INTERVAL_MS, MILLISECONDS);
                break;
            case ALMOST_SAME_TIME:
                if (almostSameTimeUpdater != null)
                    throw new IllegalStateException("Already running");
                refreshAlmostSameTime.run();
                logger.info("Scheduling approximate time conversion task with an interval of {} milliseconds", ALMOST_SAME_TIME_UPDATE_INTERVAL_MS);
                almostSameTimeUpdater = ScheduledExecutors.scheduledFastTasks.scheduleWithFixedDelay(refreshAlmostSameTime, ALMOST_SAME_TIME_UPDATE_INTERVAL_MS, ALMOST_SAME_TIME_UPDATE_INTERVAL_MS, MILLISECONDS);
                break;
        }
    }


    /**
     * Request an immediate refresh; this shouldn't generally be invoked, except perhaps by tests
     */
    @VisibleForTesting
    public static synchronized void refresh(Measurement measurement)
    {
        stop(measurement);
        start(measurement);
    }

    /** no guarantees about relationship to nanoTime; non-monotonic (tracks currentTimeMillis as closely as possible) */
    public static long currentTimeMillis()
    {
        return almostNowMillis;
    }

    /** no guarantees about relationship to currentTimeMillis; monotonic */
    public static long nanoTime()
    {
        return almostNowNanos;
    }
}