diff options
author | bnewbold <bnewbold@robocracy.org> | 2016-05-29 20:31:09 -0400 |
---|---|---|
committer | bnewbold <bnewbold@robocracy.org> | 2016-05-29 20:31:09 -0400 |
commit | 557159a2e00508820cb7bad66822cc97c61b6de5 (patch) | |
tree | c66589f768cd8da0778b762e3d9c9ff1f17f5123 /src/server.rs | |
parent | 223da5cfea8608f7b11f32720203a2704dd02601 (diff) | |
download | ucp-557159a2e00508820cb7bad66822cc97c61b6de5.tar.gz ucp-557159a2e00508820cb7bad66822cc97c61b6de5.zip |
begin implementation of actual file transfer
Diffstat (limited to 'src/server.rs')
-rw-r--r-- | src/server.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/server.rs b/src/server.rs index e60c054..4c590be 100644 --- a/src/server.rs +++ b/src/server.rs @@ -47,13 +47,14 @@ fn run_server(path: &str, is_recv: bool, recursive: bool) { let (mut socket, _src) = listener.accept().unwrap(); println!("Got connection from {}", socket.peer_addr().unwrap()); + let mut stream = socket.into(); if is_recv { - common::receive_files(&mut socket, path, recursive); + common::sink_files(&mut stream, path, recursive); } else { - common::send_files(&mut socket, path, recursive); + common::source_files(&mut stream, path, recursive); } - socket.close().unwrap(); + stream.close().unwrap(); } fn usage_server(opts: Options) { |