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