Function open_path

tcp/src/main.rs:244–286

Open a path from the root, returning a communication handle Note: This function spawns a thread which will then attempt to open the socket. It is possible that this function succeeds but then opening the socket fails.

(path: &str)

///       to open the socket. It is possible that this function
///       succeeds but then opening the socket fails.
fn open_path(path: &str) -> Result<CommHandle, ()> {
    if let Some(ind) = path.find('/') {
        // Split and copy into Strings which can be moved to a new thread
        let host_str = String::from(&path[..ind]);

        let port: u16 =  ((&path[(ind+1)..])
                                 .trim_matches(|c:char| c == '/' ||
                                               c.is_whitespace()))
            .parse().map_err(|e| {println!("[tcp] Invalid port: {:?}", e);})?;

        // Make a new communication handle pair
        let (handle, client_handle) = syscalls::new_rendezvous()
            .map_err(|e| {println!("[tcp] Couldn't create Rendezvous {:?}", e);})?;

        // Start a thread with one of the handles
        thread::spawn(move || {
            // Get the IP address
            let ip = match IpAddress::from_str(&host_str) {
                Ok(ip) => ip,
                Err(_) => {
                    // Not an IP address, so assume it's a host name to be resolved
                    match dns::resolve(&host_str) {
                        Ok(addr) => {
                            println!("[tcp] {} has address {}", &host_str, addr);
                            addr
                        }
                        Err(e) => {
                            println!("[tcp] Could not resolve host {}: {:?}", &host_str, e);
                            return;
                        }
                    }
                }
            };

            open_socket(ip, port, handle);
        });

        // Return the other handle to the client
        return Ok(client_handle);
    }
    println!("[tcp] Error: open_path '{}' doesn't contain '/'", path);
    Err(())
}

/// Returns a port number in the range 49152–65535.
///