/* Title: Pure/Thy/sessions.scala
Author: Makarius
Isabelle session information.
*/
package isabelle
import java.nio.ByteBuffer
import java.nio.channels.FileChannel
import java.nio.file.StandardOpenOption
import scala.collection.SortedSet
import scala.collection.mutable
object Sessions
{
/* Pure */
def pure_name(name: String): Boolean = name == Thy_Header.PURE
def pure_files(resources: Resources, syntax: Outer_Syntax, dir: Path): List[Path] =
{
val roots = Thy_Header.ml_roots.map(_._1)
val loaded_files =
roots.flatMap(root => resources.loaded_files(syntax, File.read(dir + Path.explode(root))))
(roots ::: loaded_files).map(file => dir + Path.explode(file))
}
/* info */
sealed case class Info(
chapter: String,
select: Boolean,
pos: Position.T,
groups: List[String],
dir: Path,
parent: Option[String],
description: String,
options: Options,
theories: List[(Boolean, Options, List[Path])],
files: List[Path],
document_files: List[(Path, Path)],
meta_digest: SHA1.Digest)
{
def timeout: Time = Time.seconds(options.real("timeout") * options.real("timeout_scale"))
}
/* session tree */
object Tree
{
def apply(infos: Seq[(String, Info)]): Tree =
{
val graph1 =
(Graph.string[Info] /: infos) {
case (graph, (name, info)) =>
if (graph.defined(name))
error("Duplicate session " + quote(name) + Position.here(info.pos) +
Position.here(graph.get_node(name).pos))
else graph.new_node(name, info)
}
val graph2 =
(graph1 /: graph1.iterator) {
case (graph, (name, (info, _))) =>
info.parent match {
case None => graph
case Some(parent) =>
if (!graph.defined(parent))
error("Bad parent session " + quote(parent) + " for " +
quote(name) + Position.here(info.pos))
try { graph.add_edge_acyclic(parent, name) }
catch {
case exn: Graph.Cycles[_] =>
error(cat_lines(exn.cycles.map(cycle =>
"Cyclic session dependency of " +
cycle.map(c => quote(c.toString)).mkString(" via "))) +
Position.here(info.pos))
}
}
}
new Tree(graph2)
}
}
final class Tree private(val graph: Graph[String, Info])
extends PartialFunction[String, Info]
{
def apply(name: String): Info = graph.get_node(name)
def isDefinedAt(name: String): Boolean = graph.defined(name)
def selection(
requirements: Boolean = false,
all_sessions: Boolean = false,
exclude_session_groups: List[String] = Nil,
exclude_sessions: List[String] = Nil,
session_groups: List[String] = Nil,
sessions: List[String] = Nil): (List[String], Tree) =
{
val bad_sessions =
SortedSet((exclude_sessions ::: sessions).filterNot(isDefinedAt(_)): _*).toList
if (bad_sessions.nonEmpty) error("Undefined session(s): " + commas_quote(bad_sessions))
val excluded =
{
val exclude_group = exclude_session_groups.toSet
val exclude_group_sessions =
(for {
(name, (info, _)) <- graph.iterator
if apply(name).groups.exists(exclude_group)
} yield name).toList
graph.all_succs(exclude_group_sessions ::: exclude_sessions).toSet
}
val pre_selected =
{
if (all_sessions) graph.keys
else {
val select_group = session_groups.toSet
val select = sessions.toSet
(for {
(name, (info, _)) <- graph.iterator
if info.select || select(name) || apply(name).groups.exists(select_group)
} yield name).toList
}
}.filterNot(excluded)
val selected =
if (requirements) (graph.all_preds(pre_selected).toSet -- pre_selected).toList
else pre_selected
val graph1 = graph.restrict(graph.all_preds(selected).toSet)
(selected, new Tree(graph1))
}
def ancestors(name: String): List[String] =
graph.all_preds(List(name)).tail.reverse
def topological_order: List[(String, Info)] =
graph.topological_order.map(name => (name, apply(name)))
override def toString: String = graph.keys_iterator.mkString("Sessions.Tree(", ", ", ")")
}
/* parser */
val ROOT = Path.explode("ROOT")
val ROOTS = Path.explode("ROOTS")
private val CHAPTER = "chapter"
private val SESSION = "session"
private val IN = "in"
private val DESCRIPTION = "description"
private val OPTIONS = "options"
private val GLOBAL_THEORIES = "global_theories"
private val THEORIES = "theories"
private val FILES = "files"
private val DOCUMENT_FILES = "document_files"
lazy val root_syntax =
Outer_Syntax.init() + "(" + ")" + "+" + "," + "=" + "[" + "]" + IN +
(CHAPTER, Keyword.THY_DECL) +
(SESSION, Keyword.THY_DECL) +
(DESCRIPTION, Keyword.QUASI_COMMAND) +
(OPTIONS, Keyword.QUASI_COMMAND) +
(GLOBAL_THEORIES, Keyword.QUASI_COMMAND) +
(THEORIES, Keyword.QUASI_COMMAND) +
(FILES, Keyword.QUASI_COMMAND) +
(DOCUMENT_FILES, Keyword.QUASI_COMMAND)
private object Parser extends Parse.Parser with Options.Parser
{
private abstract class Entry
private sealed case class Chapter(name: String) extends Entry
private sealed case class Session_Entry(
pos: Position.T,
name: String,
groups: List[String],
path: String,
parent: Option[String],
description: String,
options: List[Options.Spec],
theories: List[(Boolean, List[Options.Spec], List[String])],
files: List[String],
document_files: List[(String, String)]) extends Entry
private val chapter: Parser[Chapter] =
{
val chapter_name = atom("chapter name", _.is_name)
command(CHAPTER) ~! chapter_name ^^ { case _ ~ a => Chapter(a) }
}
private val session_entry: Parser[Session_Entry] =
{
val session_name = atom("session name", _.is_name)
val option =
option_name ~ opt($$$("=") ~! option_value ^^
{ case _ ~ x => x }) ^^ { case x ~ y => (x, y) }
val options = $$$("[") ~> rep1sep(option, $$$(",")) <~ $$$("]")
val theories =
($$$(GLOBAL_THEORIES) | $$$(THEORIES)) ~!
((options | success(Nil)) ~ rep(theory_name)) ^^
{ case x ~ (y ~ z) => (x == GLOBAL_THEORIES, y, z) }
val document_files =
$$$(DOCUMENT_FILES) ~!
(($$$("(") ~! ($$$(IN) ~! (path ~ $$$(")"))) ^^
{ case _ ~ (_ ~ (x ~ _)) => x } | success("document")) ~
rep1(path)) ^^ { case _ ~ (x ~ y) => y.map((x, _)) }
command(SESSION) ~!
(position(session_name) ~
(($$$("(") ~! (rep1(name) <~ $$$(")")) ^^ { case _ ~ x => x }) | success(Nil)) ~
(($$$(IN) ~! path ^^ { case _ ~ x => x }) | success(".")) ~
($$$("=") ~!
(opt(session_name ~! $$$("+") ^^ { case x ~ _ => x }) ~
(($$$(DESCRIPTION) ~! text ^^ { case _ ~ x => x }) | success("")) ~
(($$$(OPTIONS) ~! options ^^ { case _ ~ x => x }) | success(Nil)) ~
rep1(theories) ~
(($$$(FILES) ~! rep1(path) ^^ { case _ ~ x => x }) | success(Nil)) ~
(rep(document_files) ^^ (x => x.flatten))))) ^^
{ case _ ~ ((a, pos) ~ b ~ c ~ (_ ~ (d ~ e ~ f ~ g ~ h ~ i))) =>
Session_Entry(pos, a, b, c, d, e, f, g, h, i) }
}
def parse(options: Options, select: Boolean, dir: Path): List[(String, Info)] =
{
def make_info(entry_chapter: String, entry: Session_Entry): (String, Info) =
{
try {
val name = entry.name
if (name == "") error("Bad session name")
if (pure_name(name) && entry.parent.isDefined) error("Illegal parent session")
if (!pure_name(name) && !entry.parent.isDefined) error("Missing parent session")
val session_options = options ++ entry.options
val theories =
entry.theories.map({ case (global, opts, thys) =>
(global, session_options ++ opts, thys.map(Path.explode(_))) })
val files = entry.files.map(Path.explode(_))
val document_files =
entry.document_files.map({ case (s1, s2) => (Path.explode(s1), Path.explode(s2)) })
val meta_digest =
SHA1.digest((entry_chapter, name, entry.parent, entry.options,
entry.theories, entry.files, entry.document_files).toString)
val info =
Info(entry_chapter, select, entry.pos, entry.groups, dir + Path.explode(entry.path),
entry.parent, entry.description, session_options, theories, files,
document_files, meta_digest)
(name, info)
}
catch {
case ERROR(msg) =>
error(msg + "\nThe error(s) above occurred in session entry " +
quote(entry.name) + Position.here(entry.pos))
}
}
val root = dir + ROOT
if (root.is_file) {
val toks = Token.explode(root_syntax.keywords, File.read(root))
val start = Token.Pos.file(root.implode)
parse_all(rep(chapter | session_entry), Token.reader(toks, start)) match {
case Success(result, _) =>
var entry_chapter = "Unsorted"
val infos = new mutable.ListBuffer[(String, Info)]
result.foreach {
case Chapter(name) => entry_chapter = name
case entry: Session_Entry => infos += make_info(entry_chapter, entry)
}
infos.toList
case bad => error(bad.toString)
}
}
else Nil
}
}
/* load sessions from certain directories */
private def is_session_dir(dir: Path): Boolean =
(dir + ROOT).is_file || (dir + ROOTS).is_file
private def check_session_dir(dir: Path): Path =
if (is_session_dir(dir)) dir
else error("Bad session root directory: " + dir.toString)
def load(options: Options, dirs: List[Path] = Nil, select_dirs: List[Path] = Nil): Tree =
{
def load_dir(select: Boolean, dir: Path): List[(String, Info)] =
load_root(select, dir) ::: load_roots(select, dir)
def load_root(select: Boolean, dir: Path): List[(String, Info)] =
Parser.parse(options, select, dir)
def load_roots(select: Boolean, dir: Path): List[(String, Info)] =
{
val roots = dir + ROOTS
if (roots.is_file) {
for {
line <- split_lines(File.read(roots))
if !(line == "" || line.startsWith("#"))
dir1 =
try { check_session_dir(dir + Path.explode(line)) }
catch {
case ERROR(msg) =>
error(msg + "\nThe error(s) above occurred in session catalog " + roots.toString)
}
info <- load_dir(select, dir1)
} yield info
}
else Nil
}
val default_dirs = Isabelle_System.components().filter(is_session_dir(_))
dirs.foreach(check_session_dir(_))
select_dirs.foreach(check_session_dir(_))
Tree(
for {
(select, dir) <- (default_dirs ::: dirs).map((false, _)) ::: select_dirs.map((true, _))
info <- load_dir(select, dir)
} yield info)
}
/** heap file with SHA1 digest **/
private val sha1_prefix = "SHA1:"
def read_heap_digest(heap: Path): Option[String] =
{
if (heap.is_file) {
val file = FileChannel.open(heap.file.toPath, StandardOpenOption.READ)
try {
val len = file.size
val n = sha1_prefix.length + SHA1.digest_length
if (len >= n) {
file.position(len - n)
val buf = ByteBuffer.allocate(n)
var i = 0
var m = 0
do {
m = file.read(buf)
if (m != -1) i += m
}
while (m != -1 && n > i)
if (i == n) {
val prefix = new String(buf.array(), 0, sha1_prefix.length, UTF8.charset)
val s = new String(buf.array(), sha1_prefix.length, SHA1.digest_length, UTF8.charset)
if (prefix == sha1_prefix) Some(s) else None
}
else None
}
else None
}
finally { file.close }
}
else None
}
def write_heap_digest(heap: Path): String =
read_heap_digest(heap) match {
case None =>
val s = SHA1.digest(heap).rep
File.append(heap, sha1_prefix + s)
s
case Some(s) => s
}
/** persistent store **/
def log(name: String): Path = Path.basic("log") + Path.basic(name)
def log_gz(name: String): Path = log(name).ext("gz")
def store(system_mode: Boolean = false): Store = new Store(system_mode)
class Store private [Sessions](system_mode: Boolean)
{
/* output */
val browser_info: Path =
if (system_mode) Path.explode("~~/browser_info")
else Path.explode("$ISABELLE_BROWSER_INFO")
val output_dir: Path =
if (system_mode) Path.explode("~~/heaps/$ML_IDENTIFIER")
else Path.explode("$ISABELLE_OUTPUT")
def prepare_output() { Isabelle_System.mkdirs(output_dir + Path.basic("log")) }
/* input */
private val input_dirs =
if (system_mode) List(output_dir)
else {
val ml_ident = Path.explode("$ML_IDENTIFIER").expand
output_dir :: Path.split(Isabelle_System.getenv_strict("ISABELLE_PATH")).map(_ + ml_ident)
}
def find(name: String): Option[(Path, Option[String])] =
input_dirs.find(dir => (dir + log_gz(name)).is_file).map(dir =>
(dir + log_gz(name), read_heap_digest(dir + Path.basic(name))))
def find_log(name: String): Option[Path] =
input_dirs.map(_ + log(name)).find(_.is_file)
def find_log_gz(name: String): Option[Path] =
input_dirs.map(_ + log_gz(name)).find(_.is_file)
def find_heap(name: String): Option[Path] =
input_dirs.map(_ + Path.basic(name)).find(_.is_file)
def heap(name: String): Path =
find_heap(name) getOrElse
error("Unknown logic " + quote(name) + " -- no heap file found in:\n" +
cat_lines(input_dirs.map(dir => " " + dir.expand.implode)))
}
}