File tree Expand file tree Collapse file tree 2 files changed +5
-12
lines changed
translator/src/lib/downstream_sv1 Expand file tree Collapse file tree 2 files changed +5
-12
lines changed Original file line number Diff line number Diff line change @@ -9,6 +9,7 @@ use dotenvy::dotenv;
99use tracing:: Level ;
1010use std:: str:: FromStr ;
1111use std:: env;
12+ use tokio:: { signal, select} ;
1213
1314mod args {
1415 use std:: path:: PathBuf ;
@@ -167,16 +168,9 @@ tracing_subscriber::registry()
167168
168169 let pool = PoolSv2 :: new ( config) ;
169170
170- use tokio:: signal:: unix:: { signal, SignalKind } ;
171- let mut sigterm = signal ( SignalKind :: terminate ( ) ) . unwrap ( ) ;
172- let mut sigint = signal ( SignalKind :: interrupt ( ) ) . unwrap ( ) ;
173-
174- tokio:: select! {
175- _ = sigterm. recv( ) => {
176- error!( "Received SIGTERM signal, starting graceful shutdown" ) ;
177- }
178- _ = sigint. recv( ) => {
179- error!( "Received SIGINT signal, starting graceful shutdown" ) ;
171+ select ! {
172+ _ = signal:: ctrl_c( ) => {
173+ error!( "Received Ctrl+C signal, starting graceful shutdown" ) ;
180174 }
181175 result = pool. start( ) => {
182176 if let Err ( e) = result {
Original file line number Diff line number Diff line change @@ -587,12 +587,11 @@ impl IsServer<'static> for Downstream {
587587
588588 let result = client
589589 . post ( & api_url)
590- . header ( "accept" , "text/plain" )
591590 . header ( "X-Api-Key" , api_key)
592591 . header ( "Content-Type" , "application/json" )
593592 . json ( & serde_json:: json!( {
594593 "accountName" : worker_name. split( '.' ) . next( ) . unwrap_or( "" ) . to_string( ) ,
595- "workerNumber " : worker_name. split( '.' ) . nth( 1 ) . unwrap_or( "" ) . to_string( )
594+ "workerName " : worker_name. split( '.' ) . nth( 1 ) . unwrap_or( "" ) . to_string( )
596595 } ) )
597596 . send ( )
598597 . await ;
You can’t perform that action at this time.
0 commit comments