about summary refs log tree commit diff
path: root/src/libstd/net_tcp.rs
diff options
context:
space:
mode:
authorJeff Olson <olson.jeffery@gmail.com>2012-05-21 06:45:18 -0700
committerBrian Anderson <banderson@mozilla.com>2012-05-22 22:29:17 -0700
commit9b1035904152ab5e12f08f5e5353c4af33368dcd (patch)
tree89899f35abfceabef2aa54559c177c44b3b7a9e9 /src/libstd/net_tcp.rs
parent7de1a68217767eaedc7c192301c3814eea8c7a5e (diff)
downloadrust-9b1035904152ab5e12f08f5e5353c4af33368dcd.tar.gz
rust-9b1035904152ab5e12f08f5e5353c4af33368dcd.zip
std: several minor cleanups wrt codereview.. see extended comments
* there are a few places where I was experimenting w/ using `alt` in places
where `if`/`else` would've sufficed. don't drink the koolaid!
* I had an unneeded `else` structure (the `if` branch that preceeded
concluded with a `fail` statement.. I added the `fail` later in the dev
cycle for this branch, so I forgot to remove the `else` after doing so)
* consistent wrt `prop_name: value` vs. `prop_name : value` in record decl
and initialization
* change an `alt` exp on an `ip_addr` to actually be exhaustive,
instead of using a catch-all clause
Diffstat (limited to 'src/libstd/net_tcp.rs')
-rw-r--r--src/libstd/net_tcp.rs57
1 files changed, 26 insertions, 31 deletions
diff --git a/src/libstd/net_tcp.rs b/src/libstd/net_tcp.rs
index ef21baea982..632c901f694 100644
--- a/src/libstd/net_tcp.rs
+++ b/src/libstd/net_tcp.rs
@@ -107,9 +107,9 @@ fn connect(input_ip: ip::ip_addr, port: uint)
     let socket_data = @{
         reader_po: reader_po,
         reader_ch: comm::chan(reader_po),
-        stream_handle_ptr : stream_handle_ptr,
-        connect_req : uv::ll::connect_t(),
-        write_req : uv::ll::write_t(),
+        stream_handle_ptr: stream_handle_ptr,
+        connect_req: uv::ll::connect_t(),
+        write_req: uv::ll::write_t(),
         hl_loop: hl_loop
     };
     let socket_data_ptr = ptr::addr_of(*socket_data);
@@ -523,13 +523,14 @@ net::tcp::listen(remote_ip, remote_port, backlog) {|new_conn, kill_ch|
     let cont_ch = comm::chan(cont_po);
     task::spawn {||
         let accept_result = net::tcp::accept(new_conn);
-        alt accept_result.is_failure() {
-          false { comm::send(cont_ch, result::get_err(accept_result)); }
-          true {
+        if accept_result.is_failure() {
+            comm::send(cont_ch, result::get_err(accept_result));
+            // fail?
+        }
+        else {
             let sock = result::get(accept_result);
             comm::send(cont_ch, true);
             // do work here
-          }
         }
     };
     alt comm::recv(cont_po) {
@@ -841,8 +842,7 @@ crust fn tcp_lfc_on_connection_cb(handle: *uv::ll::uv_tcp_t,
     let server_data_ptr = uv::ll::get_data_for_uv_handle(handle)
         as *tcp_listen_fc_data;
     let kill_ch = (*server_data_ptr).kill_ch;
-    alt (*server_data_ptr).active {
-      true {
+    if (*server_data_ptr).active {
         alt status {
           0i32 {
             let new_conn = new_tcp_conn(handle);
@@ -856,9 +856,6 @@ crust fn tcp_lfc_on_connection_cb(handle: *uv::ll::uv_tcp_t,
             (*server_data_ptr).active = false;
           }
         }
-      }
-      _ {
-      }
     }
 }
 
@@ -1101,7 +1098,7 @@ fn ipv4_ip_addr_to_sockaddr_in(input_ip: ip::ip_addr,
       ip::ipv4(_,_,_,_) {
         uv::ll::ip4_addr(ip::format_addr(input_ip), port as int)
       }
-      _ {
+      ip::ipv6(_,_,_,_,_,_,_,_) {
         fail "FIXME ipv6 not yet supported";
       }
     }
@@ -1324,24 +1321,22 @@ mod test {
                                 err_data.err_name, err_data.err_msg));
                 fail "couldn't recv new conn";
             }
-            else {
-                let sock = result::unwrap(new_conn_result);
-                log(debug, "SERVER: successfully accepted"+
-                    "connection!");
-                let received_req_bytes =
-                    tcp_read_single(sock);
-                alt received_req_bytes {
-                  result::ok(data) {
-                    server_ch.send(
-                        str::from_bytes(data));
-                    log(debug, "SERVER: before write");
-                    tcp_write_single(sock, str::bytes(resp));
-                    log(debug, "SERVER: after write.. die");
-                  }
-                  result::err(err_data) {
-                    server_ch.send("");
-                  }
-                }
+            let sock = result::unwrap(new_conn_result);
+            log(debug, "SERVER: successfully accepted"+
+                "connection!");
+            let received_req_bytes =
+                tcp_read_single(sock);
+            alt received_req_bytes {
+              result::ok(data) {
+                server_ch.send(
+                    str::from_bytes(data));
+                log(debug, "SERVER: before write");
+                tcp_write_single(sock, str::bytes(resp));
+                log(debug, "SERVER: after write.. die");
+              }
+              result::err(err_data) {
+                server_ch.send("");
+              }
             }
         };
         let ret_val = server_ch.recv();