From d289079b1b15286e994bc29b98cd732fc32fb06f Mon Sep 17 00:00:00 2001 From: elinuxhenrik Date: Fri, 5 Nov 2021 08:00:12 +0100 Subject: [PATCH] Fix locking in DMaaP Mediator Producer Issue-ID: NONRTRIC-631 Signed-off-by: elinuxhenrik Change-Id: I38d2255be7f180a10559152c385ee88fc8471ce4 --- dmaap-mediator-producer/internal/jobs/jobs.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dmaap-mediator-producer/internal/jobs/jobs.go b/dmaap-mediator-producer/internal/jobs/jobs.go index b856e296..1c429424 100644 --- a/dmaap-mediator-producer/internal/jobs/jobs.go +++ b/dmaap-mediator-producer/internal/jobs/jobs.go @@ -182,8 +182,6 @@ func (jh *jobHandler) start(mRAddress string) { } func (jh *jobHandler) pollAndDistributeMessages(mRAddress string) { - jh.mu.Lock() - defer jh.mu.Unlock() log.Debugf("Processing jobs for type: %v", jh.typeId) messagesBody, error := restclient.Get(mRAddress+jh.topicUrl, jh.pollClient) if error != nil { @@ -195,6 +193,8 @@ func (jh *jobHandler) pollAndDistributeMessages(mRAddress string) { func (jh *jobHandler) distributeMessages(messages []byte) { if len(messages) > 2 { + jh.mu.Lock() + defer jh.mu.Unlock() for _, jobInfo := range jh.jobs { go jh.sendMessagesToConsumer(messages, jobInfo) } -- 2.16.6