Issue #17 and concurrent compiling.

src/main/asl.go

@@ -41,6 +41,7 @@ func usage() {
 	fmt.Println("<output directory> output directory, directory structure will be created corresponding to input directory")
 }
 
+// Parses compiler flags.
 func flags(flag string) bool {
 	flag = strings.ToLower(flag)
 
@@ -63,6 +64,7 @@ func flags(flag string) bool {
 	return false
 }
 
+// Creates a list of all ASL files to compile.
 func readAslFiles(path string) {
 	dir, err := ioutil.ReadDir(path)
 
@@ -90,28 +92,57 @@ func readAslFiles(path string) {
 	}
 }
 
-func compile(path string) {
+// Recovers and prints thrown error.
-	for i := 0; i < len(aslFiles); i++ {
+func recoverCompileError(file string, waiter chan bool) {
-		out := filepath.FromSlash(path + PathSeparator + aslFiles[i].out + PathSeparator + aslFiles[i].newname + sqfextension)
+	if r := recover(); r != nil {
-		fmt.Println(aslFiles[i].in + " -> " + out)
+		fmt.Println("Compile error in file "+file+":", r)
-		code, err := ioutil.ReadFile(aslFiles[i].in)
-
-		if err != nil {
-			fmt.Println("Error reading file: " + aslFiles[i].in)
-			continue
 	}
 
+	waiter <- true // the show must go on
+}
+
+// Compiles a single ASL file.
+func compileFile(path string, file ASLFile, waiter chan bool) {
+	defer recoverCompileError(file.in, waiter)
+
+	// read file
+	out := filepath.FromSlash(path + PathSeparator + file.out + PathSeparator + file.newname + sqfextension)
+	fmt.Println(file.in + " -> " + out)
+	code, err := ioutil.ReadFile(file.in)
+
+	if err != nil {
+		fmt.Println("Error reading file: " + file.in)
+		return
+	}
+
+	// compile
 	token := tokenizer.Tokenize(code, false)
 	compiler := parser.Compiler{}
 	sqf := compiler.Parse(token, pretty)
 
-		os.MkdirAll(filepath.FromSlash(path+PathSeparator+aslFiles[i].out), 0777)
+	os.MkdirAll(filepath.FromSlash(path+PathSeparator+file.out), 0777)
 	err = ioutil.WriteFile(out, []byte(sqf), 0666)
 
 	if err != nil {
-			fmt.Println("Error writing file: " + aslFiles[i].out)
+		fmt.Println("Error writing file: " + file.out)
 		fmt.Println(err)
 	}
+
+	waiter <- true // done
+}
+
+// Compiles ASL files concurrently.
+func compile(path string) {
+	waiter := make(chan bool, len(aslFiles))
+
+	// fire compile
+	for i := 0; i < len(aslFiles); i++ {
+		go compileFile(path, aslFiles[i], waiter)
+	}
+
+	// wait until all files are compiled
+	for i := 0; i < len(aslFiles); i++ {
+		<-waiter
 	}
 }
 

src/parser/parser_helper.go

@@ -1,6 +1,7 @@
 package parser
 
 import (
+	"errors"
 	"strconv"
 	"tokenizer"
 )
@@ -38,7 +39,7 @@ func (c *Compiler) accept(token string) bool {
 // Throws if current token does not match expected one.
 func (c *Compiler) expect(token string) {
 	if !c.tokenEqual(token, c.get()) {
-		panic("Parse error, expected '" + token + "' but was '" + c.get().Token + "' in line " + strconv.Itoa(c.get().Line) + " at " + strconv.Itoa(c.get().Column))
+		panic(errors.New("Parse error, expected '" + token + "' but was '" + c.get().Token + "' in line " + strconv.Itoa(c.get().Line) + " at " + strconv.Itoa(c.get().Column)))
 	}
 
 	c.next()
@@ -62,7 +63,7 @@ func (c *Compiler) next() {
 // Returns current token or throws, if no more tokens are available.
 func (c *Compiler) get() tokenizer.Token {
 	if c.tokenIndex >= len(c.tokens) {
-		panic("No more tokens")
+		panic(errors.New("No more tokens"))
 	}
 
 	return c.tokens[c.tokenIndex]