artiq/artiq/firmware/libproto/kernel_proto.rs

use core::fmt;
use dyld;

pub const KERNELCPU_EXEC_ADDRESS:    usize = 0x40800000;
pub const KERNELCPU_PAYLOAD_ADDRESS: usize = 0x40840000;
pub const KERNELCPU_LAST_ADDRESS:    usize = 0x4fffffff;
pub const KSUPPORT_HEADER_SIZE:      usize = 0x80;

#[repr(C)]
#[derive(Debug, Clone)]
pub struct Exception<'a> {
    pub name:     &'a str,
    pub file:     &'a str,
    pub line:     u32,
    pub column:   u32,
    pub function: &'a str,
    pub message:  &'a str,
    pub param:    [i64; 3]
}

#[derive(Debug)]
pub enum Message<'a> {
    LoadRequest(&'a [u8]),
    LoadReply(Result<(), dyld::Error<'a>>),

    NowInitRequest,
    NowInitReply(u64),
    NowSave(u64),

    RtioInitRequest,

    DmaRecordStart,
    DmaRecordAppend {
        timestamp: u64,
        channel:   u32,
        address:   u32,
        data:      &'a [u32]
    },
    DmaRecordStop(&'a str),

    DmaEraseRequest(&'a str),

    DmaPlaybackRequest(&'a str),
    DmaPlaybackReply(Option<&'a [u8]>),

    DrtioChannelStateRequest { channel: u32 },
    DrtioChannelStateReply { fifo_space: u16, last_timestamp: u64 },
    DrtioResetChannelStateRequest { channel: u32 },
    DrtioGetFifoSpaceRequest { channel: u32 },
    DrtioPacketCountRequest,
    DrtioPacketCountReply { tx_cnt: u32, rx_cnt: u32 },
    DrtioFifoSpaceReqCountRequest,
    DrtioFifoSpaceReqCountReply { cnt: u32 },

    RunFinished,
    RunException {
        exception: Exception<'a>,
        backtrace: &'a [usize]
    },
    RunAborted,

    WatchdogSetRequest { ms: u64 },
    WatchdogSetReply   { id: usize },
    WatchdogClear      { id: usize },

    RpcSend {
        async: bool,
        service: u32,
        tag: &'a [u8],
        data: *const *const ()
    },
    RpcRecvRequest(*mut ()),
    RpcRecvReply(Result<usize, Exception<'a>>),

    CacheGetRequest { key: &'a str },
    CacheGetReply   { value: &'static [i32] },
    CachePutRequest { key: &'a str, value: &'a [i32] },
    CachePutReply   { succeeded: bool },

    I2cStartRequest { busno: u8 },
    I2cStopRequest { busno: u8 },
    I2cWriteRequest { busno: u8, data: u8 },
    I2cWriteReply { ack: bool },
    I2cReadRequest { busno: u8, ack: bool },
    I2cReadReply { data: u8 },

    Log(fmt::Arguments<'a>),
    LogSlice(&'a str)
}

pub use self::Message::*;