ruda-kernel 0.1.3

Ruda Rust kernel DSL and device tensor operations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

use crate::dsl::prelude::*;
use crate::dsl::ir::{BinaryOperator, Instruction, ManagedVariable, Operator, UnaryOperator};

/// Obtain the native byte address of a slice element. The address remains valid
/// only while the underlying allocation is alive and in its owning address space.
pub fn native_address<T: RudaPrimitive>(_input: &Slice<T>, _index: usize) -> u64 {
    crate::dsl::unexpanded!()
}

pub mod native_address {
    use super::*;
    pub fn expand<T: RudaPrimitive>(scope: &mut Scope, input: SliceExpand<T, ReadOnly>, index: NativeExpand<usize>) -> NativeExpand<u64> {
        let (array, offset) = input.__to_raw_parts();
        let index = if index.expand.ty != usize::as_type(scope) {
            let converted = scope.create_local(usize::as_type(scope));
            cast::expand::<usize, usize>(scope, index, converted.clone().into());
            converted.into()
        } else { index };
        let index = add::expand(scope, index, NativeExpand::new(ManagedVariable::Plain(offset)));
        let ty = u64::as_type(scope);
        let output = scope.create_local(ty);
        scope.register(Instruction::new(Operator::NativeAddress(BinaryOperator {
            lhs: array, rhs: index.expand.consume(),
        }), *output));
        output.into()
    }
}

/// Read a value at a native byte address. The caller supplies a valid, aligned
/// address in the current device's address space, with enough readable storage.
pub fn native_load<T: RudaPrimitive>(_address: u64) -> T {
    crate::dsl::unexpanded!()
}

pub mod native_load {
    use super::*;
    pub fn expand<T: RudaPrimitive>(scope: &mut Scope, address: NativeExpand<u64>) -> NativeExpand<T> {
        let ty = T::as_type(scope);
        let output = scope.create_local(ty);
        scope.register(Instruction::new(Operator::NativeLoad(UnaryOperator { input: address.expand.consume() }), *output));
        output.into()
    }
}

/// Write through a native byte address. The caller supplies a valid, aligned,
/// writable allocation and obeys the device's synchronization requirements.
pub fn native_store<T: RudaPrimitive>(_address: u64, _value: T) {
    crate::dsl::unexpanded!()
}

pub mod native_store {
    use super::*;
    pub fn expand<T: RudaPrimitive>(scope: &mut Scope, address: NativeExpand<u64>, value: NativeExpand<T>) {
        scope.register(Instruction::no_out(Operator::NativeStore(BinaryOperator {
            lhs: address.expand.consume(), rhs: value.expand.consume(),
        })));
    }
}