File tree Expand file tree Collapse file tree 1 file changed +11
-0
lines changed
Expand file tree Collapse file tree 1 file changed +11
-0
lines changed Original file line number Diff line number Diff line change @@ -107,6 +107,8 @@ impl LambdaRequest {
107107 // Startup the request channels
108108 let channel_futures = ( 0 ..self . channel_count )
109109 . map ( |channel_number| {
110+ let router_endpoint_url = self . router_endpoint . url ( ) . clone ( ) ;
111+ let lambda_id = Arc :: clone ( & self . lambda_id ) ;
110112 let last_active = Arc :: clone ( & self . last_active ) ;
111113 // Create a JoinHandle and implicitly return it to be collected in the vector
112114 let mut router_channel = RouterChannel :: new (
@@ -133,6 +135,15 @@ impl LambdaRequest {
133135 . start ( app_client. clone ( ) , router_client. clone ( ) )
134136 . await ;
135137
138+ // If we failed to connect to the router we should log our IP, router IP, port and protocol
139+ if let Err ( LambdaRequestError :: RouterUnreachable ) = result {
140+ log:: error!(
141+ "LambdaId: {} - start - Failed to connect to router: {}" ,
142+ lambda_id,
143+ router_endpoint_url
144+ ) ;
145+ }
146+
136147 // Tell the other channels to stop
137148 goaway_received. store ( true , Ordering :: Release ) ;
138149
You can’t perform that action at this time.
0 commit comments