Struct GdbServer

pub struct GdbServer<R, W>
where
    R: BufRead,
    W: Write,
{
    pub reader: R,
    pub writer: W,
    /* private fields */
}

Fields

reader: R

writer: W

Implementations

impl GdbServer<BufReader<TcpStream>, TcpStream>

pub fn listen<A>(addr: A) -> Result<Self, Error>

where A: ToSocketAddrs,

Examples found in repository

examples/repl.rs (line 6)

fn main() -> Result<(), Error> {
    println!("Listening on port 1337...");
    let mut server = GdbServer::listen("0.0.0.0:1337")?;
    println!("Connected!");

    while let Some(packet) = server.next_packet()? {
        println!(
            "-> {:?} {:?}",
            packet.kind,
            std::str::from_utf8(&packet.data)
        );

        print!(": ");
        io::stdout().flush()?;
        let mut response = String::new();
        io::stdin().read_line(&mut response)?;
        if response.ends_with('\n') {
            response.truncate(response.len() - 1);
        }
        let response = CheckedPacket::from_data(Kind::Packet, response.into_bytes());

        let mut bytes = Vec::new();
        response.encode(&mut bytes).unwrap();
        println!("<- {:?}", std::str::from_utf8(&bytes));

        server.dispatch(&response)?;
    }

    println!("EOF");
    Ok(())
}

impl<'a> GdbServer<&'a mut &'a [u8], Vec<u8>>

pub fn tester(input: &'a mut &'a [u8]) -> Self

pub fn response(&mut self) -> Vec<u8>

impl<R, W> GdbServer<R, W>

where R: BufRead, W: Write,

pub fn new(reader: R, writer: W) -> Self

pub fn next_packet(&mut self) -> Result<Option<CheckedPacket>, Error>

Examples found in repository

examples/repl.rs (line 9)

fn main() -> Result<(), Error> {
    println!("Listening on port 1337...");
    let mut server = GdbServer::listen("0.0.0.0:1337")?;
    println!("Connected!");

    while let Some(packet) = server.next_packet()? {
        println!(
            "-> {:?} {:?}",
            packet.kind,
            std::str::from_utf8(&packet.data)
        );

        print!(": ");
        io::stdout().flush()?;
        let mut response = String::new();
        io::stdin().read_line(&mut response)?;
        if response.ends_with('\n') {
            response.truncate(response.len() - 1);
        }
        let response = CheckedPacket::from_data(Kind::Packet, response.into_bytes());

        let mut bytes = Vec::new();
        response.encode(&mut bytes).unwrap();
        println!("<- {:?}", std::str::from_utf8(&bytes));

        server.dispatch(&response)?;
    }

    println!("EOF");
    Ok(())
}

pub fn dispatch(&mut self, packet: &CheckedPacket) -> Result<(), Error>

Sends a packet, retrying upon any failed checksum verification on the remote.

Examples found in repository

examples/repl.rs (line 29)

fn main() -> Result<(), Error> {
    println!("Listening on port 1337...");
    let mut server = GdbServer::listen("0.0.0.0:1337")?;
    println!("Connected!");

    while let Some(packet) = server.next_packet()? {
        println!(
            "-> {:?} {:?}",
            packet.kind,
            std::str::from_utf8(&packet.data)
        );

        print!(": ");
        io::stdout().flush()?;
        let mut response = String::new();
        io::stdin().read_line(&mut response)?;
        if response.ends_with('\n') {
            response.truncate(response.len() - 1);
        }
        let response = CheckedPacket::from_data(Kind::Packet, response.into_bytes());

        let mut bytes = Vec::new();
        response.encode(&mut bytes).unwrap();
        println!("<- {:?}", std::str::from_utf8(&bytes));

        server.dispatch(&response)?;
    }

    println!("EOF");
    Ok(())
}