@@ -15,7 +15,7 @@ use crate::time::Duration;
15
15
pub fn init ( ) -> io:: Result < ( ) > {
16
16
if abi:: network_init ( ) < 0 {
17
17
return Err ( io:: Error :: new_const (
18
- ErrorKind :: Other ,
18
+ ErrorKind :: Unknown ,
19
19
& "Unable to initialize network interface" ,
20
20
) ) ;
21
21
}
@@ -51,7 +51,7 @@ impl TcpStream {
51
51
match abi:: tcpstream:: connect ( addr. ip ( ) . to_string ( ) . as_bytes ( ) , addr. port ( ) , None ) {
52
52
Ok ( handle) => Ok ( TcpStream ( Arc :: new ( Socket ( handle) ) ) ) ,
53
53
_ => Err ( io:: Error :: new_const (
54
- ErrorKind :: Other ,
54
+ ErrorKind :: Unknown ,
55
55
& "Unable to initiate a connection on a socket" ,
56
56
) ) ,
57
57
}
@@ -65,44 +65,44 @@ impl TcpStream {
65
65
) {
66
66
Ok ( handle) => Ok ( TcpStream ( Arc :: new ( Socket ( handle) ) ) ) ,
67
67
_ => Err ( io:: Error :: new_const (
68
- ErrorKind :: Other ,
68
+ ErrorKind :: Unknown ,
69
69
& "Unable to initiate a connection on a socket" ,
70
70
) ) ,
71
71
}
72
72
}
73
73
74
74
pub fn set_read_timeout ( & self , duration : Option < Duration > ) -> io:: Result < ( ) > {
75
75
abi:: tcpstream:: set_read_timeout ( * self . 0 . as_inner ( ) , duration. map ( |d| d. as_millis ( ) as u64 ) )
76
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "Unable to set timeout value" ) )
76
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to set timeout value" ) )
77
77
}
78
78
79
79
pub fn set_write_timeout ( & self , duration : Option < Duration > ) -> io:: Result < ( ) > {
80
80
abi:: tcpstream:: set_write_timeout (
81
81
* self . 0 . as_inner ( ) ,
82
82
duration. map ( |d| d. as_millis ( ) as u64 ) ,
83
83
)
84
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "Unable to set timeout value" ) )
84
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to set timeout value" ) )
85
85
}
86
86
87
87
pub fn read_timeout ( & self ) -> io:: Result < Option < Duration > > {
88
88
let duration = abi:: tcpstream:: get_read_timeout ( * self . 0 . as_inner ( ) ) . map_err ( |_| {
89
- io:: Error :: new_const ( ErrorKind :: Other , & "Unable to determine timeout value" )
89
+ io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to determine timeout value" )
90
90
} ) ?;
91
91
92
92
Ok ( duration. map ( |d| Duration :: from_millis ( d) ) )
93
93
}
94
94
95
95
pub fn write_timeout ( & self ) -> io:: Result < Option < Duration > > {
96
96
let duration = abi:: tcpstream:: get_write_timeout ( * self . 0 . as_inner ( ) ) . map_err ( |_| {
97
- io:: Error :: new_const ( ErrorKind :: Other , & "Unable to determine timeout value" )
97
+ io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to determine timeout value" )
98
98
} ) ?;
99
99
100
100
Ok ( duration. map ( |d| Duration :: from_millis ( d) ) )
101
101
}
102
102
103
103
pub fn peek ( & self , buf : & mut [ u8 ] ) -> io:: Result < usize > {
104
104
abi:: tcpstream:: peek ( * self . 0 . as_inner ( ) , buf)
105
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "set_nodelay failed" ) )
105
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "set_nodelay failed" ) )
106
106
}
107
107
108
108
pub fn read ( & self , buffer : & mut [ u8 ] ) -> io:: Result < usize > {
@@ -113,8 +113,9 @@ impl TcpStream {
113
113
let mut size: usize = 0 ;
114
114
115
115
for i in ioslice. iter_mut ( ) {
116
- let ret = abi:: tcpstream:: read ( * self . 0 . as_inner ( ) , & mut i[ 0 ..] )
117
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "Unable to read on socket" ) ) ?;
116
+ let ret = abi:: tcpstream:: read ( * self . 0 . as_inner ( ) , & mut i[ 0 ..] ) . map_err ( |_| {
117
+ io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to read on socket" )
118
+ } ) ?;
118
119
119
120
if ret != 0 {
120
121
size += ret;
@@ -138,7 +139,7 @@ impl TcpStream {
138
139
139
140
for i in ioslice. iter ( ) {
140
141
size += abi:: tcpstream:: write ( * self . 0 . as_inner ( ) , i) . map_err ( |_| {
141
- io:: Error :: new_const ( ErrorKind :: Other , & "Unable to write on socket" )
142
+ io:: Error :: new_const ( ErrorKind :: Unknown , & "Unable to write on socket" )
142
143
} ) ?;
143
144
}
144
145
@@ -152,13 +153,13 @@ impl TcpStream {
152
153
153
154
pub fn peer_addr ( & self ) -> io:: Result < SocketAddr > {
154
155
let ( ipaddr, port) = abi:: tcpstream:: peer_addr ( * self . 0 . as_inner ( ) )
155
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "peer_addr failed" ) ) ?;
156
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "peer_addr failed" ) ) ?;
156
157
157
158
let saddr = match ipaddr {
158
159
Ipv4 ( ref addr) => SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: from ( addr. 0 ) ) , port) ,
159
160
Ipv6 ( ref addr) => SocketAddr :: new ( IpAddr :: V6 ( Ipv6Addr :: from ( addr. 0 ) ) , port) ,
160
161
_ => {
161
- return Err ( io:: Error :: new_const ( ErrorKind :: Other , & "peer_addr failed" ) ) ;
162
+ return Err ( io:: Error :: new_const ( ErrorKind :: Unknown , & "peer_addr failed" ) ) ;
162
163
}
163
164
} ;
164
165
@@ -171,7 +172,7 @@ impl TcpStream {
171
172
172
173
pub fn shutdown ( & self , how : Shutdown ) -> io:: Result < ( ) > {
173
174
abi:: tcpstream:: shutdown ( * self . 0 . as_inner ( ) , how as i32 )
174
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "unable to shutdown socket" ) )
175
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "unable to shutdown socket" ) )
175
176
}
176
177
177
178
pub fn duplicate ( & self ) -> io:: Result < TcpStream > {
@@ -180,22 +181,22 @@ impl TcpStream {
180
181
181
182
pub fn set_nodelay ( & self , mode : bool ) -> io:: Result < ( ) > {
182
183
abi:: tcpstream:: set_nodelay ( * self . 0 . as_inner ( ) , mode)
183
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "set_nodelay failed" ) )
184
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "set_nodelay failed" ) )
184
185
}
185
186
186
187
pub fn nodelay ( & self ) -> io:: Result < bool > {
187
188
abi:: tcpstream:: nodelay ( * self . 0 . as_inner ( ) )
188
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "nodelay failed" ) )
189
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "nodelay failed" ) )
189
190
}
190
191
191
192
pub fn set_ttl ( & self , tll : u32 ) -> io:: Result < ( ) > {
192
193
abi:: tcpstream:: set_tll ( * self . 0 . as_inner ( ) , tll)
193
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "unable to set TTL" ) )
194
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "unable to set TTL" ) )
194
195
}
195
196
196
197
pub fn ttl ( & self ) -> io:: Result < u32 > {
197
198
abi:: tcpstream:: get_tll ( * self . 0 . as_inner ( ) )
198
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "unable to get TTL" ) )
199
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "unable to get TTL" ) )
199
200
}
200
201
201
202
pub fn take_error ( & self ) -> io:: Result < Option < io:: Error > > {
@@ -204,7 +205,7 @@ impl TcpStream {
204
205
205
206
pub fn set_nonblocking ( & self , mode : bool ) -> io:: Result < ( ) > {
206
207
abi:: tcpstream:: set_nonblocking ( * self . 0 . as_inner ( ) , mode)
207
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "unable to set blocking mode" ) )
208
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "unable to set blocking mode" ) )
208
209
}
209
210
}
210
211
@@ -230,12 +231,12 @@ impl TcpListener {
230
231
231
232
pub fn accept ( & self ) -> io:: Result < ( TcpStream , SocketAddr ) > {
232
233
let ( handle, ipaddr, port) = abi:: tcplistener:: accept ( self . 0 . port ( ) )
233
- . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Other , & "accept failed" ) ) ?;
234
+ . map_err ( |_| io:: Error :: new_const ( ErrorKind :: Unknown , & "accept failed" ) ) ?;
234
235
let saddr = match ipaddr {
235
236
Ipv4 ( ref addr) => SocketAddr :: new ( IpAddr :: V4 ( Ipv4Addr :: from ( addr. 0 ) ) , port) ,
236
237
Ipv6 ( ref addr) => SocketAddr :: new ( IpAddr :: V6 ( Ipv6Addr :: from ( addr. 0 ) ) , port) ,
237
238
_ => {
238
- return Err ( io:: Error :: new_const ( ErrorKind :: Other , & "accept failed" ) ) ;
239
+ return Err ( io:: Error :: new_const ( ErrorKind :: Unknown , & "accept failed" ) ) ;
239
240
}
240
241
} ;
241
242
0 commit comments