提交 e790c66c authored 作者: Serhij S's avatar Serhij S

codefmt

上级 fa5bca7d
...@@ -106,7 +106,7 @@ fn parse_path(path: &str) -> Result<Parameters> { ...@@ -106,7 +106,7 @@ fn parse_path(path: &str) -> Result<Parameters> {
pub fn open(params: &Parameters, timeout: Duration) -> Result<SystemPort> { pub fn open(params: &Parameters, timeout: Duration) -> Result<SystemPort> {
let mut port = serial::open(&params.port_dev).map_err(Error::io)?; let mut port = serial::open(&params.port_dev).map_err(Error::io)?;
port.reconfigure(&|settings| { port.reconfigure(&|settings| {
(settings.set_baud_rate(params.baud_rate).unwrap()); settings.set_baud_rate(params.baud_rate)?;
settings.set_char_size(params.char_size); settings.set_char_size(params.char_size);
settings.set_parity(params.parity); settings.set_parity(params.parity);
settings.set_stop_bits(params.stop_bits); settings.set_stop_bits(params.stop_bits);
......
...@@ -70,6 +70,7 @@ impl SemaphoreInner { ...@@ -70,6 +70,7 @@ impl SemaphoreInner {
} }
} }
#[allow(clippy::module_name_repetitions)]
pub struct SemaphoreGuard { pub struct SemaphoreGuard {
inner: Arc<SemaphoreInner>, inner: Arc<SemaphoreInner>,
} }
...@@ -121,9 +122,8 @@ mod test { ...@@ -121,9 +122,8 @@ mod test {
} }
'outer: loop { 'outer: loop {
for task in &tasks { for task in &tasks {
if sem.is_poisoned() { std::hint::spin_loop();
panic!("Semaphore is poisoned"); assert!(!sem.is_poisoned(), "Semaphore is poisoned");
}
if !task.is_finished() { if !task.is_finished() {
continue 'outer; continue 'outer;
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论