@@ -324,29 +324,22 @@ static int build_payload_for_route(struct flb_route_payload *payload,
324324 uint8_t * matched_non_default )
325325{
326326 size_t i ;
327- int matched ;
328327 int ret ;
328+ int condition_result ;
329+ int matched ;
329330 struct flb_condition * compiled ;
330331 struct flb_log_event_encoder * encoder ;
331332
332333 if (!payload || !records || record_count == 0 || !matched_non_default ) {
333334 return -1 ;
334335 }
335336
336- flb_info ("[router] build_payload_for_route called for route '%s' with %zu records" ,
337- payload -> route -> name , record_count );
338-
339- flb_info ("[router] route condition: %p, per_record_routing: %d" ,
340- payload -> route -> condition , payload -> route -> per_record_routing );
341337
342338 compiled = flb_router_route_get_condition (payload -> route );
343339 if (!compiled ) {
344- flb_info ("[router] no compiled condition found for route '%s'" , payload -> route -> name );
345340 return 0 ;
346341 }
347342
348- flb_info ("[router] compiled condition found for route '%s'" , payload -> route -> name );
349-
350343 encoder = flb_log_event_encoder_create (FLB_LOG_EVENT_FORMAT_DEFAULT );
351344 if (!encoder ) {
352345 return -1 ;
@@ -355,19 +348,11 @@ static int build_payload_for_route(struct flb_route_payload *payload,
355348 matched = 0 ;
356349
357350 for (i = 0 ; i < record_count ; i ++ ) {
358- int condition_result = flb_condition_evaluate (compiled , records [i ]);
359- flb_info ("[router] route '%s' record %zu: condition_result=%d" ,
360- payload -> route -> name , i , condition_result );
361-
351+ condition_result = flb_condition_evaluate (compiled , records [i ]);
362352 if (condition_result != FLB_TRUE ) {
363- flb_info ("[router] route '%s' record %zu: condition failed, skipping" ,
364- payload -> route -> name , i );
365353 continue ;
366354 }
367355
368- flb_info ("[router] route '%s' record %zu: condition matched, adding to payload" ,
369- payload -> route -> name , i );
370-
371356 ret = encode_chunk_record (encoder , records [i ]);
372357 if (ret != 0 ) {
373358 flb_log_event_encoder_destroy (encoder );
@@ -423,22 +408,15 @@ static int build_payload_for_default_route(struct flb_route_payload *payload,
423408 matched = 0 ;
424409
425410 for (i = 0 ; i < record_count ; i ++ ) {
426- flb_info ("[router] default route record %zu: matched_non_default[%zu]=%d" ,
427- i , i , matched_non_default [i ]);
428-
429411 if (matched_non_default [i ]) {
430- flb_info ("[router] default route record %zu: already matched, skipping" , i );
431412 continue ;
432413 }
433414
434415 if (compiled &&
435416 flb_condition_evaluate (compiled , records [i ]) != FLB_TRUE ) {
436- flb_info ("[router] default route record %zu: condition failed, skipping" , i );
437417 continue ;
438418 }
439419
440- flb_info ("[router] default route record %zu: adding to default payload" , i );
441-
442420 ret = encode_chunk_record (encoder , records [i ]);
443421 if (ret != 0 ) {
444422 flb_log_event_encoder_destroy (encoder );
0 commit comments