From 398c688fed1aa0e851f36a55a96d4909b070fb2e Mon Sep 17 00:00:00 2001 From: "zero@thinky" Date: Sat, 4 Apr 2026 18:10:05 +0300 Subject: [PATCH] fix race --- backend/internal/grpcsrv/commander/commander.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/internal/grpcsrv/commander/commander.go b/backend/internal/grpcsrv/commander/commander.go index ba0cec0..2bc35a9 100644 --- a/backend/internal/grpcsrv/commander/commander.go +++ b/backend/internal/grpcsrv/commander/commander.go @@ -81,6 +81,7 @@ func (self *Agent) AddJob(job models.JobForInsert) (int64, error) { if err != nil { return 0, err } + self.jobs[jid] = newJob() self.in <- &proto.Command{ Id: jid, Command: job.Command, @@ -155,7 +156,6 @@ func (self *Agent) recv() error { func (self *Agent) send() error { for job := range self.in { - self.jobs[job.Id] = newJob() if err := self.bidi.Send(job); err != nil { return err }