@@ -192,6 +192,7 @@ client::CancellationToken VolatileLayerClientImpl::GetBaseVersion(
192192 " Operation cancelled." , true ));
193193 };
194194
195+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
195196 auto getBaseVersion_callback =
196197 [=](MetadataApi::CatalogVersionResponse response) {
197198 self->tokenList_ .RemoveTask (id);
@@ -209,12 +210,14 @@ client::CancellationToken VolatileLayerClientImpl::GetBaseVersion(
209210 }
210211 };
211212
213+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
212214 auto getBaseVersion_function = [=]() -> client::CancellationToken {
213215 return MetadataApi::GetLatestCatalogVersion (*self->apiclient_metadata_ , -1 ,
214216 olp::porting::none,
215217 getBaseVersion_callback);
216218 };
217219
220+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
218221 cancel_context->ExecuteOrCancelled (
219222 [=]() -> client::CancellationToken {
220223 return self->InitApiClients (
@@ -264,6 +267,7 @@ client::CancellationToken VolatileLayerClientImpl::StartBatch(
264267 }
265268 };
266269
270+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
267271 auto init_publication_function = [=]() -> client::CancellationToken {
268272 model::Publication pub;
269273 pub.SetLayerIds (request.GetLayers ().value_or (std::vector<std::string>()));
@@ -275,12 +279,14 @@ client::CancellationToken VolatileLayerClientImpl::StartBatch(
275279 init_publication_callback);
276280 };
277281
282+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
278283 auto cancel_function = [=]() {
279284 self->tokenList_ .RemoveTask (id);
280285 callback (client::ApiError (client::ErrorCode::Cancelled,
281286 " Operation cancelled." , true ));
282287 };
283288
289+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
284290 cancel_context->ExecuteOrCancelled (
285291 [=]() -> client::CancellationToken {
286292 return self->InitApiClients (
@@ -425,6 +431,7 @@ client::CancellationToken VolatileLayerClientImpl::GetBatch(
425431 " Operation cancelled." , true ));
426432 };
427433
434+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
428435 auto getPublication_callback =
429436 [=](GetPublicationResponse getPublicationResponse) {
430437 self->tokenList_ .RemoveTask (id);
@@ -435,12 +442,14 @@ client::CancellationToken VolatileLayerClientImpl::GetBatch(
435442 }
436443 };
437444
445+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
438446 auto getPublication_function = [=]() -> client::CancellationToken {
439447 return PublishApi::GetPublication (*self->apiclient_publish_ , publicationId,
440448 olp::porting::none,
441449 getPublication_callback);
442450 };
443451
452+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
444453 cancel_context->ExecuteOrCancelled (
445454 [=]() -> client::CancellationToken {
446455 return self->InitApiClients (
@@ -572,12 +581,14 @@ client::CancellationToken VolatileLayerClientImpl::PublishToBatch(
572581 auto self = shared_from_this ();
573582 auto id = tokenList_.GetNextId ();
574583
584+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
575585 auto cancel_function = [=]() {
576586 self->tokenList_ .RemoveTask (id);
577587 callback (client::ApiError (client::ErrorCode::Cancelled,
578588 " Operation cancelled." , true ));
579589 };
580590
591+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
581592 auto upload_partitions_callback =
582593 [=](UploadPartitionsResponse upload_partitions_response) {
583594 self->tokenList_ .RemoveTask (id);
@@ -588,6 +599,7 @@ client::CancellationToken VolatileLayerClientImpl::PublishToBatch(
588599 }
589600 };
590601
602+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
591603 auto upload_partitions_function = [=]() -> client::CancellationToken {
592604 std::vector<model::PublishPartition> pub_partition_list;
593605 for (const auto & partition_request : partitions) {
@@ -610,6 +622,7 @@ client::CancellationToken VolatileLayerClientImpl::PublishToBatch(
610622 upload_partitions_callback);
611623 };
612624
625+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
613626 cancel_context->ExecuteOrCancelled (
614627 [=]() -> client::CancellationToken {
615628 return self->InitApiClients (
@@ -654,12 +667,14 @@ client::CancellationToken VolatileLayerClientImpl::CompleteBatch(
654667 auto self = shared_from_this ();
655668 auto cancel_context = std::make_shared<client::CancellationContext>();
656669 auto id = tokenList_.GetNextId ();
670+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
657671 auto cancel_function = [=]() {
658672 self->tokenList_ .RemoveTask (id);
659673 callback (client::ApiError (client::ErrorCode::Cancelled,
660674 " Operation cancelled." , true ));
661675 };
662676
677+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
663678 auto completePublication_callback =
664679 [=](SubmitPublicationResponse submitPublicationResponse) {
665680 self->tokenList_ .RemoveTask (id);
@@ -670,12 +685,14 @@ client::CancellationToken VolatileLayerClientImpl::CompleteBatch(
670685 }
671686 };
672687
688+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
673689 auto completePublication_function = [=]() -> client::CancellationToken {
674690 return PublishApi::SubmitPublication (*self->apiclient_publish_ ,
675691 publicationId, olp::porting::none,
676692 completePublication_callback);
677693 };
678694
695+ // NOLINTNEXTLINE(clang-analyzer-cplusplus.NewDeleteLeaks): false
679696 cancel_context->ExecuteOrCancelled (
680697 [=]() -> client::CancellationToken {
681698 return self->InitApiClients (
0 commit comments