ckb-vm-debug-utils 1.1.1

#[macro_use]
extern crate log;

use bytes::Bytes;
use ckb_vm::machine::VERSION2;
use ckb_vm::{
    DefaultCoreMachine, DefaultMachineBuilder, ISA_A, ISA_B, ISA_IMC, ISA_MOP, SparseMemory, SupportMachine,
    WXorXMemory,
};
#[cfg(feature = "stdio")]
use ckb_vm_debug_utils::Stdio;
use ckb_vm_debug_utils::{GdbStubHandler, GdbStubHandlerEventLoop};
use gdbstub::conn::ConnectionExt;
use gdbstub::stub::{DisconnectReason, GdbStub};
use gdbstub_arch::riscv::Riscv64;
use std::env;
use std::fs::File;
use std::io::Read;
use std::net::TcpListener;

fn main() {
    let _ = env_logger::init();
    let args: Vec<String> = env::args().skip(1).collect();

    let listener = TcpListener::bind(&args[0]).expect("listen");
    debug!("Listening on {}", args[0]);

    let mut file = File::open(&args[1]).expect("open program");
    let mut buffer = Vec::new();
    file.read_to_end(&mut buffer).unwrap();
    let program: Bytes = buffer.into();
    let program_args: Vec<Bytes> = args.into_iter().skip(1).map(|a| a.into()).collect();

    for res in listener.incoming() {
        debug!("Got connection");
        if let Ok(stream) = res {
            // TODO: vm version and isa should be configurable in the future.
            let machine_core = DefaultCoreMachine::<u64, WXorXMemory<SparseMemory<u64>>>::new(
                ISA_IMC | ISA_A | ISA_B | ISA_MOP,
                VERSION2,
                u64::max_value(),
            );
            let machine_builder = DefaultMachineBuilder::new(machine_core);
            #[cfg(feature = "stdio")]
            let mut machine = machine_builder.syscall(Box::new(Stdio::new(true))).build();
            #[cfg(not(feature = "stdio"))]
            let mut machine = machine_builder.build();
            machine.load_program(&program, program_args.iter().cloned().map(Ok)).expect("load program");
            machine.set_running(true);
            let mut h = GdbStubHandler::<_, Riscv64>::new(machine);
            let connection: Box<dyn ConnectionExt<Error = std::io::Error>> = Box::new(stream);
            let gdb = GdbStub::new(connection);
            match gdb.run_blocking::<GdbStubHandlerEventLoop<_, Riscv64>>(&mut h) {
                Ok(DisconnectReason::Disconnect) => {
                    debug!("GDB client disconnected, running to completion");
                    let _ = h.run_till_exited();
                }
                Ok(DisconnectReason::TargetExited(_)) => {
                    let _ = h.run_till_exited();
                }
                Ok(reason) => {
                    debug!("GDB session ended: {:?}", reason);
                }
                Err(e) => {
                    debug!("GDB stub error: {}", e);
                }
            }
        }
        debug!("Connection closed");
    }
}