diff options
author | bnewbold <bnewbold@robocracy.org> | 2016-05-29 15:33:04 -0400 |
---|---|---|
committer | bnewbold <bnewbold@robocracy.org> | 2016-05-29 15:33:04 -0400 |
commit | 223da5cfea8608f7b11f32720203a2704dd02601 (patch) | |
tree | a03b59582f29488fb52fcba7485b8da276339da9 /src/client.rs | |
parent | a7b4e46f76ec70f71a189a1f3fbbd30370d82b4f (diff) | |
download | ucp-223da5cfea8608f7b11f32720203a2704dd02601.tar.gz ucp-223da5cfea8608f7b11f32720203a2704dd02601.zip |
fix module hierarchy; actually call common functions
Diffstat (limited to 'src/client.rs')
-rw-r--r-- | src/client.rs | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/src/client.rs b/src/client.rs index 9687488..a2ebf27 100644 --- a/src/client.rs +++ b/src/client.rs @@ -1,6 +1,8 @@ extern crate utp; +use super::common; + use std::string::String; use std::env; use std::process; @@ -46,12 +48,11 @@ pub fn run_client(host: &str, local_file: &str, remote_file: &str, remote_is_dir println!("\thost: {}", remote_host); println!("\tsecret: {}", remote_secret); - let mut buf = [0; 2000]; let mut socket = UtpSocket::connect((remote_host, remote_port)).unwrap();; - socket.send_to("PING".as_bytes()); - socket.flush(); - let (amt, _src) = socket.recv_from(&mut buf).ok().unwrap(); - let reply = String::from_utf8_lossy(&buf[..amt]); - println!("Got uTP reply: {}", reply); - socket.close(); + if is_recv { + common::receive_files(&mut socket, local_file, remote_is_dir); + } else { + common::send_files(&mut socket, local_file, remote_is_dir); + } + socket.close().unwrap(); } |