|
|
|
#[macro_use]
|
|
|
|
extern crate log;
|
|
|
|
|
|
|
|
use std::collections::HashMap;
|
|
|
|
|
|
|
|
use std::time::Duration;
|
|
|
|
|
|
|
|
use clappconfig::{AppConfig, clap};
|
|
|
|
use clappconfig::clap::ArgMatches;
|
|
|
|
use serde::{Deserialize, Serialize};
|
|
|
|
|
|
|
|
use crsn::asm::data::literal::Addr;
|
|
|
|
use crsn::module::{OpTrait, CrsnUniq};
|
|
|
|
use crsn::runtime::run_thread::{RunThread, ThreadToken, ThreadParams};
|
|
|
|
use crsn_arith::ArithOps;
|
|
|
|
use crsn_screen::ScreenOps;
|
|
|
|
use crsn_stdio::StdioOps;
|
|
|
|
use crsn_buf::BufOps;
|
|
|
|
|
|
|
|
mod serde_duration_millis;
|
|
|
|
|
|
|
|
#[derive(Debug, Clone, Serialize, Deserialize)]
|
|
|
|
struct LogConfig {
|
|
|
|
level: String,
|
|
|
|
modules: HashMap<String, String>,
|
|
|
|
}
|
|
|
|
|
|
|
|
#[derive(Debug, Clone, Serialize, Deserialize)]
|
|
|
|
#[serde(default)]
|
|
|
|
struct Config {
|
|
|
|
log: LogConfig,
|
|
|
|
#[serde(skip)]
|
|
|
|
program_file: String,
|
|
|
|
#[serde(skip)]
|
|
|
|
assemble_only: bool,
|
|
|
|
#[serde(skip)]
|
|
|
|
assemble_debug: bool,
|
|
|
|
#[serde(with = "serde_duration_millis")]
|
|
|
|
cycle_time: Duration,
|
|
|
|
#[serde(with = "serde_duration_millis")]
|
|
|
|
switch_time: Duration,
|
|
|
|
}
|
|
|
|
|
|
|
|
impl Default for Config {
|
|
|
|
fn default() -> Self {
|
|
|
|
Self {
|
|
|
|
log: LogConfig {
|
|
|
|
level: "warn".to_string(),
|
|
|
|
modules: Default::default(),
|
|
|
|
},
|
|
|
|
program_file: "".to_string(),
|
|
|
|
assemble_only: false,
|
|
|
|
assemble_debug: false,
|
|
|
|
cycle_time: Duration::default(),
|
|
|
|
switch_time: Duration::from_millis(10),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
impl AppConfig for Config {
|
|
|
|
type Init = Self;
|
|
|
|
|
|
|
|
fn logging(&self) -> &str {
|
|
|
|
&self.log.level
|
|
|
|
}
|
|
|
|
|
|
|
|
fn logging_mod_levels(&self) -> Option<&HashMap<String, String>> {
|
|
|
|
Some(&self.log.modules)
|
|
|
|
}
|
|
|
|
|
|
|
|
fn pre_log_println(_message: String) {
|
|
|
|
// shut up
|
|
|
|
}
|
|
|
|
|
|
|
|
fn print_banner(_name: &str, _version: &str) {
|
|
|
|
// No banner
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Add args to later use in the `configure` method.
|
|
|
|
fn add_args<'a: 'b, 'b>(clap: clap::App<'a, 'b>) -> clap::App<'a, 'b> {
|
|
|
|
// Default impl
|
|
|
|
clap
|
|
|
|
.arg(
|
|
|
|
clap::Arg::with_name("input")
|
|
|
|
.value_name("FILE")
|
|
|
|
.help("Program to run")
|
|
|
|
.required_unless("default-config")
|
|
|
|
.takes_value(true),
|
|
|
|
)
|
|
|
|
.arg(
|
|
|
|
clap::Arg::with_name("asm-only")
|
|
|
|
.short("P")
|
|
|
|
.long("asm")
|
|
|
|
.help("Only assemble, do not run."),
|
|
|
|
)
|
|
|
|
.arg(
|
|
|
|
clap::Arg::with_name("asm-debug")
|
|
|
|
.short("D")
|
|
|
|
.long("asm-debug")
|
|
|
|
.help("Only assemble, do not run. Print the result in debug format."),
|
|
|
|
)
|
|
|
|
.arg(
|
|
|
|
clap::Arg::with_name("cycle")
|
|
|
|
.long("cycle")
|
|
|
|
.short("C")
|
|
|
|
.value_name("MICROS")
|
|
|
|
.help("Cycle time (us, append \"s\" or \"ms\" for coarser time)")
|
|
|
|
.takes_value(true),
|
|
|
|
)
|
|
|
|
.arg(
|
|
|
|
clap::Arg::with_name("sched")
|
|
|
|
.long("sched")
|
|
|
|
.short("S")
|
|
|
|
.value_name("MILLIS")
|
|
|
|
.help("Scheduler switch time (ms, append \"u\", \"s\" or \"ms\" for other unit)")
|
|
|
|
.takes_value(true),
|
|
|
|
)
|
|
|
|
}
|
|
|
|
|
|
|
|
fn configure(mut self, clap: &ArgMatches) -> anyhow::Result<Self> {
|
|
|
|
self.program_file = clap.value_of("input").unwrap().to_string();
|
|
|
|
self.assemble_debug = clap.is_present("asm-debug");
|
|
|
|
self.assemble_only = self.assemble_debug || clap.is_present("asm-only");
|
|
|
|
if let Some(t) = clap.value_of("cycle") {
|
|
|
|
let (t, mul) = if t.ends_with("us") {
|
|
|
|
(&t[..(t.len()-2)], 1)
|
|
|
|
} else if t.ends_with("ms") {
|
|
|
|
(&t[..(t.len()-2)], 1000)
|
|
|
|
} else if t.ends_with("m") {
|
|
|
|
(&t[..(t.len()-1)], 1000)
|
|
|
|
} else if t.ends_with("u") {
|
|
|
|
(&t[..(t.len()-1)], 1)
|
|
|
|
} else if t.ends_with("s") {
|
|
|
|
(&t[..(t.len()-1)], 1000_000)
|
|
|
|
} else {
|
|
|
|
(t, 1) // us default
|
|
|
|
};
|
|
|
|
|
|
|
|
self.cycle_time = Duration::from_micros(t.parse::<u64>().expect("parse -C value") * mul);
|
|
|
|
}
|
|
|
|
|
|
|
|
if let Some(t) = clap.value_of("sched") {
|
|
|
|
let (t, mul) = if t.ends_with("us") {
|
|
|
|
(&t[..(t.len()-2)], 1)
|
|
|
|
} else if t.ends_with("ms") {
|
|
|
|
(&t[..(t.len()-2)], 1000)
|
|
|
|
} else if t.ends_with("m") {
|
|
|
|
(&t[..(t.len()-1)], 1000)
|
|
|
|
} else if t.ends_with("u") {
|
|
|
|
(&t[..(t.len()-1)], 1)
|
|
|
|
} else if t.ends_with("s") {
|
|
|
|
(&t[..(t.len()-1)], 1000_000)
|
|
|
|
} else {
|
|
|
|
(t, 1000) // ms default
|
|
|
|
};
|
|
|
|
|
|
|
|
self.switch_time = Duration::from_micros(t.parse::<u64>().expect("parse -S value") * mul);
|
|
|
|
}
|
|
|
|
Ok(self)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
fn main() -> anyhow::Result<()> {
|
|
|
|
let config = Config::init("crsn", "crsn.json5", env!("CARGO_PKG_VERSION"))?;
|
|
|
|
|
|
|
|
debug!("Loading {}", config.program_file);
|
|
|
|
|
|
|
|
let uniq = CrsnUniq::new();
|
|
|
|
|
|
|
|
let parsed = crsn::asm::assemble(&config.program_file, &uniq, vec![
|
|
|
|
ArithOps::new(),
|
|
|
|
BufOps::new(),
|
|
|
|
ScreenOps::new(),
|
|
|
|
StdioOps::new(),
|
|
|
|
])?;
|
|
|
|
|
|
|
|
if config.assemble_only {
|
|
|
|
println!("--- {} ---", config.program_file);
|
|
|
|
for (n, op) in parsed.ops.iter().enumerate() {
|
|
|
|
if config.assemble_debug {
|
|
|
|
println!("{:04} : {:?}", n, op);
|
|
|
|
} else {
|
|
|
|
println!("{:04} : {}", n, op.to_sexp());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return Ok(());
|
|
|
|
} else {
|
|
|
|
trace!("--- Compiled program ---");
|
|
|
|
for (n, op) in parsed.ops.iter().enumerate() {
|
|
|
|
trace!("{:04} : {}", n, op.to_sexp());
|
|
|
|
}
|
|
|
|
trace!("------------------------");
|
|
|
|
}
|
|
|
|
|
|
|
|
debug!("Start runtime");
|
|
|
|
|
|
|
|
let args = &[];
|
|
|
|
let thread = RunThread::new(ThreadParams {
|
|
|
|
id: ThreadToken(0),
|
|
|
|
uniq,
|
|
|
|
program: parsed,
|
|
|
|
pc: Addr(0),
|
|
|
|
cycle_time: config.cycle_time,
|
|
|
|
scheduler_interval: config.switch_time,
|
|
|
|
args
|
|
|
|
});
|
|
|
|
|
|
|
|
// run without spawning, so it is on the main thread - required by some extensions
|
|
|
|
thread.run();
|
|
|
|
|
|
|
|
debug!("Runtime shut down.");
|
|
|
|
|
|
|
|
Ok(())
|
|
|
|
}
|