tentacle 0.7.5

Minimal implementation for a multiplexed p2p network framework.
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

use crate::{SessionId, secio::error::SecioError};
use multiaddr::Multiaddr;
use std::io::Error as IOError;
use thiserror::Error;

#[derive(Error, Debug)]
/// Transport Error
pub enum TransportErrorKind {
    /// IO error
    #[error("transport io error: `{0:?}`")]
    Io(#[from] IOError),
    /// Proxy server error
    #[error("proxy error: `{0:?}`")]
    ProxyError(IOError),
    /// Protocol not support
    #[error("multiaddr `{0:?}` is not supported")]
    NotSupported(Multiaddr),
    /// Dns resolver error
    #[error("can not resolve `{0:?}`, io error: `{1:?}`")]
    DnsResolverError(Multiaddr, IOError),
    /// Tls error
    #[error("tls setting error: `{0:?}`")]
    #[cfg(feature = "tls")]
    TlsError(String),
}

#[derive(Error, Debug)]
/// Protocol handle error
pub enum ProtocolHandleErrorKind {
    /// protocol handle abnormally closed, may be user's protocol handle implementation problem
    #[error("protocol handle abnormally closed, session id: `{0:?}`")]
    AbnormallyClosed(Option<SessionId>),
}

#[derive(Error, Debug)]
/// Detail error kind when dial remote error
pub enum DialerErrorKind {
    /// IO error
    #[error("dialler io error: `{0:?}`")]
    IoError(IOError),
    /// When dial remote, peer id does not match
    #[error("peer id not match")]
    PeerIdNotMatch,
    /// Connected to the connected peer
    #[error("repeated connection, sessio id: `{0:?}`")]
    RepeatedConnection(SessionId),
    /// Handshake error
    #[error("handshake error: `{0:?}`")]
    HandshakeError(HandshakeErrorKind),
    /// Transport error
    #[error("transport error: `{0:?}`")]
    TransportError(TransportErrorKind),
}

#[derive(Error, Debug)]
/// Handshake error
pub enum HandshakeErrorKind {
    /// Handshake timeout error
    #[error("timeout error: `{0:?}`")]
    Timeout(String),
    /// Secio error
    #[error("secio error: `{0:?}`")]
    SecioError(SecioError),
}

#[derive(Error, Debug)]
/// Listener error kind when dial remote error
pub enum ListenErrorKind {
    /// IO error
    #[error("listen io error: `{0:?}`")]
    IoError(IOError),
    /// Connected to the connected peer
    #[error("repeated connection, sessio id: `{0:?}`")]
    RepeatedConnection(SessionId),
    /// Transport error
    #[error("transport error: `{0:?}`")]
    TransportError(TransportErrorKind),
}

#[derive(Error, Debug)]
/// Send error kind when send service task
pub enum SendErrorKind {
    /// Sending failed because a pipe was closed.
    #[error("broken pipe")]
    BrokenPipe,
    /// The operation needs to block to complete, but the blocking operation was requested to not occur.
    #[error("would block")]
    WouldBlock,
}