Skip to content

Commit 54487d0

Browse files
fix: replace panic unwrap with error check in cluster.rs (tikv#504) (tikv#508)
closes tikv#504 Signed-off-by: Saathwik Dasari <saathwik.dasari@gmail.com>
1 parent 6fd16c9 commit 54487d0

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

src/pd/cluster.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,11 @@ impl Connection {
319319

320320
// Then try to connect the PD cluster leader.
321321
if let Some(resp) = resp {
322-
let leader = resp.leader.as_ref().unwrap();
322+
let leader = resp
323+
.leader
324+
.as_ref()
325+
.ok_or_else(|| internal_err!("no leader found in GetMembersResponse"))?;
326+
323327
for ep in &leader.client_urls {
324328
if let Ok((client, keyspace_client, members)) =
325329
self.try_connect(ep.as_str(), cluster_id, timeout).await

0 commit comments

Comments
 (0)