wincwifi 0.3.0

WINC1500 Wifi chip embedded driver
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

use core::net::SocketAddrV4;

use super::op::OpImpl;
use crate::client::ClientSocketOp;
use crate::socket::Socket;
use crate::stack::sock_holder::SocketStore;
use crate::stack::socket_callbacks::SocketCallbacks;
use crate::stack::socket_callbacks::{AsyncOp, AsyncState};
use crate::transfer::Xfer;
use crate::Handle;
use crate::StackError;

#[derive(Debug)]
pub struct TcpAcceptOp {
    handle: Handle,
}

impl TcpAcceptOp {
    pub fn new(handle: Handle) -> Self {
        Self { handle }
    }
}

impl<X: Xfer> OpImpl<X> for TcpAcceptOp {
    type Output = (Socket, SocketAddrV4);
    type Error = StackError;

    fn poll_impl(
        &mut self,
        _manager: &mut crate::manager::Manager<X>,
        callbacks: &mut SocketCallbacks,
    ) -> Result<Option<Self::Output>, Self::Error> {
        let (_sock, op) = callbacks
            .tcp_sockets
            .get(self.handle)
            .ok_or(StackError::SocketNotFound)?;

        match op {
            ClientSocketOp::AsyncOp(AsyncOp::Accept(Some(accept_result)), _) => {
                let accepted_socket = accept_result.accepted_socket;
                let addr = accept_result.accept_addr;
                *op = ClientSocketOp::None;
                Ok(Some((accepted_socket, addr)))
            }
            ClientSocketOp::AsyncOp(AsyncOp::Accept(None), AsyncState::Pending(_)) => Ok(None),
            _ => {
                // No manager command to send - just set up the pending state
                *op = ClientSocketOp::AsyncOp(AsyncOp::Accept(None), AsyncState::Pending(None));
                Ok(None)
            }
        }
    }
}