/*
 * DSI utilities
 *
 * Copyright (C) 2012-2023 Sebastiano Vigna
 *
 * This program and the accompanying materials are made available under the
 * terms of the GNU Lesser General Public License v2.1 or later,
 * which is available at
 * http://www.gnu.org/licenses/old-licenses/lgpl-2.1-standalone.html,
 * or the Apache Software License 2.0, which is available at
 * https://www.apache.org/licenses/LICENSE-2.0.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE.
 *
 * SPDX-License-Identifier: LGPL-2.1-or-later OR Apache-2.0
 */

package it.unimi.dsi.test;

import java.io.IOException;

import org.apache.commons.math3.distribution.ZipfDistribution;

import it.unimi.dsi.bits.Fast;
import it.unimi.dsi.fastutil.doubles.DoubleArrays;
import it.unimi.dsi.fastutil.io.FastByteArrayOutputStream;
import it.unimi.dsi.io.InputBitStream;
import it.unimi.dsi.io.OutputBitStream;
import it.unimi.dsi.logging.ProgressLogger;
import it.unimi.dsi.util.XoShiRo256PlusRandomGenerator;

public class InputBitStreamSpeedTest  {

	private InputBitStreamSpeedTest() {}

	private static final int DELTA_DISTR_SIZE = 1000000;

	private static double[] delta_distr = new double[DELTA_DISTR_SIZE];
	static {
		double s = 0;
		for (int i = 1; i < DELTA_DISTR_SIZE; i++) {
			s += 1 / (2 * (i + 3) * (Fast.log2(i) + 2) * (Fast.log2(i) + 2));
			delta_distr[i] = s;
        }

		for (int i = 1; i < DELTA_DISTR_SIZE; i++) delta_distr[i] /= s;
	}

	@SuppressWarnings("resource")
	public static void main(final String[] arg) throws IOException {
		final int n = Integer.parseInt(arg[0]);
		final XoShiRo256PlusRandomGenerator r = new XoShiRo256PlusRandomGenerator(0);
		final ProgressLogger pl = new ProgressLogger();

		final ZipfDistribution zipf2 = new ZipfDistribution(r, 1_000_000_000, 2);
		final int data2[] = new int[n];
		for(int i = 0; i < n; i++)
			data2[i] = zipf2.sample() - 1;

		final ZipfDistribution zipf12 = new ZipfDistribution(r, 1_000_000_000, 1.2);
		final int data12[] = new int[n];
		for (int i = 0; i < n; i++)
			data12[i] = zipf12.sample() - 1;

		final int dataDelta[] = new int[n];
		for (int i = 0; i < n; i++) {
			int p = DoubleArrays.binarySearch(delta_distr, r.nextDouble());
			if (p < 0) p = -p - 2;
			dataDelta[i] = p;
		}

		final int dataUnary[] = new int[n];
		for (int i = 0; i < n; i++) dataUnary[i] = Long.numberOfTrailingZeros(r.nextLong());

		final FastByteArrayOutputStream fbaos = new FastByteArrayOutputStream();
		InputBitStream ibs;
		OutputBitStream obs;
		long u = 0;

		for (int k = 10; k-- != 0;) {
			fbaos.reset();
			obs = new OutputBitStream(fbaos);
			pl.start("Writing unary...");
			for (final int x : dataUnary) obs.writeLongUnary(x);
			pl.done(n);
			obs.flush();

			ibs = new InputBitStream(fbaos.array);
			pl.start("Reading unary...");
			for (int i = n; i-- != 0;) u += ibs.readLongUnary();
			pl.done(n);

			fbaos.reset();
			obs = new OutputBitStream(fbaos);
			pl.start("Writing ɣ...");
			for (final int x : data2)
				obs.writeLongGamma(x);
			pl.done(n);
			obs.flush();

			ibs = new InputBitStream(fbaos.array);
			pl.start("Reading ɣ...");
			for (int i = n; i-- != 0;)
				u += ibs.readLongGamma();
			pl.done(n);

			fbaos.reset();
			obs = new OutputBitStream(fbaos);
			pl.start("Writing δ..");
			for (final int x : dataDelta)
				obs.writeLongDelta(x);
			pl.done(n);
			obs.flush();

			ibs = new InputBitStream(fbaos.array);
			pl.start("Reading δ...");
			for (int i = n; i-- != 0;)
				u += ibs.readLongDelta();
			pl.done(n);

			fbaos.reset();
			obs = new OutputBitStream(fbaos);
			pl.start("Writing ζ..");
			for (final int x : data12)
				obs.writeLongZeta(x, 3);
			pl.done(n);
			obs.flush();

			ibs = new InputBitStream(fbaos.array);
			pl.start("Reading ζ...");
			for (int i = n; i-- != 0;)
				u += ibs.readLongZeta(3);
			pl.done(n);
		}

		if (u == 0)
			System.err.println();
	}

}