From f39e1778353171ff0d8277ad06738df79ebaf997 Mon Sep 17 00:00:00 2001 From: yanafu Date: Thu, 28 Nov 2024 11:09:39 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20worker=E9=80=89=E5=8F=96=E5=8F=8A?= =?UTF-8?q?=E6=81=A2=E5=A4=8D=E6=9C=BA=E5=88=B6=E4=BC=98=E5=8C=96=20#311?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../booster/bk_dist/controller/pkg/manager/remote/mgr.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go b/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go index a32af34c..216a3e34 100644 --- a/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go +++ b/src/backend/booster/bk_dist/controller/pkg/manager/remote/mgr.go @@ -1112,10 +1112,11 @@ func (m *Mgr) ensureFiles( blog.Debugf("remote: ensure file %s and match rule %d", fd.File.FilePath, t) servers := make([]*dcProtocol.Host, 0, 0) switch t { - case dcSDK.FilterRuleHandleDefault: - r = append(r, "") - continue - + //此处会导致文件不被发送，注释掉保证文件都在此处发送，共用内存锁避免OOM + /*case dcSDK.FilterRuleHandleDefault: + r = append(r, "") + continue + */ case dcSDK.FilterRuleHandleAllDistribution: // cleaner = append(cleaner, f) if err = m.fileMessageBank.ensure(sender, sandbox); err != nil {