MeexReay/flowgate
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

new version!!!!

Browse Source
This commit is contained in:
MeexReay 2024-10-05 01:13:33 +03:00
parent c864c3d551
commit 5180979d6b
3 changed files with 4 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Cargo.toml
View File

@ -1,11 +1,11 @@
[package] [package]
name = "flowgate" name = "flowgate"
version = "0.1.1" version = "0.1.2"
edition = "2021" edition = "2021"
[dependencies] [dependencies]
openssl = { version = "0.10.66", optional = true } openssl = { version = "0.10.66", optional = true }
rustls = { version = "0.23.13", optional = true } rustls = { version = "0.23.14", optional = true }
rustls-pemfile = { version = "2.2.0", optional = true } rustls-pemfile = { version = "2.2.0", optional = true }
serde_yml = "0.0.12" serde_yml = "0.0.12"
log = "0.4.22" log = "0.4.22"

4
conf.yml
View File

@ -1,5 +1,5 @@
http_host: localhost:80 # Http server host http_host: localhost:80 # Http server host
https_host: localhost:443 # Https server host https_host: localhost:443 # Https server host
threadpool_size: 10 # Threadpool size (count of threads that accept requests) (optional, default - 10) threadpool_size: 10 # Threadpool size (count of threads that accept requests) (optional, default - 10)
connection_timeout: 10 # Read and write timeout of connections in seconds (optional, default - 10) connection_timeout: 10 # Read and write timeout of connections in seconds (optional, default - 10)

14
src/flowgate/server.rs
View File

@ -191,20 +191,6 @@ impl FlowgateServer {
addr: SocketAddr, addr: SocketAddr,
https: bool https: bool
) -> Option<()> { ) -> Option<()> {
// let mut head: Vec<u8> = Vec::new();
// for char in stream.bytes() {
// if let Ok(char) = char {
// if char == b'\n' && &head[head.len()-3..] == b"\r\n\r" {
// head = head[..head.len()-3].to_vec();
// break;
// }
// head.push(char);
// } else {
// return None;
// }
// }
let mut connected = Self::read_request(config.clone(), stream, addr, https, None)?; let mut connected = Self::read_request(config.clone(), stream, addr, https, None)?;
if connected.2 && connected.1.enable_keep_alive { if connected.2 && connected.1.enable_keep_alive {