@@ -241,12 +241,13 @@ where
241
241
validate_buffering_configuration ( self . log_buffering ) ?;
242
242
243
243
let addr = SocketAddr :: from ( ( [ 0 , 0 , 0 , 0 ] , self . log_port_number ) ) ;
244
+ let service = log_processor. make_service ( ( ) ) ;
245
+ let service = Arc :: new ( Mutex :: new ( service. await . unwrap ( ) ) ) ;
244
246
tokio:: task:: spawn ( async move {
245
247
trace ! ( "Creating new logs processor Service" ) ;
246
248
247
249
loop {
248
- let service = log_processor. make_service ( ( ) ) ;
249
- let service = Arc :: new ( Mutex :: new ( service. await . unwrap ( ) ) ) ;
250
+ let service: Arc < Mutex < _ > > = service. clone ( ) ;
250
251
let make_service = service_fn ( move |req : Request < Incoming > | log_wrapper ( service. clone ( ) , req) ) ;
251
252
252
253
let listener = TcpListener :: bind ( addr) . await . unwrap ( ) ;
@@ -285,23 +286,14 @@ where
285
286
286
287
validate_buffering_configuration ( self . telemetry_buffering ) ?;
287
288
288
- // Spawn task to run processor
289
- // let make_service = service_fn(move |_socket: &AddrStream| {
290
- // trace!("Creating new telemetry processor Service");
291
- // let service = telemetry_processor.make_service(());
292
- // async move {
293
- // let service = Arc::new(Mutex::new(service.await?));
294
- // Ok::<_, T::MakeError>(service_fn(move |req| telemetry_wrapper(service.clone(), req)))
295
- // }
296
- // });
297
-
298
289
let addr = SocketAddr :: from ( ( [ 0 , 0 , 0 , 0 ] , self . telemetry_port_number ) ) ;
290
+ let service = telemetry_processor. make_service ( ( ) ) ;
291
+ let service = Arc :: new ( Mutex :: new ( service. await . unwrap ( ) ) ) ;
299
292
tokio:: task:: spawn ( async move {
300
293
trace ! ( "Creating new telemetry processor Service" ) ;
301
294
302
295
loop {
303
- let service = telemetry_processor. make_service ( ( ) ) ;
304
- let service = Arc :: new ( Mutex :: new ( service. await . unwrap ( ) ) ) ;
296
+ let service = service. clone ( ) ;
305
297
let make_service = service_fn ( move |req| telemetry_wrapper ( service. clone ( ) , req) ) ;
306
298
307
299
let listener = TcpListener :: bind ( addr) . await . unwrap ( ) ;
0 commit comments