Searched refs:semaphore_fg (Results 1 – 1 of 1) sorted by relevance
496 let semaphore_fg = Arc::new(tokio::sync::Semaphore::new(1)); in handle_client_command() localVariable504 let semaphore = semaphore_fg.clone(); in handle_client_command()785 semaphore_fg.add_permits(1); in handle_client_command()814 semaphore_fg.add_permits(1); in handle_client_command()820 semaphore_fg.close(); in handle_client_command()