Skip to content

Commit 54fd720

Browse files
authored
pd: handle get members with error (#452)
1 parent 0db723f commit 54fd720

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

src/pd/cluster.rs

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,6 +234,19 @@ impl Connection {
234234
.get_members(pdpb::GetMembersRequest::default())
235235
.await?
236236
.into_inner();
237+
if let Some(err) = resp
238+
.header
239+
.as_ref()
240+
.and_then(|header| header.error.as_ref())
241+
{
242+
return Err(internal_err!("failed to get PD members, err {:?}", err));
243+
}
244+
if resp.leader.is_none() {
245+
return Err(internal_err!(
246+
"unexpected no PD leader in get member resp: {:?}",
247+
resp
248+
));
249+
}
237250
Ok((client, keyspace_client, resp))
238251
}
239252

0 commit comments

Comments
 (0)