use crate::{ dust_error::AnnotatedError, parse, Chunk, ChunkError, DustError, Identifier, Instruction, Local, Operation, Span, Value, ValueError, }; pub fn run(source: &str) -> Result, DustError> { let chunk = parse(source)?; let mut vm = Vm::new(chunk); vm.run() .map_err(|error| DustError::Runtime { error, source }) } #[derive(Debug, Eq, PartialEq)] pub struct Vm { chunk: Chunk, ip: usize, register_stack: Vec>, } impl Vm { const STACK_LIMIT: usize = u16::MAX as usize; pub fn new(chunk: Chunk) -> Self { Self { chunk, ip: 0, register_stack: Vec::new(), } } pub fn take_chunk(self) -> Chunk { self.chunk } pub fn run(&mut self) -> Result, VmError> { // DRY helper closure to take a constant or clone a register let take_constants_or_clone = |vm: &mut Vm, instruction: Instruction, position: Span| -> Result<(Value, Value), VmError> { let left = if instruction.first_argument_is_constant() { vm.chunk .take_constant(instruction.first_argument(), position)? } else { vm.clone(instruction.first_argument(), position)? }; let right = if instruction.second_argument_is_constant() { vm.chunk .take_constant(instruction.second_argument(), position)? } else { vm.clone(instruction.second_argument(), position)? }; Ok((left, right)) }; while let Ok((instruction, position)) = self.read(Span(0, 0)).copied() { log::trace!("Running instruction {instruction} at {position}"); match instruction.operation() { Operation::Move => { let from = instruction.first_argument(); let to = instruction.destination(); let value = self.clone(from, position)?; self.insert(value, to, position)?; } Operation::Close => { let from = instruction.first_argument(); let to = instruction.second_argument(); for register_index in from..to { self.register_stack[register_index as usize] = None; } } Operation::LoadBoolean => { let to_register = instruction.destination(); let boolean = instruction.first_argument() != 0; let skip = instruction.second_argument() != 0; let value = Value::boolean(boolean); self.insert(value, to_register, position)?; if skip { self.ip += 1; } } Operation::LoadConstant => { let to_register = instruction.destination(); let from_constant = instruction.first_argument(); let value = self.chunk.take_constant(from_constant, position)?; self.insert(value, to_register, position)?; } Operation::LoadList => { let to_register = instruction.destination(); let length = instruction.first_argument(); let first_register = to_register - length - 1; let last_register = to_register - 1; let mut list = Vec::with_capacity(length as usize); for register_index in first_register..=last_register { let value = match self.clone(register_index, position) { Ok(value) => value, Err(VmError::EmptyRegister { .. }) => continue, Err(error) => return Err(error), }; list.push(value); } self.insert(Value::list(list), to_register, position)?; } Operation::DefineLocal => { let from_register = instruction.destination(); let to_local = instruction.first_argument(); self.chunk.define_local(to_local, from_register, position)?; } Operation::GetLocal => { let register_index = instruction.destination(); let local_index = instruction.first_argument(); let local = self.chunk.get_local(local_index, position)?.clone(); let value = self.clone_as_variable(local, position)?; self.insert(value, register_index, position)?; } Operation::SetLocal => { let register_index = instruction.destination(); let local_index = instruction.first_argument(); let local = self.chunk.get_local(local_index, position)?.clone(); let value = self.clone_as_variable(local, position)?; let new_value = if instruction.first_argument_is_constant() { self.chunk.take_constant(register_index, position)? } else { self.clone(register_index, position)? }; value .mutate(new_value) .map_err(|error| VmError::Value { error, position })?; self.insert(value, register_index, position)?; } Operation::Add => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let sum = left .add(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(sum, instruction.destination(), position)?; } Operation::Subtract => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let difference = left .subtract(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(difference, instruction.destination(), position)?; } Operation::Multiply => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let product = left .multiply(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(product, instruction.destination(), position)?; } Operation::Divide => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let quotient = left .divide(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(quotient, instruction.destination(), position)?; } Operation::Modulo => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let remainder = left .modulo(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(remainder, instruction.destination(), position)?; } Operation::And => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let and = left .and(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(and, instruction.destination(), position)?; } Operation::Or => { let (left, right) = take_constants_or_clone(self, instruction, position)?; let or = left .or(&right) .map_err(|error| VmError::Value { error, position })?; self.insert(or, instruction.destination(), position)?; } Operation::Negate => { let value = if instruction.first_argument_is_constant() { self.chunk .take_constant(instruction.first_argument(), position)? } else { self.clone(instruction.first_argument(), position)? }; let negated = value .negate() .map_err(|error| VmError::Value { error, position })?; self.insert(negated, instruction.destination(), position)?; } Operation::Not => { let value = if instruction.first_argument_is_constant() { self.chunk .take_constant(instruction.first_argument(), position)? } else { self.clone(instruction.first_argument(), position)? }; let not = value .not() .map_err(|error| VmError::Value { error, position })?; self.insert(not, instruction.destination(), position)?; } Operation::Return => { let value = self.pop(position)?; return Ok(Some(value)); } } } Ok(None) } fn insert(&mut self, value: Value, index: u8, position: Span) -> Result<(), VmError> { if self.register_stack.len() == Self::STACK_LIMIT { Err(VmError::StackOverflow { position }) } else { let index = index as usize; while index >= self.register_stack.len() { self.register_stack.push(None); } self.register_stack[index] = Some(value); Ok(()) } } fn clone(&mut self, index: u8, position: Span) -> Result { let index = index as usize; if let Some(register) = self.register_stack.get_mut(index) { let cloneable = if let Some(value) = register.take() { if value.is_raw() { value.into_reference() } else { value } } else { return Err(VmError::EmptyRegister { index, position }); }; *register = Some(cloneable.clone()); Ok(cloneable) } else { Err(VmError::RegisterIndexOutOfBounds { position }) } } fn clone_mutable(&mut self, index: u8, position: Span) -> Result { let index = index as usize; if let Some(register) = self.register_stack.get_mut(index) { let cloneable = if let Some(value) = register.take() { value.into_mutable() } else { return Err(VmError::EmptyRegister { index, position }); }; *register = Some(cloneable.clone()); Ok(cloneable) } else { Err(VmError::RegisterIndexOutOfBounds { position }) } } fn clone_as_variable(&mut self, local: Local, position: Span) -> Result { let index = if let Some(index) = local.register_index { index } else { return Err(VmError::UndefinedVariable { identifier: local.identifier, position, }); }; let clone_result = if local.mutable { self.clone_mutable(index, position) } else { self.clone(index, position) }; match clone_result { Err(VmError::EmptyRegister { .. }) => Err(VmError::UndefinedVariable { identifier: local.identifier, position, }), _ => clone_result, } } fn pop(&mut self, position: Span) -> Result { if let Some(register) = self.register_stack.pop() { let value = register.ok_or(VmError::EmptyRegister { index: self.register_stack.len().saturating_sub(1), position, })?; Ok(value) } else { Err(VmError::StackUnderflow { position }) } } fn read(&mut self, position: Span) -> Result<&(Instruction, Span), VmError> { let current = self.chunk.get_instruction(self.ip, position)?; self.ip += 1; Ok(current) } } #[derive(Debug, Clone, PartialEq)] pub enum VmError { EmptyRegister { index: usize, position: Span, }, RegisterIndexOutOfBounds { position: Span, }, InvalidInstruction { instruction: Instruction, position: Span, }, StackOverflow { position: Span, }, StackUnderflow { position: Span, }, UndefinedVariable { identifier: Identifier, position: Span, }, // Wrappers for foreign errors Chunk(ChunkError), Value { error: ValueError, position: Span, }, } impl From for VmError { fn from(error: ChunkError) -> Self { Self::Chunk(error) } } impl AnnotatedError for VmError { fn title() -> &'static str { "Runtime Error" } fn description(&self) -> &'static str { match self { Self::EmptyRegister { .. } => "Empty register", Self::RegisterIndexOutOfBounds { .. } => "Register index out of bounds", Self::InvalidInstruction { .. } => "Invalid instruction", Self::StackOverflow { .. } => "Stack overflow", Self::StackUnderflow { .. } => "Stack underflow", Self::UndefinedVariable { .. } => "Undefined variable", Self::Value { .. } => "Value error", Self::Chunk(error) => error.description(), } } fn details(&self) -> Option { match self { Self::EmptyRegister { index, .. } => Some(format!("Register {index} is empty")), Self::UndefinedVariable { identifier, .. } => { Some(format!("{identifier} is not in scope")) } Self::Chunk(error) => error.details(), Self::Value { error, .. } => Some(error.to_string()), _ => None, } } fn position(&self) -> Span { match self { Self::EmptyRegister { position, .. } => *position, Self::RegisterIndexOutOfBounds { position } => *position, Self::InvalidInstruction { position, .. } => *position, Self::StackUnderflow { position } => *position, Self::StackOverflow { position } => *position, Self::UndefinedVariable { position, .. } => *position, Self::Chunk(error) => error.position(), Self::Value { position, .. } => *position, } } }