From 590e4e5bc7522e5868b1bf9a51ae07d4510e402b Mon Sep 17 00:00:00 2001
From: Sven Rebhan <36194019+srebhan@users.noreply.github.com>
Date: Fri, 30 Jun 2023 18:27:25 +0200
Subject: [PATCH] fix(inputs.cloud_pubsub): Properly lock for decompression
 (#13525)

---
 plugins/inputs/cloud_pubsub/cloud_pubsub.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/plugins/inputs/cloud_pubsub/cloud_pubsub.go b/plugins/inputs/cloud_pubsub/cloud_pubsub.go
index ca763c1e3..a232300e1 100644
--- a/plugins/inputs/cloud_pubsub/cloud_pubsub.go
+++ b/plugins/inputs/cloud_pubsub/cloud_pubsub.go
@@ -217,12 +217,11 @@ func (ps *PubSub) decompressData(data []byte) ([]byte, error) {
 	}
 
 	ps.decoderMutex.Lock()
+	defer ps.decoderMutex.Unlock()
 	data, err := ps.decoder.Decode(data)
 	if err != nil {
-		ps.decoderMutex.Unlock()
 		return nil, err
 	}
-	ps.decoderMutex.Unlock()
 
 	decompressedData := make([]byte, len(data))
 	copy(decompressedData, data)