/*
 * Copyright (c) 2006, 2009 The Australian National University.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Apache License v2.0.
 * You may obtain the license at
 * 
 *    http://www.opensource.org/licenses/apache2.0.php
 */
package org.dacapo.parser;

import com.jingpu.android.apersistance.util.TPCCLog;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
import java.net.URL;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.Set;
import java.util.Vector;


/**
 * Container class for all options specified in a benchmark's configuration
 * file.
 * 
 * @date $Date: 2009-12-24 11:19:36 +1100 (Thu, 24 Dec 2009) $
 * @id $Id: Config.java 738 2009-12-24 00:19:36Z steveb-oss $
 */
public class Config {

  /**
   * threadCount is the specified threadCountOverride from the user. A value of
   * 0 indicates that it is unspecified and not to override the standard
   * configuration
   */
  private static int threadCountOverride = 0;

  public static void setThreadCountOverride(int threadCount) {
    threadCountOverride = threadCount;
  }

  public static int getThreadCountOverride() {
    return threadCountOverride;
  }

  public enum ThreadModel {
    SINGLE("single threaded"), FIXED("fixed #threads"), PER_CPU("scaled to available CPUs");

    private String description;

    private ThreadModel(String description) {
      this.description = description;
    }

    public String describe() {
      return description;
    }
  };

  /**
   * Inner class that keeps details of one of the output files specified by a
   * benchmark.
   */
  class OutputFile {
    String name; // Output file name
    String digest = null; // SHA1-digest - check if non-null
    boolean keep = false; // keep this file
    boolean existence = false; // Check file exists
    int lines = -1; // Check for #lines
    long bytes = -1; // Check for #bytes

    /* Options that apply to digest processing */
    boolean text = false; // Read as a text file - canonical CR/LF processing
    boolean filter = false; // Filter scratch directory name

    OutputFile(String name) {
      this.name = name;
    }

    boolean hasDigest() {
      return digest != null;
    }

    boolean hasLines() {
      return lines != -1;
    }

    boolean hasBytes() {
      return bytes != -1;
    }
  }

  /**
   * Inner class to encapsulate specifications for a given sized run of a
   * benchmark.
   * 
   * @author Robin Garner
   * 
   */
  class Size {
    final String name;
    final String[] args;

    /**
     * Number of threads. Interpretation depends on the threading model of the
     * benchmark
     * <ul>
     * <li> <code>SINGLE</code> One thread
     * <li> <code>FIXED</code> the exact number of threads used.
     * <li> <code>PER_CPU</code> A multiplier on the number of CPUs detected or
     * specified
     * </ul>
     */
    private int threadLimit = 0;
    private int nThreads = 1;
    private String description;

    HashMap<String, OutputFile> outputFiles = new LinkedHashMap<String, OutputFile>(20);

    Size(String name, Vector<String> args) {
      this.args = (String[]) args.toArray(new String[0]);
      this.name = name;
    }

    void addOutputFile(String file) {
      outputFiles.put(file, new OutputFile(file));
    }

    OutputFile getOutputFile(String file) {
      return (OutputFile) outputFiles.get(file);
    }

    void setThreadLimit(int threadLimit) {
      this.threadLimit = threadLimit;
    }

    int getThreadLimit() {
      return threadLimit;
    }

    void setThreadCount(int nThreads) {
      this.nThreads = nThreads;
    }

    int getThreadCount() {
      return nThreads;
    }

    void setDesc(String description) {
      this.description = description;
    }

    String getDesc() {
      return description;
    }
  }

  /*********************************************************************************
   * 
   * Class methods. Factory methods that invoke the parser on various input
   * sources
   */

  /**
   * Parse a config file
   * 
   * @param file
   * @return
   */
  public static Config parse(String file) {
    return parse(new File(file));
  }

  /**
   * Parse a config file
   * 
   * @param file
   * @return
   */
  public static Config parse(File file) {
    try {
      return parse(new FileInputStream(file));
    } catch (FileNotFoundException e) {
      e.printStackTrace();
    }
    return null;
  }

