1
0
Fork 0

Compare commits

..

1 commit

Author SHA1 Message Date
671d83b186
WIP add transmit-only UART example 2025-10-22 05:06:57 -07:00
3 changed files with 47 additions and 129 deletions

View file

@ -3,34 +3,10 @@
use clap::builder::TypedValueParser; use clap::builder::TypedValueParser;
use fayalite::{ use fayalite::{
build::{ToArgs, WriteArgs}, build::{ToArgs, WriteArgs},
platform::PeripheralRef,
prelude::*, prelude::*,
}; };
use ordered_float::NotNan; use ordered_float::NotNan;
fn pick_clock<'a>(
platform_io_builder: &PlatformIOBuilder<'a>,
) -> PeripheralRef<'a, peripherals::ClockInput> {
let mut clks = platform_io_builder.peripherals_with_type::<peripherals::ClockInput>();
clks.sort_by_key(|clk| {
// sort clocks by preference, smaller return values means higher preference
let mut frequency = clk.ty().frequency();
let priority;
if frequency < 10e6 {
frequency = -frequency; // prefer bigger frequencies
priority = 1;
} else if frequency > 50e6 {
// prefer smaller frequencies
priority = 2; // least preferred
} else {
priority = 0; // most preferred
frequency = (frequency - 25e6).abs(); // prefer closer to 25MHz
}
(priority, NotNan::new(frequency).expect("should be valid"))
});
clks[0]
}
#[hdl_module] #[hdl_module]
fn tx_only_uart( fn tx_only_uart(
platform_io_builder: PlatformIOBuilder<'_>, platform_io_builder: PlatformIOBuilder<'_>,
@ -38,7 +14,8 @@ fn tx_only_uart(
message: impl AsRef<[u8]>, message: impl AsRef<[u8]>,
) { ) {
let message = message.as_ref(); let message = message.as_ref();
let clk_input = pick_clock(&platform_io_builder).use_peripheral(); let clk_input =
platform_io_builder.peripherals_with_type::<peripherals::ClockInput>()[0].use_peripheral();
let rst = platform_io_builder.peripherals_with_type::<Reset>()[0].use_peripheral(); let rst = platform_io_builder.peripherals_with_type::<Reset>()[0].use_peripheral();
let cd = #[hdl] let cd = #[hdl]
ClockDomain { ClockDomain {
@ -79,12 +56,17 @@ fn tx_only_uart(
connect_any(next_uart_state, uart_state_reg + 1u8); connect_any(next_uart_state, uart_state_reg + 1u8);
#[hdl] #[hdl]
let message_mem: Array<UInt<8>> = wire(Array[UInt::new_static()][message.len()]); let mut message_mem = memory_with_init(message);
for (message, message_mem) in message.iter().zip(message_mem) { message_mem.read_latency(4);
connect(message_mem, *message); #[hdl]
} let startup_reg = reg_builder().clock_domain(cd).reset(0u128);
connect_any(startup_reg, (startup_reg << 1) | 1u8);
let message_read = message_mem.new_read_port();
connect(message_read.clk, cd.clk);
connect(message_read.en, true);
#[hdl] #[hdl]
let addr_reg: UInt<32> = reg_builder().clock_domain(cd).reset(0u32); let addr_reg: UInt<32> = reg_builder().clock_domain(cd).reset(0u32);
connect_any(message_read.addr, addr_reg);
#[hdl] #[hdl]
let next_addr: UInt<32> = wire(); let next_addr: UInt<32> = wire();
connect(next_addr, addr_reg); connect(next_addr, addr_reg);
@ -93,19 +75,18 @@ fn tx_only_uart(
let tx = reg_builder().clock_domain(cd).reset(true); let tx = reg_builder().clock_domain(cd).reset(true);
#[hdl] #[hdl]
let tx_bits: Array<Bool, 10> = wire(); if !startup_reg[message_mem.get_read_latency()] {
connect(next_uart_state, 0_hdl_u4);
connect(tx_bits[0], false); // start bit connect(tx, true);
connect(tx_bits[9], true); // stop bit } else if uart_state_reg.cmp_eq(0_hdl_u4) {
connect(tx, false); // start bit
for i in 0..8 { } else if uart_state_reg.cmp_le(8_hdl_u4) {
connect(tx_bits[i + 1], message_mem[addr_reg][i]); // data bits connect(
} tx,
(message_read.data >> (uart_state_reg - 1_hdl_u4))[0].cast_to_static(),
connect(tx, tx_bits[uart_state_reg]); ); // data bit
} else {
#[hdl] connect(tx, true); // stop bit
if uart_state_reg.cmp_eq(Expr::ty(tx_bits).len() - 1) {
connect(next_uart_state, 0_hdl_u4); connect(next_uart_state, 0_hdl_u4);
let next_addr_val = addr_reg + 1u8; let next_addr_val = addr_reg + 1u8;
#[hdl] #[hdl]
@ -166,7 +147,7 @@ fn main() {
"tx_only_uart", "tx_only_uart",
|_, platform, ExtraArgs { baud_rate, message }| { |_, platform, ExtraArgs { baud_rate, message }| {
Ok(JobParams::new(platform.try_wrap_main_module(|io| { Ok(JobParams::new(platform.try_wrap_main_module(|io| {
let clk = pick_clock(&io).ty(); let clk = io.peripherals_with_type::<peripherals::ClockInput>()[0].ty();
let divisor = clk.frequency() / *baud_rate; let divisor = clk.frequency() / *baud_rate;
let baud_rate_error = |msg| { let baud_rate_error = |msg| {
<Cli as clap::CommandFactory>::command() <Cli as clap::CommandFactory>::command()

View file

@ -3,7 +3,7 @@
use crate::{ use crate::{
intern::{Intern, Interned}, intern::{Intern, Interned},
module::{instance_with_loc, reg_builder_with_loc, wire_with_loc}, module::{instance_with_loc, wire_with_loc},
platform::{ platform::{
DynPlatform, Peripheral, PeripheralRef, Peripherals, PeripheralsBuilderFactory, DynPlatform, Peripheral, PeripheralRef, Peripherals, PeripheralsBuilderFactory,
PeripheralsBuilderFinished, Platform, PlatformAspectSet, PeripheralsBuilderFinished, Platform, PlatformAspectSet,
@ -12,7 +12,7 @@ use crate::{
prelude::*, prelude::*,
vendor::xilinx::{ vendor::xilinx::{
Device, XdcCreateClockAnnotation, XdcIOStandardAnnotation, XdcLocationAnnotation, Device, XdcCreateClockAnnotation, XdcIOStandardAnnotation, XdcLocationAnnotation,
primitives, primitives::{self, BUFGCE, STARTUPE2_default_inputs},
}, },
}; };
use ordered_float::NotNan; use ordered_float::NotNan;
@ -66,7 +66,7 @@ arty_a7_platform! {
#[derive(Debug)] #[derive(Debug)]
pub struct ArtyA7Peripherals { pub struct ArtyA7Peripherals {
clk100_div_pow2: [Peripheral<ClockInput>; 4], clk100: Peripheral<ClockInput>,
rst: Peripheral<Reset>, rst: Peripheral<Reset>,
rst_sync: Peripheral<SyncReset>, rst_sync: Peripheral<SyncReset>,
ld0: Peripheral<RgbLed>, ld0: Peripheral<RgbLed>,
@ -84,7 +84,7 @@ pub struct ArtyA7Peripherals {
impl Peripherals for ArtyA7Peripherals { impl Peripherals for ArtyA7Peripherals {
fn append_peripherals<'a>(&'a self, peripherals: &mut Vec<PeripheralRef<'a, CanonicalType>>) { fn append_peripherals<'a>(&'a self, peripherals: &mut Vec<PeripheralRef<'a, CanonicalType>>) {
let Self { let Self {
clk100_div_pow2, clk100,
rst, rst,
rst_sync, rst_sync,
ld0, ld0,
@ -97,7 +97,7 @@ impl Peripherals for ArtyA7Peripherals {
ld7, ld7,
uart, uart,
} = self; } = self;
clk100_div_pow2.append_peripherals(peripherals); clk100.append_peripherals(peripherals);
rst.append_peripherals(peripherals); rst.append_peripherals(peripherals);
rst_sync.append_peripherals(peripherals); rst_sync.append_peripherals(peripherals);
ld0.append_peripherals(peripherals); ld0.append_peripherals(peripherals);
@ -171,20 +171,9 @@ impl Platform for ArtyA7Platform {
builder_factory: PeripheralsBuilderFactory<'builder>, builder_factory: PeripheralsBuilderFactory<'builder>,
) -> (Self::Peripherals, PeripheralsBuilderFinished<'builder>) { ) -> (Self::Peripherals, PeripheralsBuilderFinished<'builder>) {
let mut builder = builder_factory.builder(); let mut builder = builder_factory.builder();
let clk100_div_pow2 = std::array::from_fn(|log2_divisor| {
let divisor = 1u64 << log2_divisor;
let name = if divisor != 1 {
format!("clk100_div_{divisor}")
} else {
"clk100".into()
};
builder.input_peripheral(name, ClockInput::new(100e6 / divisor as f64))
});
builder.add_conflicts(Vec::from_iter(clk100_div_pow2.iter().map(|v| v.id())));
( (
ArtyA7Peripherals { ArtyA7Peripherals {
clk100_div_pow2, clk100: builder.input_peripheral("clk100", ClockInput::new(100e6)),
rst: builder.input_peripheral("rst", Reset), rst: builder.input_peripheral("rst", Reset),
rst_sync: builder.input_peripheral("rst_sync", SyncReset), rst_sync: builder.input_peripheral("rst_sync", SyncReset),
ld0: builder.output_peripheral("ld0", RgbLed), ld0: builder.output_peripheral("ld0", RgbLed),
@ -207,7 +196,7 @@ impl Platform for ArtyA7Platform {
fn add_peripherals_in_wrapper_module(&self, m: &ModuleBuilder, peripherals: Self::Peripherals) { fn add_peripherals_in_wrapper_module(&self, m: &ModuleBuilder, peripherals: Self::Peripherals) {
let ArtyA7Peripherals { let ArtyA7Peripherals {
clk100_div_pow2, clk100,
rst, rst,
rst_sync, rst_sync,
ld0, ld0,
@ -265,82 +254,30 @@ impl Platform for ArtyA7Platform {
connect(buf.T, false); connect(buf.T, false);
buf.I buf.I
}; };
let mut frequency = clk100_div_pow2[0].ty().frequency(); let clock_annotation = XdcCreateClockAnnotation {
let mut log2_divisor = 0; period: NotNan::new(1e9 / clk100.ty().frequency()).expect("known to be valid"),
let mut clk = None;
for (cur_log2_divisor, p) in clk100_div_pow2.into_iter().enumerate() {
let Some(p) = p.into_used() else {
continue;
}; };
debug_assert!(
clk.is_none(),
"conflict-handling logic should ensure at most one clock is used",
);
frequency = p.ty().frequency();
clk = Some(p);
log2_divisor = cur_log2_divisor;
}
let clk100_buf = make_buffered_input("clk100", "E3", "LVCMOS33", false); let clk100_buf = make_buffered_input("clk100", "E3", "LVCMOS33", false);
let startup = instance_with_loc( let startup = instance_with_loc(
"startup", "startup",
primitives::STARTUPE2_default_inputs(), STARTUPE2_default_inputs(),
SourceLocation::builtin(), SourceLocation::builtin(),
); );
let clk_global_buf = instance_with_loc( let clk100_sync = instance_with_loc("clk100_sync", BUFGCE(), SourceLocation::builtin());
"clk_global_buf", connect(clk100_sync.CE, startup.EOS);
primitives::BUFGCE(), connect(clk100_sync.I, clk100_buf);
SourceLocation::builtin(), let clk100_out = wire_with_loc("clk100_out", SourceLocation::builtin(), Clock);
); connect(clk100_out, clk100_sync.O);
connect(clk_global_buf.CE, startup.EOS); annotate(clk100_out, clock_annotation);
let mut clk_global_buf_in = clk100_buf.to_clock(); annotate(clk100_out, DontTouchAnnotation);
for prev_log2_divisor in 0..log2_divisor { if let Some(clk100) = clk100.into_used() {
let prev_divisor = 1u64 << prev_log2_divisor; connect(clk100.instance_io_field().clk, clk100_out);
let clk_in = wire_with_loc(
&format!("clk_div_{prev_divisor}"),
SourceLocation::builtin(),
Clock,
);
connect(clk_in, clk_global_buf_in);
annotate(
clk_in,
XdcCreateClockAnnotation {
period: NotNan::new(1e9 / (100e6 / prev_divisor as f64))
.expect("known to be valid"),
},
);
annotate(clk_in, DontTouchAnnotation);
let cd = wire_with_loc(
&format!("clk_div_{prev_divisor}_in"),
SourceLocation::builtin(),
ClockDomain[AsyncReset],
);
connect(cd.clk, clk_in);
connect(cd.rst, (!startup.EOS).to_async_reset());
let divider = reg_builder_with_loc("divider", SourceLocation::builtin())
.clock_domain(cd)
.reset(false)
.build();
connect(divider, !divider);
clk_global_buf_in = divider.to_clock();
}
connect(clk_global_buf.I, clk_global_buf_in);
let clk_out = wire_with_loc("clk_out", SourceLocation::builtin(), Clock);
connect(clk_out, clk_global_buf.O);
annotate(
clk_out,
XdcCreateClockAnnotation {
period: NotNan::new(1e9 / frequency).expect("known to be valid"),
},
);
annotate(clk_out, DontTouchAnnotation);
if let Some(clk) = clk {
connect(clk.instance_io_field().clk, clk_out);
} }
let rst_value = { let rst_value = {
let rst_buf = make_buffered_input("rst", "C2", "LVCMOS33", true); let rst_buf = make_buffered_input("rst", "C2", "LVCMOS33", true);
let rst_sync = instance_with_loc("rst_sync", reset_sync(), SourceLocation::builtin()); let rst_sync = instance_with_loc("rst_sync", reset_sync(), SourceLocation::builtin());
connect(rst_sync.clk, clk_out); connect(rst_sync.clk, clk100_sync.O);
connect(rst_sync.inp, rst_buf | !startup.EOS); connect(rst_sync.inp, rst_buf);
rst_sync.out rst_sync.out
}; };
if let Some(rst) = rst.into_used() { if let Some(rst) = rst.into_used() {

View file

@ -33,7 +33,7 @@ pub fn BUFGCE() {
#[hdl] #[hdl]
let CE: Bool = m.input(); let CE: Bool = m.input();
#[hdl] #[hdl]
let I: Clock = m.input(); let I: Bool = m.input();
} }
#[hdl_module(extern)] #[hdl_module(extern)]