grpc/otel: handle credentials creation error

Signed-off-by: Attila Szakacs <[email protected]>

Author: alltilla

modules/grpc/otel/otel-dest-worker.cpp

@@ -47,6 +47,14 @@ DestWorker::DestWorker(GrpcDestWorker *s)
     formatter(s->super.owner->super.super.super.cfg)
 {
   std::shared_ptr<::grpc::ChannelCredentials> credentials = DestWorker::create_credentials();
+  if (!credentials)
+    {
+      msg_error("Error querying OTel credentials",
+                evt_tag_str("url", this->owner.get_url().c_str()),
+                log_pipe_location_tag((LogPipe *) this->super->super.owner));
+      throw std::runtime_error("Error querying OTel credentials");
+    }
+
   ::grpc::ChannelArguments args = this->create_channel_args();
 
   channel = ::grpc::CreateCustomChannel(owner.get_url(), credentials, args);

modules/grpc/otel/otel-dest.cpp

@@ -56,7 +56,15 @@ LogThreadedDestWorker *
 DestDriver::construct_worker(int worker_index)
 {
   GrpcDestWorker *worker = grpc_dw_new(this->super, worker_index);
-  worker->cpp = new DestWorker(worker);
+  try
+    {
+      worker->cpp = new DestWorker(worker);
+    }
+  catch (const std::runtime_error &e)
+    {
+      log_threaded_dest_worker_free(&worker->super);
+      return NULL;
+    }
   return &worker->super;
 }