diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-06 22:27:51 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-06 22:27:51 +0200 |
| commit | 87f2b4d2fc8835f8adda69adb6b51fd73ffb20a5 (patch) | |
| tree | b28f8e2c585489f51fc083d343179e25d8f8c76a /src/rpc.rs | |
| parent | 3c36b449a3786bb62fa023bde37bac24635b5717 (diff) | |
| download | garage-87f2b4d2fc8835f8adda69adb6b51fd73ffb20a5.tar.gz garage-87f2b4d2fc8835f8adda69adb6b51fd73ffb20a5.zip | |
Ununderstandable error
Diffstat (limited to 'src/rpc.rs')
| -rw-r--r-- | src/rpc.rs | 6 |
1 files changed, 5 insertions, 1 deletions
@@ -133,7 +133,11 @@ async fn handler(sys: Arc<System>, req: Request<Body>, addr: SocketAddr) -> Resu let resp = err_to_msg(match &msg { Message::Ping(ping) => sys.handle_ping(&addr, ping).await, - Message::AdvertiseNode(adv) => sys.handle_advertise_node(adv).await, + Message::PullStatus => sys.handle_pull_status().await, + Message::PullConfig => sys.handle_pull_config().await, + Message::AdvertiseNodesUp(adv) => sys.handle_advertise_nodes_up(adv).await, + Message::AdvertiseConfig(adv) => sys.handle_advertise_config(adv).await, + _ => Ok(Message::Error(format!("Unexpected message: {:?}", msg))), }); |