Skip to content

Commit 2f63262

Browse files
committed
Added timeouts to sockets
1 parent 38ebc52 commit 2f63262

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/host/remote.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,14 +45,16 @@ impl Host {
4545
let api_sock = ZSock::new(ZSockType::REQ);
4646
user_cert.apply(&api_sock);
4747
api_sock.set_curve_serverkey(server_cert.public_txt());
48-
api_sock.set_linger(5000);
48+
api_sock.set_sndtimeo(Some(5000));
49+
api_sock.set_rcvtimeo(Some(5000));
4950
try!(api_sock.connect(&format!("tcp://{}:{}", hostname, api_port)));
5051
self.api_sock = Some(api_sock);
5152

5253
let file_sock = ZSock::new(ZSockType::DEALER);
5354
user_cert.apply(&file_sock);
5455
file_sock.set_curve_serverkey(server_cert.public_txt());
55-
file_sock.set_linger(5000);
56+
file_sock.set_sndtimeo(Some(5000));
57+
file_sock.set_rcvtimeo(Some(5000));
5658
try!(file_sock.connect(&format!("tcp://{}:{}", hostname, file_port)));
5759
self.file_sock = Some(file_sock);
5860

0 commit comments

Comments
 (0)