Fixes for previous release2.
This commit is contained in:
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "alfis"
|
name = "alfis"
|
||||||
version = "0.4.28"
|
version = "0.4.29"
|
||||||
authors = ["Revertron <alfis@revertron.com>"]
|
authors = ["Revertron <alfis@revertron.com>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
build = "build.rs"
|
build = "build.rs"
|
||||||
|
|||||||
+1
-1
@@ -356,7 +356,7 @@ fn read_message(stream: &mut TcpStream) -> Result<Vec<u8>, ()> {
|
|||||||
// We give every connection no more than 200ms to read a message
|
// We give every connection no more than 200ms to read a message
|
||||||
if instant.elapsed().as_millis() < MAX_READ_BLOCK_TIME {
|
if instant.elapsed().as_millis() < MAX_READ_BLOCK_TIME {
|
||||||
// We need to sleep a bit, otherwise it can eat CPU
|
// We need to sleep a bit, otherwise it can eat CPU
|
||||||
let delay = Duration::from_millis(10);
|
let delay = Duration::from_millis(2);
|
||||||
thread::sleep(delay);
|
thread::sleep(delay);
|
||||||
continue;
|
continue;
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user