docker/pgcat
1
0
Fork 0
mirror of https://github.com/postgresml/pgcat.git synced 2026-03-27 02:36:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Main Thread Panic when swarmed with clients (#158)

Browse Source 
* Main Thread Panic when swarmed with clients

* fix

* fix

* 1024

* fix

* remove test

* Update src/client.rs

* Update src/main.rs

* Update src/client.rs

* Update src/main.rs

Co-authored-by: Lev Kokotov <levkk@users.noreply.github.com>
This commit is contained in:
Mostafa Abdelraouf
2022-09-05 03:21:06 -05:00
committed by GitHub
parent 417358c35d
commit 976b406468
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/client.rs
View File

@@ -95,7 +95,7 @@ pub async fn client_entrypoint(
mut stream: TcpStream, mut stream: TcpStream,
client_server_map: ClientServerMap, client_server_map: ClientServerMap,
shutdown: Receiver<()>, shutdown: Receiver<()>,
drain: Sender<i8>, drain: Sender<i32>,
admin_only: bool, admin_only: bool,
) -> Result<(), Error> { ) -> Result<(), Error> {
// Figure out if the client wants TLS or not. // Figure out if the client wants TLS or not.

2
src/main.rs
View File

@@ -178,7 +178,7 @@ async fn main() {
let mut interrupt_signal = unix_signal(SignalKind::interrupt()).unwrap(); let mut interrupt_signal = unix_signal(SignalKind::interrupt()).unwrap();
let mut sighup_signal = unix_signal(SignalKind::hangup()).unwrap(); let mut sighup_signal = unix_signal(SignalKind::hangup()).unwrap();
let (shutdown_tx, _) = broadcast::channel::<()>(1); let (shutdown_tx, _) = broadcast::channel::<()>(1);
let (drain_tx, mut drain_rx) = mpsc::channel::<i8>(2048); let (drain_tx, mut drain_rx) = mpsc::channel::<i32>(2048);
let (exit_tx, mut exit_rx) = mpsc::channel::<()>(1); let (exit_tx, mut exit_rx) = mpsc::channel::<()>(1);
info!("Waiting for clients"); info!("Waiting for clients");