From 3c7bca44f809a92e4c0e1418a450211d5cbfea01 Mon Sep 17 00:00:00 2001 From: Aayush Gupta Date: Fri, 4 Feb 2022 15:50:43 -0800 Subject: [PATCH] Using projectOutputBuffers to check for jobID instead of receiverBuffers --- server/handlers/project_command_output_handler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/server/handlers/project_command_output_handler.go b/server/handlers/project_command_output_handler.go index 02cb85160..da3d92b03 100644 --- a/server/handlers/project_command_output_handler.go +++ b/server/handlers/project_command_output_handler.go @@ -117,9 +117,9 @@ func NewAsyncProjectCommandOutputHandler( } func (p *AsyncProjectCommandOutputHandler) IsKeyExists(key string) bool { - p.receiverBuffersLock.RLock() - defer p.receiverBuffersLock.RUnlock() - _, ok := p.receiverBuffers[key] + p.projectOutputBuffersLock.RLock() + defer p.projectOutputBuffersLock.RUnlock() + _, ok := p.projectOutputBuffers[key] return ok }