X-Git-Url: http://git.euphorik.ch/?p=crypto_lab1.git;a=blobdiff_plain;f=src%2Fend_point.rs;h=2d0a66c9e09815cc76a7fffb2efa176ef43dbab8;hp=71f217e9d428be7923f4af5f0de4b5f78e1ef814;hb=c9318a07ce0ec00f999ff17943b83048d536ecd1;hpb=148adf7e5ffe25dba11e00b17b29e4eeacec4d3d diff --git a/src/end_point.rs b/src/end_point.rs index 71f217e..2d0a66c 100644 --- a/src/end_point.rs +++ b/src/end_point.rs @@ -15,7 +15,7 @@ pub struct Client { end_point: EndPoint, } -struct EndPoint { +pub struct EndPoint { socket: TcpStream, current_timestamp: u64 } @@ -33,7 +33,7 @@ impl Server { for stream in acceptor.incoming() { match stream { Ok(stream) => spawn(proc() { - Server::handle_client(EndPoint { socket: stream, current_timestamp: 0 }); + Server::handle_client(EndPoint::new(stream)); }), _ => return } @@ -246,6 +246,10 @@ impl Client { } impl EndPoint { + pub fn new(socket: TcpStream) -> EndPoint { + EndPoint { socket: socket, current_timestamp: 0 } + } + fn close(&mut self) -> IoResult<()> { try!(self.socket.close_read()); try!(self.socket.close_write());