etherage 0.5.1

An EtherCAT master in pure-Rust very close to the ethercat nature
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
59
60
61

use std::error::Error;
use etherage::{
    EthernetSocket, RawMaster,
    SlaveAddress, Slave, CommunicationState,
    sii::{self, Sii, CategoryType, WORD},
    };

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let master = RawMaster::new(EthernetSocket::new("eno1")?);

    let mut slave = Slave::raw(master.clone(), SlaveAddress::AutoIncremented(0));
    slave.switch(CommunicationState::Init).await.unwrap();
    slave.set_address(1).await.unwrap();

    let mut sii = Sii::new(master.clone(), slave.address()).await.unwrap();
    sii.acquire().await?;

    let mut categories = sii.categories();
    loop {
        let category = categories.unpack::<sii::Category>().await?;
        if category.ty() == CategoryType::End
            {break}
        let mut sub = categories.sub(WORD*category.size());
        match category.ty() {
            CategoryType::General => println!("{:#?}", sub.unpack::<sii::General>().await?),
            CategoryType::Dc => println!("{:#?}", sub.unpack::<sii::DistributedClock>().await?),
            CategoryType::SyncManager => while sub.remain() > 0 {
                println!("{:#?}", sub.unpack::<sii::SyncManager>().await?);
            },
            CategoryType::SyncUnit => while sub.remain() > 0 {
                println!("{:#?}", sub.unpack::<sii::SyncUnit>().await?);
            },
            CategoryType::PdoWrite => while sub.remain() > 0 {
                let pdo = sub.unpack::<sii::Pdo>().await?;
                println!("write {:#?}", pdo);
                for i in 0 .. pdo.entries {
                    let entry = sub.unpack::<sii::PdoEntry>().await?;
                    println!("    {}: {:?}", i, entry);
                }
            },
            CategoryType::PdoRead => while sub.remain() > 0 {
                let pdo = sub.unpack::<sii::Pdo>().await?;
                println!("read {:#?}", pdo);
                for i in 0 .. pdo.entries {
                    let entry = sub.unpack::<sii::PdoEntry>().await?;
                    println!("    {}: {:?}", i, entry);
                }
            },
            CategoryType::Fmmu => while sub.remain() > 0 {
                println!("Fmmu {:#?}", sub.unpack::<sii::FmmuUsage>().await?);
            },
            CategoryType::FmmuExtension => while sub.remain() > 0 {
                println!("{:#?}", sub.unpack::<sii::FmmuExtension>().await?);
            },
            _ => println!("{:?}", category.ty()),
        }
    }

    Ok(())
}