fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-29 18:51:22 +00:00
Code Issues Projects Releases Wiki Activity

Remove exposed unimplemented!() in the Kad server (#298)

Browse Source
This commit is contained in:
Pierre Krieger 2018-07-14 13:58:16 +02:00 committed by GitHub
parent 4592d1b21e
commit 7c71ffddb2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
kad/src/kad_server.rs
View File

@ -383,10 +383,16 @@ where
Box::new(future) Box::new(future)
} }
Some(EventSource::Remote(KadMsg::GetValueReq { .. })) => { Some(EventSource::Remote(KadMsg::GetValueReq { .. })) => {
unimplemented!() // FIXME: warn!("GET_VALUE requests are not implemented yet");
let future = future::err(IoError::new(IoErrorKind::Other,
"GET_VALUE requests are not implemented yet"));
return Box::new(future);
} }
Some(EventSource::Remote(KadMsg::PutValue { .. })) => { Some(EventSource::Remote(KadMsg::PutValue { .. })) => {
unimplemented!() // FIXME: warn!("PUT_VALUE requests are not implemented yet");
let state = (events, kad_sink, responders_tx, send_back_queue, expected_pongs, finished);
let future = future::ok((None, state));
return Box::new(future);
} }
} }
})) }))

2
kad/src/protocol.rs
View File

@ -227,7 +227,7 @@ fn msg_to_proto(kad_msg: KadMsg) -> protobuf_structs::dht::Message {
msg.set_clusterLevelRaw(10); msg.set_clusterLevelRaw(10);
msg msg
} }
KadMsg::GetValueRes { .. } => unimplemented!(), KadMsg::GetValueRes { .. } => unimplemented!(), // TODO:
KadMsg::FindNodeReq { key } => { KadMsg::FindNodeReq { key } => {
let mut msg = protobuf_structs::dht::Message::new(); let mut msg = protobuf_structs::dht::Message::new();
msg.set_field_type(protobuf_structs::dht::Message_MessageType::FIND_NODE); msg.set_field_type(protobuf_structs::dht::Message_MessageType::FIND_NODE);