Skip to content

Commit c9ced85

Browse files
committed
Auto merge of #77626 - tamird:parse-scope-id, r=dtolnay
Parse SocketAddrV6::scope_id r? `@dtolnay`
2 parents 5779815 + 49ade22 commit c9ced85

File tree

2 files changed

+27
-13
lines changed

2 files changed

+27
-13
lines changed

library/std/src/net/parser.rs

+23-11
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ macro_rules! impl_helper {
3232
})*)
3333
}
3434

35-
impl_helper! { u8 u16 }
35+
impl_helper! { u8 u16 u32 }
3636

3737
struct Parser<'a> {
3838
// parsing as ASCII, so can use byte array
@@ -75,9 +75,12 @@ impl<'a> Parser<'a> {
7575
})
7676
}
7777

78-
/// Read the next character from the input if it matches the target
79-
fn read_given_char(&mut self, target: char) -> Option<char> {
80-
self.read_atomically(|p| p.read_char().filter(|&c| c == target))
78+
#[must_use]
79+
/// Read the next character from the input if it matches the target.
80+
fn read_given_char(&mut self, target: char) -> Option<()> {
81+
self.read_atomically(|p| {
82+
p.read_char().and_then(|c| if c == target { Some(()) } else { None })
83+
})
8184
}
8285

8386
/// Helper for reading separators in an indexed loop. Reads the separator
@@ -90,7 +93,7 @@ impl<'a> Parser<'a> {
9093
{
9194
self.read_atomically(move |p| {
9295
if index > 0 {
93-
let _ = p.read_given_char(sep)?;
96+
p.read_given_char(sep)?;
9497
}
9598
inner(p)
9699
})
@@ -187,8 +190,8 @@ impl<'a> Parser<'a> {
187190

188191
// read `::` if previous code parsed less than 8 groups
189192
// `::` indicates one or more groups of 16 bits of zeros
190-
let _ = p.read_given_char(':')?;
191-
let _ = p.read_given_char(':')?;
193+
p.read_given_char(':')?;
194+
p.read_given_char(':')?;
192195

193196
// Read the back part of the address. The :: must contain at least one
194197
// set of zeroes, so our max length is 7.
@@ -211,7 +214,15 @@ impl<'a> Parser<'a> {
211214
/// Read a : followed by a port in base 10.
212215
fn read_port(&mut self) -> Option<u16> {
213216
self.read_atomically(|p| {
214-
let _ = p.read_given_char(':')?;
217+
p.read_given_char(':')?;
218+
p.read_number(10, None)
219+
})
220+
}
221+
222+
/// Read a % followed by a scope id in base 10.
223+
fn read_scope_id(&mut self) -> Option<u32> {
224+
self.read_atomically(|p| {
225+
p.read_given_char('%')?;
215226
p.read_number(10, None)
216227
})
217228
}
@@ -228,12 +239,13 @@ impl<'a> Parser<'a> {
228239
/// Read an IPV6 address with a port
229240
fn read_socket_addr_v6(&mut self) -> Option<SocketAddrV6> {
230241
self.read_atomically(|p| {
231-
let _ = p.read_given_char('[')?;
242+
p.read_given_char('[')?;
232243
let ip = p.read_ipv6_addr()?;
233-
let _ = p.read_given_char(']')?;
244+
let scope_id = p.read_scope_id().unwrap_or(0);
245+
p.read_given_char(']')?;
234246

235247
let port = p.read_port()?;
236-
Some(SocketAddrV6::new(ip, port, 0, 0))
248+
Some(SocketAddrV6::new(ip, port, 0, scope_id))
237249
})
238250
}
239251

library/std/src/net/parser/tests.rs

+4-2
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ use crate::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr, SocketAddrV4, SocketAdd
33
use crate::str::FromStr;
44

55
const PORT: u16 = 8080;
6+
const SCOPE_ID: u32 = 1337;
67

78
const IPV4: Ipv4Addr = Ipv4Addr::new(192, 168, 0, 1);
89
const IPV4_STR: &str = "192.168.0.1";
@@ -13,6 +14,7 @@ const IPV6_STR_FULL: &str = "2001:db8:0:0:0:0:c0a8:1";
1314
const IPV6_STR_COMPRESS: &str = "2001:db8::c0a8:1";
1415
const IPV6_STR_V4: &str = "2001:db8::192.168.0.1";
1516
const IPV6_STR_PORT: &str = "[2001:db8::c0a8:1]:8080";
17+
const IPV6_STR_PORT_SCOPE_ID: &str = "[2001:db8::c0a8:1%1337]:8080";
1618

1719
#[test]
1820
fn parse_ipv4() {
@@ -74,8 +76,8 @@ fn parse_socket_v4() {
7476

7577
#[test]
7678
fn parse_socket_v6() {
77-
let result: SocketAddrV6 = IPV6_STR_PORT.parse().unwrap();
78-
assert_eq!(result, SocketAddrV6::new(IPV6, PORT, 0, 0));
79+
assert_eq!(IPV6_STR_PORT.parse(), Ok(SocketAddrV6::new(IPV6, PORT, 0, 0)));
80+
assert_eq!(IPV6_STR_PORT_SCOPE_ID.parse(), Ok(SocketAddrV6::new(IPV6, PORT, 0, SCOPE_ID)));
7981

8082
assert!(SocketAddrV6::from_str(IPV4_STR).is_err());
8183
assert!(SocketAddrV6::from_str(IPV4_STR_PORT).is_err());

0 commit comments

Comments
 (0)