@@ -275,12 +275,6 @@ void CleanupLogger()
275275 opentelemetry::logs::Provider::SetLoggerProvider (noop);
276276}
277277
278- static void init_metrics ()
279- {
280- using namespace opentelemetry ;
281- }
282-
283-
284278void InitMetrics (const std::string &name)
285279{
286280 #if 0
@@ -453,44 +447,43 @@ int main1()
453447 // }
454448 // proxy_thread pA(last, opentelemetry::exporter::otlp::GetOtlpDefaultGrpcEndpoint());
455449// proxy_thread pA(last,"127.0.0.1:4317");
456- // pA.proxy->SetActive( false );
450+ // pA.proxy->SetActive( false );
457451
458452 printf (" starting...\n " );
459- proxy_thread proxy (" 127.0.0.1:4317" , opentelemetry::exporter::otlp::GetOtlpDefaultGrpcEndpoint ());
453+ proxy_thread proxy (" 127.0.0.1:43170" , opentelemetry::exporter::otlp::GetOtlpDefaultGrpcEndpoint ());
454+ proxy.proxy ->SetActive (false );
460455 printf (" started...\n " );
461- // {
462- // using namespace opentelemetry::sdk::common;
463- // setenv( "OTEL_EXPORTER_OTLP_ENDPOINT", "http://127.0.0.1:4317", 1 /* override */ );
464- // }
465456
466- // std::string metrics_name{"malkia_metrics_test"};
467- // InitTracer();
468- // InitLogger();
469- // InitMetrics(metrics_name);
470-
471- // init_metrics();
472- // logs_foo_library();
473- // traces_foo_library();
474- // std::thread counter_example{&metrics_counter_example, metrics_name};
475- // std::thread observable_counter_example{&metrics_observable_counter_example, metrics_name};
476- // std::thread histogram_example{&metrics_histogram_example, metrics_name};
477- // counter_example.join();
478- // observable_counter_example.join();
479- // histogram_example.join();
480- // CleanupMetrics();
481- // CleanupLogger();
482- // CleanupTracer();
483-
484- printf (" Press Ctrl+C to break\n " );
485- try {
486- printf (" waiting...\n " );
487- std::this_thread::sleep_for (std::chrono::seconds (3600 *10 ));
457+ {
458+ using namespace opentelemetry ::sdk::common;
459+ setenv ( " OTEL_EXPORTER_OTLP_ENDPOINT" , " http://127.0.0.1:43170" , 1 /* override */ );
488460 }
489- catch ( ... )
461+
462+ std::string metrics_name{" malkia_metrics_test" };
463+
464+ InitTracer ();
465+ InitLogger ();
466+ InitMetrics (metrics_name);
467+
468+ for (int i=0 ; i<10000 ; i++)
490469 {
491- printf (" Caught something?\n " );
470+ logs_foo_library ();
471+ traces_foo_library ();
472+ if ( i % 100 == 0 )
473+ {
474+ std::thread counter_example{&metrics_counter_example, metrics_name};
475+ std::thread observable_counter_example{&metrics_observable_counter_example, metrics_name};
476+ std::thread histogram_example{&metrics_histogram_example, metrics_name};
477+ counter_example.join ();
478+ observable_counter_example.join ();
479+ histogram_example.join ();
480+ }
492481 }
493482
483+ CleanupMetrics ();
484+ CleanupLogger ();
485+ CleanupTracer ();
486+
494487 return 0 ;
495488}
496489
0 commit comments