File tree 4 files changed +25
-6
lines changed
library/std/src/os/unix/net
4 files changed +25
-6
lines changed Original file line number Diff line number Diff line change @@ -285,7 +285,11 @@ impl SocketAddr {
285
285
) ) ;
286
286
}
287
287
288
- ptr:: copy_nonoverlapping ( namespace. as_ptr ( ) , addr. sun_path . as_mut_ptr ( ) . offset ( 1 ) as * mut u8 , namespace. len ( ) ) ;
288
+ ptr:: copy_nonoverlapping (
289
+ namespace. as_ptr ( ) ,
290
+ addr. sun_path . as_mut_ptr ( ) . offset ( 1 ) as * mut u8 ,
291
+ namespace. len ( ) ,
292
+ ) ;
289
293
let len = ( sun_path_offset ( & addr) + 1 + namespace. len ( ) ) as libc:: socklen_t ;
290
294
SocketAddr :: from_parts ( addr, len)
291
295
}
Original file line number Diff line number Diff line change @@ -136,7 +136,11 @@ impl UnixDatagram {
136
136
pub fn bind_addr ( socket_addr : & SocketAddr ) -> io:: Result < UnixDatagram > {
137
137
unsafe {
138
138
let socket = UnixDatagram :: unbound ( ) ?;
139
- cvt ( libc:: bind ( * socket. 0 . as_inner ( ) , & socket_addr. addr as * const _ as * const _ , socket_addr. len as _ ) ) ?;
139
+ cvt ( libc:: bind (
140
+ * socket. 0 . as_inner ( ) ,
141
+ & socket_addr. addr as * const _ as * const _ ,
142
+ socket_addr. len as _ ,
143
+ ) ) ?;
140
144
Ok ( socket)
141
145
}
142
146
}
@@ -245,7 +249,11 @@ impl UnixDatagram {
245
249
#[ unstable( feature = "unix_socket_abstract" , issue = "42048" ) ]
246
250
pub fn connect_addr ( & self , socket_addr : & SocketAddr ) -> io:: Result < ( ) > {
247
251
unsafe {
248
- cvt ( libc:: connect ( * self . 0 . as_inner ( ) , & socket_addr. addr as * const _ as * const _ , socket_addr. len ) ) ?;
252
+ cvt ( libc:: connect (
253
+ * self . 0 . as_inner ( ) ,
254
+ & socket_addr. addr as * const _ as * const _ ,
255
+ socket_addr. len ,
256
+ ) ) ?;
249
257
}
250
258
Ok ( ( ) )
251
259
}
Original file line number Diff line number Diff line change @@ -107,14 +107,17 @@ impl UnixListener {
107
107
pub fn bind_addr ( socket_addr : & SocketAddr ) -> io:: Result < UnixListener > {
108
108
unsafe {
109
109
let inner = Socket :: new_raw ( libc:: AF_UNIX , libc:: SOCK_STREAM ) ?;
110
- cvt ( libc:: bind ( * inner. as_inner ( ) , & socket_addr. addr as * const _ as * const _ , socket_addr. len as _ ) ) ?;
110
+ cvt ( libc:: bind (
111
+ * inner. as_inner ( ) ,
112
+ & socket_addr. addr as * const _ as * const _ ,
113
+ socket_addr. len as _ ,
114
+ ) ) ?;
111
115
cvt ( libc:: listen ( * inner. as_inner ( ) , 128 ) ) ?;
112
116
113
117
Ok ( UnixListener ( inner) )
114
118
}
115
119
}
116
120
117
-
118
121
/// Accepts a new incoming connection to this listener.
119
122
///
120
123
/// This function will block the calling thread until a new Unix connection
Original file line number Diff line number Diff line change @@ -130,7 +130,11 @@ impl UnixStream {
130
130
pub fn connect_addr ( socket_addr : & SocketAddr ) -> io:: Result < UnixStream > {
131
131
unsafe {
132
132
let inner = Socket :: new_raw ( libc:: AF_UNIX , libc:: SOCK_STREAM ) ?;
133
- cvt ( libc:: connect ( * inner. as_inner ( ) , & socket_addr. addr as * const _ as * const _ , socket_addr. len ) ) ?;
133
+ cvt ( libc:: connect (
134
+ * inner. as_inner ( ) ,
135
+ & socket_addr. addr as * const _ as * const _ ,
136
+ socket_addr. len ,
137
+ ) ) ?;
134
138
Ok ( UnixStream ( inner) )
135
139
}
136
140
}
You can’t perform that action at this time.
0 commit comments