  /**
   * Parse a config file
   * 
   * @param url
   * @return
   */
  public static Config parse(URL url) {
    try {
      return parse(url.openStream());
    } catch (IOException e) {
      e.printStackTrace();
      return null;
    }
  }

  public static Config parse(InputStream stream) {
    try {
      ConfigFile parser = new ConfigFile(stream);

      return parser.configFile();
    } catch (ParseException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    return null;
  }

  /**
   * Main - for testing purposes. Parse a config file and print its contents.
   * 
   * @param args Input file(s)
   */
  public static void main(String[] args) {
    // TODO Auto-generated method stub
    for (int i = 0; i < args.length; i++) {
      parse(args[i]).print(System.out);
    }
  }

  /********************************************************************************
   * 
   * Instance fields
   */

  /**
   * The name of the benchmark
   */
  public final String name;

  /**
   * The class name of the benchmark driver
   */
  public String className = null;

  /**
   * The threading model used by the benchmark
   */
  private ThreadModel threadModel = null;

  HashMap<String, Size> sizes = new HashMap<String, Size>(3);
  HashMap<String, String> desc = new HashMap<String, String>(6);

  /**
   * The name of the jar containing this bm
   */
  public String jar;

  /**
   * The list of jars upon which this bm depends
   */
  public String[] libs;

  /**
   * Constructor. These are always constructed by the parser, and at time of
   * construction all we know is the benchmark name.
   * 
   * @param name
   */
  Config(String name) {
    this.name = name;
  }

  /**************************************************************************************
   * 
   * Per-benchmark setter methods. Invoked as the parser finds out more about
   * the benchmark.
   * 
   */

  /**
   * Set the jar from which this benchmark executes
   * 
   * @param jarName The name of the jar
   * @throws ParseException
   */
  void setJar(String jarName) throws ParseException {
    if (this.jar != null) {
      throw new ParseException("Configuration file error - cannot set jar name twice");
    }
    this.jar = jarName;
  }

  /**
   * Set the list of libraries on which this benchmark depends
   * 
   * @param libs An array of strings (jar names)
   * @throws ParseException
   */
  void setLibs(String[] libs) throws ParseException {
    if (this.libs != null) {
      throw new ParseException("Configuration file error - cannot set libs twice");
    }
    this.libs = libs;
  }

  /**
   * Set the class name - easier to check for duplicate attempts here than in
   * the grammar.
   * 
   * @param className
   * @throws ParseException
   */
  void setClass(String className) throws ParseException {
    if (this.className != null) {
      throw new ParseException("Configuration file error - cannot set class name twice");
    }
    this.className = className;
  }

  /**
   * Set the threading model for this benchmark
   * 
   * @param model
   * @throws ParseException
   */
  void setThreadModel(ThreadModel model) throws ParseException {
    if (this.threadModel != null) {
      throw new ParseException("Configuration file error - cannot set thread model twice");
    }
    this.threadModel = model;
  }

  /**
   * Add a benchmark run size
   * 
   * @param name
   * @param args
   */
  void addSize(String name, Vector<String> args) {
    sizes.put(name, new Size(name, args));
  }

  /**
   * Add a description element for the benchmark
   * 
   * @param element
   * @param description
   */
  void addDesc(String element, String description) {
    desc.put(element, description);
  }

  /*************************************************************************************
   * 
   * Per-config getter methods
   * 
   */

  /***************************************************************************************
   * 
   * Per-size setter methods
   * 
   */

  /**
   * 
   */
  void setThreadLimit(String size, int threadLimit) throws ParseException {
    if (threadModel == ThreadModel.SINGLE || threadModel == ThreadModel.FIXED)
      throw new ParseException("Thread limit is not valid for Single and Fixed threading models");
    if (threadLimit < 0)
      throw new ParseException("Thread limit cannot be less than 0");
    getSize(size).setThreadLimit(threadLimit);
  }

  /**
   * Set the threading factor for this size.
   */
  public void setThreadFactor(String size, int nThreads) throws ParseException {
    if (threadModel == ThreadModel.SINGLE && nThreads != 1)
      throw new ParseException("Single threaded benchmarks must have exactly 1 thread");
    if (nThreads < 1)
      throw new ParseException("Thread factor or number must be 1 or more");
    getSize(size).setThreadCount(nThreads);
    if (threadModel == ThreadModel.SINGLE || threadModel == ThreadModel.FIXED)
      getSize(size).setThreadLimit(nThreads);
  }

  /**
   * 
   */
  void setSizeDescription(String size, String description) throws ParseException {
    getSize(size).setDesc(description);
  }

  /*************************************************************************************
   * Output files
   */

  /**
   * Add an output file to this size of the benchmark
   */
  void addOutputFile(String size, String file) {
    getSize(size).addOutputFile(file);

    /* Set defaults for certain files */
    if (file.equals("stdout.log") || file.equals("stderr.log")) {
      setTextFile(size, file, true);
      setFilterScratch(size, file, true);
    }
  }

  /** Set the expected digest for an output file */
  void setDigest(String size, String file, String digest) {
    getSize(size).getOutputFile(file).digest = digest;
  }

  /** Set the expected line count for an output file */
  void setLines(String size, String file, int lines) {
    getSize(size).getOutputFile(file).lines = lines;
  }

  /** Set the expected byte count for an output file */
  void setBytes(String size, String file, long bytes) {
    getSize(size).getOutputFile(file).bytes = bytes;
  }

  /** Set whether we keep this file around after the benchmark run */
  void setKeep(String size, String file) {
    getSize(size).getOutputFile(file).keep = true;
  }

  /** Set whether we check for existence of this file */
  void setExists(String size, String file) {
    getSize(size).getOutputFile(file).existence = true;
  }

  /**
   * Is this a text file (affects how it is read)
   * 
   * @param size benchmark size
   * @param file output file
   * @param isText Is this a text file ?
   */
  public void setTextFile(String size, String file, boolean isText) {
    Size s = getSize(size);
    s.getOutputFile(file).text = isText;
  }

  /**
   * Do we filter this file replacing occurrences of the scratch directory name
   * before applying the digest function to it ?
   * 
   * @param size
   * @param file
   * @param doFilter
   */
  public void setFilterScratch(String size, String file, boolean doFilter) {
    Size s = getSize(size);
    s.getOutputFile(file).filter = doFilter;
  }

  /***********************************************************************************
   * 
   * Getter methods
   */

  /**
   * Benchmark arguments for a given run size. The return value is a clone so
   * callers are free to modify it.
   */
  public String[] getArgs(String size) {
    return (String[]) getSize(size).args.clone();
  }

  /**
   * Get the collection of sizes this benchmark accepts
   * 
   * @return A collection of strings
   */
  public Collection<String> getSizes() {
    return Collections.unmodifiableSet(sizes.keySet());
  }

  /**
   * Get the thread model for this benchmark. Apply the default here, because we
   * use 'null' to prevent double-setting in the config file.
   */
  public ThreadModel getThreadModel() {
    if (threadModel == null) {
      return ThreadModel.FIXED;
    } else {
      return threadModel;
    }
  }

  /**
   * Get the thread limit for this size of this benchmark.
   * 
   * @param size
   * @return the thread limit
   */
  public int getThreadLimit(String size) {
    return getSize(size).getThreadLimit();
  }

  /**
   * Get the threading factor for this size of this benchmark.
   * 
   * @param size
   * @return
   */
  public int getThreadFactor(String size) {
    return getSize(size).getThreadCount();
  }

  /**
   * Get the set of output files for a benchmark size
   * 
   * @param size
   * @return Set\<String\> of file names
   */
  public Set<String> getOutputs(String size) {
    return Collections.unmodifiableSet(getSize(size).outputFiles.keySet());
  }

  /**
   * Get the expected digest for a given size/file pair
   * 
   * @param size benchmark size
   * @param file output file
   */
  public String getDigest(String size, String file) {
    return getSize(size).getOutputFile(file).digest;
  }

  /**
   * Does the given size/file pair have an expected file digest ?
   * 
   * @param size benchmark size
   * @param file output file
   */
  public boolean hasDigest(String size, String file) {
    return getSize(size).getOutputFile(file).hasDigest();
  }

  /**
   * Is this a text file (affects how it is read)
   * 
   * @param size benchmark size
   * @param file output file
   * @return Is this a text file ?
   */
  public boolean isTextFile(String size, String file) {
    Size s = getSize(size);
    return s.getOutputFile(file).text;
  }

  /**
   * Should we filter scratch directories for this output file ?
   * 
   * @param size
   * @param file
   * @return
   */
  public boolean filterScratch(String size, String file) {
    return getSize(size).getOutputFile(file).filter;
  }

  /**
   * Does this output file have a byte length validation ?
   * 
   * @param size
   * @param file
   * @return
   */
  public boolean hasBytes(String size, String file) {
    return getSize(size).getOutputFile(file).hasBytes();
  }

  /**
   * What is the byte-length requirement for this file ?
   * 
   * @param size
   * @param file
   * @return
   */
  public long getBytes(String size, String file) {
    return getSize(size).getOutputFile(file).bytes;
  }

  public boolean hasLines(String size, String file) {
    Size s = getSize(size);
    return s.getOutputFile(file).hasLines();
  }

  public int getLines(String size, String file) {
    Size s = getSize(size);
    return s.getOutputFile(file).lines;
  }

  public boolean isKept(String size, String file) {
    Size s = getSize(size);
    return s.getOutputFile(file).keep;
  }

  /**
   * Should we check for the existence of this file ?
   * 
   * @param size
   * @param file
   * @return
   */
  public boolean checkExists(String size, String file) {
    Size s = getSize(size);
    return s.getOutputFile(file).existence;
  }

  private String pad(String in, int length) {
    while (in.length() < length)
      in += " ";
    return in;
  }

  /*
   * Manage the description fields
   */
  public void describe(PrintStream str, String size) {
    describe(str, size, false);
  }

  private void describe(PrintStream str, String size, boolean decorated, String desc, String trail) {
    String log = "";
    if (decorated)
      log = "  ";
    TPCCLog.v(Config.class.getName(), log + pad(desc, 10) + this.desc.get(desc) + (decorated ? trail : ""));
  }

  public void describe(PrintStream str, String size, boolean decorated) {
    if (decorated)
      TPCCLog.v(Config.class.getName(), "description");
    describe(str, size, decorated, "short", ",");
    describe(str, size, decorated, "long", ",");
    describe(str, size, decorated, "author", ",");
    describe(str, size, decorated, "license", ",");
    describe(str, size, decorated, "copyright", ",");
    describe(str, size, decorated, "url", ",");

    String sizeDesc = (size != null && getSize(size) != null) ? getSize(size).getDesc() : null;

    if (sizeDesc == null)
      describe(str, size, decorated, "version", ";");
    else {
      describe(str, size, decorated, "version", ",");
      TPCCLog.v(Config.class.getName(), pad("size", 10) + sizeDesc + (decorated ? ";" : ""));
    }
  }

  public String getDesc(String item) {
    return (String) desc.get(item);
  }

  public void print(PrintStream str) {
    StringBuffer sb = new StringBuffer();
    sb.append("benchmark " + name);
    if (className != null)
      sb.append(" class " + className);
    TPCCLog.v(Config.class.getName(), sb.append(";"));

    if (threadModel == null) {

      TPCCLog.v(Config.class.getName(), "  Threading model: unspecified");
    } else {
      TPCCLog.v(Config.class.getName(), "  Threading model: " + threadModel.describe());
    }

    sb.setLength(0);
    for (String size : getSizes()) {
      String[] args = getArgs(size);
      sb.append("size " + size + " args \"");
      for (int j = 0; j < args.length; j++) {
        if (j != 0)
          sb.append(" ");
        sb.append(args[j]);
      }
      TPCCLog.v(Config.class.getName(), sb.append("\""));

      sb.setLength(0);
      sb.append("  threads ");
      if (threadModel == null) {
        TPCCLog.v(Config.class.getName(), sb.append("<specified in benchmark arguments>"));
      } else {
        TPCCLog.v(Config.class.getName(), sb.append(getThreadFactor(size)));
      }

      sb.append("  outputs");
      for (Iterator<String> v = getOutputs(size).iterator(); v.hasNext();) {
        TPCCLog.v(Config.class.getName(), sb.toString());
        sb.setLength(0);
        String file = (String) v.next();
        OutputFile f = getSize(size).getOutputFile(file);
        sb.append("    \"" + file + "\"");
        if (f.hasDigest())
          sb.append(" digest 0x" + f.digest);
        if (f.keep)
          sb.append(" keep");
        if (v.hasNext())
          sb.append(",");
      }
      if (sb.length() > 0) {
        TPCCLog.v(Config.class.getName(),sb.append(";"));
      }
    }

    describe(str, null, true);
  }

  public void printThreadModel(PrintStream str, String size, boolean verbose) {
    if (getThreadModel() == ThreadModel.PER_CPU) {
      TPCCLog.v(Config.class.getName(), "Using scaled threading model. " + Runtime.getRuntime().availableProcessors() + " processors detected, " + getThreadCount(size)
              + " threads used to drive the workload, in a possible range of [1," + (getThreadLimit(size) == 0 ? "unlimited" : "" + getThreadLimit(size)) + "]");
    } else if (verbose) {
      if (getThreadModel() == ThreadModel.FIXED) {
        TPCCLog.v(Config.class.getName(), "Using a fixed threading model. " + getThreadCount(size) + " threads used to drive the workload.");
      } else if (getThreadModel() == ThreadModel.SINGLE) {
        TPCCLog.v(Config.class.getName(), "Using a single thread to drive the workload.");
      }
    }
  }

  /*************************************************************************************
   * 
   * Utility methods
   * 
   */
  /**
   * Determine the multi-threading level of this benchmark size. TODO allow the
   * user to override on the command-line
   */
  public int getThreadCount(String size) {
    switch (getThreadModel()) {
    case SINGLE:
      return 1;
    case FIXED:
      return getThreadFactor(size);
    case PER_CPU: {
      return threadCountOverride != 0 ? threadCountOverride : getThreadFactor(size) * Runtime.getRuntime().availableProcessors();
    }
    default:
      throw new RuntimeException("Unknown thread model");
    }
  }

  /**
   * Retrieve the benchmark arguments for the given size, applying preprocessing
   * as appropriate. The preprocessing that is currently done is:
   * <ul>
   * <li>${SCRATCH} - replaced with the absolute path name of the scratch
   * directory
   * <li>${THREADS} - replaced with the specified thread count for the benchmark
   * size
   * </ul>
   */
  public String[] preprocessArgs(String size, File scratch) {
    String[] raw = getArgs(size);
    String[] cooked = new String[raw.length];
    for (int i = 0; i < raw.length; i++) {
      String tmp = raw[i];
      // Jing Pu
      if (null != scratch) {
        tmp = tmp.replace("${SCRATCH}", scratch.getAbsolutePath());
        tmp = tmp.replace("${THREADS}", Integer.toString(getThreadCount(size)));
      }
      cooked[i] = tmp;
    }
    return cooked;
  }

  /**
   * Extract the named size from the available sizes in this benchmark, handling
   * pesky epistemological issues.
   * 
   * @param size
   * @return
   */
  private Size getSize(String size) {
    Size s = (Size) sizes.get(size);
    if (s == null) {
      TPCCLog.e(Config.class.getName(), "No such size: \"" + size + "\" for benchmark " + name);
      System.exit(-1);
    }
    return s;
  }
}