Function dispatch_loop

euralios_std/src/server.rs:154–190

Dispatch messages in a loop, returning when the communication handle is closed. This function handles common error messages, passing other messages to the given function `f`.

(handle: &CommHandle,
                    mut f: F)

/// other messages to the given function `f`.
///
fn dispatch_loop<F>(handle: &CommHandle,
                    mut f: F)
where
    F: FnMut(syscalls::Message) -> (),
{
    loop {
        match syscalls::receive(handle) {
            Ok(syscalls::Message::Short(
                message::CLOSE, _, _)) => {
                // Close this file handler, dropping comm_handle
                return;
            },
            Err(syscalls::SYSCALL_ERROR_RECV_BLOCKING) => {
                // Waiting for a message
                // => Send an error message
                if let Err((err, _msg)) = syscalls::send(handle,
                                                         syscalls::Message::Short(
                                                             message::ERROR, 0, 0)) {
                    // Failed to send. Not clear what to do here
                    println!("[std:dispatch_loop] Blocked recv: {}", err);
                }
                // Wait and try again
                syscalls::thread_yield();
            },
            Err(syscalls::SYSCALL_ERROR_CLOSED) => {
                // Other Rendezvous handles have been dropped
                return;
            },
            Ok(msg) => f(msg),
            Err(code) => {
                println!("[std:dispatch_loop] Receive error {}", code);
                // Wait and try again
                syscalls::thread_yield();
            }
        }
    }
}

/// Serve messages received from a communication channel
/// reading and writing data from a file