book: indirection for faster message passing

This commit is contained in:
Jorge Aparicio 2019-04-22 22:21:46 +02:00
parent 852337e03b
commit 4dc44594c9
3 changed files with 93 additions and 0 deletions

View file

@ -91,3 +91,27 @@ after the function, not the interrupt / exception. Example below:
``` console ``` console
$ cargo run --example binds $ cargo run --example binds
{{#include ../../../../ci/expected/binds.run}}``` {{#include ../../../../ci/expected/binds.run}}```
## Indirection for faster message passing
Message passing always involves copying the payload from the sender into a
static variable and then from the static variable into the receiver. Thus
sending a large buffer, like a `[u8; 128]`, as a message involves two expensive
`memcpy`s. To minimize the message passing overhead one can use indirection:
instead of sending the buffer by value, one can send an owning pointer into the
buffer.
One can use a global allocator to achieve indirection (`alloc::Box`,
`alloc::Rc`, etc.), which requires using the nightly channel as of Rust v1.34.0,
or one can use a statically allocated memory pool like [`heapless::Pool`].
[`heapless::Pool`]: https://docs.rs/heapless/0.4.3/heapless/pool/index.html
Here's an example where `heapless::Pool` is used to "box" buffers of 128 bytes.
``` rust
{{#include ../../../../examples/pool.rs}}
```
``` console
$ cargo run --example binds
{{#include ../../../../ci/expected/pool.run}}```

2
ci/expected/pool.run Normal file
View file

@ -0,0 +1,2 @@
bar(0x2000008c)
foo(0x20000110)

67
examples/pool.rs Normal file
View file

@ -0,0 +1,67 @@
//! examples/pool.rs
#![deny(unsafe_code)]
#![deny(warnings)]
#![no_main]
#![no_std]
extern crate panic_semihosting;
use cortex_m_semihosting::{debug, hprintln};
use heapless::{
pool,
pool::singleton::{Box, Pool},
};
use lm3s6965::Interrupt;
use rtfm::app;
// Declare a pool of 128-byte memory blocks
pool!(P: [u8; 128]);
#[app(device = lm3s6965)]
const APP: () = {
#[init]
fn init() {
static mut MEMORY: [u8; 512] = [0; 512];
// Increase the capacity of the memory pool by ~4
P::grow(MEMORY);
rtfm::pend(Interrupt::I2C0);
}
#[interrupt(priority = 2, spawn = [foo, bar])]
fn I2C0() {
// claim a memory block, leave it uninitialized and ..
let x = P::alloc().unwrap().freeze();
// .. send it to the `foo` task
spawn.foo(x).ok().unwrap();
// send another block to the task `bar`
spawn.bar(P::alloc().unwrap().freeze()).ok().unwrap();
}
#[task]
fn foo(x: Box<P>) {
hprintln!("foo({:?})", x.as_ptr()).unwrap();
// explicitly return the block to the pool
drop(x);
debug::exit(debug::EXIT_SUCCESS);
}
#[task(priority = 2)]
fn bar(x: Box<P>) {
hprintln!("bar({:?})", x.as_ptr()).unwrap();
// this is done automatically so we can omit the call to `drop`
// drop(x);
}
extern "C" {
fn UART0();
fn UART1();
}
};