From bb9903e5dd358b0efdb128c10aface9b88766437 Mon Sep 17 00:00:00 2001
From: JeshuaRen <270813223@qq.com>
Date: Thu, 13 Feb 2025 15:58:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=95=B0=E6=8D=AE=E7=BB=91?=
 =?UTF-8?q?=E5=AE=9A=E7=AD=9B=E9=80=89=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pkgs/bitmap/bitmap.go       |  2 +-
 pkgs/ioswitch/dag/node.go   |  2 +-
 pkgs/ioswitch/dag/var.go    | 10 +++++-----
 sdks/pcmscheduler/models.go | 13 +++++++++++++
 utils/io2/chunked_split.go  |  2 +-
 utils/serder/serder_test.go |  8 ++++----
 6 files changed, 25 insertions(+), 12 deletions(-)

diff --git a/pkgs/bitmap/bitmap.go b/pkgs/bitmap/bitmap.go
index b1c3e63..d655772 100644
--- a/pkgs/bitmap/bitmap.go
+++ b/pkgs/bitmap/bitmap.go
@@ -23,7 +23,7 @@ func (b *Bitmap64) Weight() int {
 	cnt := 0
 	for v > 0 {
 		cnt++
-		v &= (v - 1)
+		v &= v - 1
 	}
 	return cnt
 }
diff --git a/pkgs/ioswitch/dag/node.go b/pkgs/ioswitch/dag/node.go
index 6fbe735..d513267 100644
--- a/pkgs/ioswitch/dag/node.go
+++ b/pkgs/ioswitch/dag/node.go
@@ -98,7 +98,7 @@ func (s *VarSlots[T]) Clear(val *T) {
 }
 
 func (s *VarSlots[T]) RemoveAt(idx int) {
-	(*s) = lo2.RemoveAt(*s, idx)
+	*s = lo2.RemoveAt(*s, idx)
 }
 
 func (s *VarSlots[T]) RemoveRange(start int, cnt int) {
diff --git a/pkgs/ioswitch/dag/var.go b/pkgs/ioswitch/dag/var.go
index 27168a3..5d5989e 100644
--- a/pkgs/ioswitch/dag/var.go
+++ b/pkgs/ioswitch/dag/var.go
@@ -87,28 +87,28 @@ func (s *DstList) Get(idx int) Node {
 }
 
 func (s *DstList) Add(n Node) int {
-	(*s) = append((*s), n)
+	*s = append(*s, n)
 	return len(*s) - 1
 }
 
 func (s *DstList) Remove(n Node) {
 	for i, e := range *s {
 		if e == n {
-			(*s) = lo2.RemoveAt((*s), i)
+			*s = lo2.RemoveAt(*s, i)
 			return
 		}
 	}
 }
 
 func (s *DstList) RemoveAt(idx int) {
-	lo2.RemoveAt((*s), idx)
+	lo2.RemoveAt(*s, idx)
 }
 
 func (s *DstList) Resize(size int) {
 	if s.Len() < size {
-		(*s) = append((*s), make([]Node, size-s.Len())...)
+		*s = append(*s, make([]Node, size-s.Len())...)
 	} else if s.Len() > size {
-		(*s) = (*s)[:size]
+		*s = (*s)[:size]
 	}
 }
 
diff --git a/sdks/pcmscheduler/models.go b/sdks/pcmscheduler/models.go
index 0a0e14b..8fb7182 100644
--- a/sdks/pcmscheduler/models.go
+++ b/sdks/pcmscheduler/models.go
@@ -44,6 +44,9 @@ const (
 
 	PreferencePriority     = "preference"
 	SpecifyClusterPriority = "specify"
+
+	FailedStatus  = "failed"
+	SuccessStatus = "success"
 )
 
 type TaskID int64
@@ -253,6 +256,11 @@ type BiasPriority struct {
 	Options []string `json:"options"`
 }
 
+type TaskMessage struct {
+	Status  string `json:"status"`
+	Message string `json:"message"`
+}
+
 type UploadParams struct {
 	DataType   string     `json:"dataType"`
 	UploadInfo UploadInfo `json:"uploadInfo"`
@@ -406,6 +414,11 @@ type ClusterImage struct {
 	CardType       string           `json:"cardType"`
 }
 
+type QueryBindingFilters struct {
+	Status string `json:"status"`
+	Name   string `json:"name"`
+}
+
 type QueryBindingDataParam interface {
 	Noop()
 }
diff --git a/utils/io2/chunked_split.go b/utils/io2/chunked_split.go
index b6606c5..07893a0 100644
--- a/utils/io2/chunked_split.go
+++ b/utils/io2/chunked_split.go
@@ -32,7 +32,7 @@ func ChunkedSplit(stream io.Reader, chunkSize int, streamCount int, opts ...Chun
 	loop:
 		for {
 			for i := 0; i < streamCount; i++ {
-				var rd int = 0
+				var rd = 0
 				if !eof {
 					var err error
 					rd, err = io.ReadFull(stream, buf)
diff --git a/utils/serder/serder_test.go b/utils/serder/serder_test.go
index bdb3101..b36c0d1 100644
--- a/utils/serder/serder_test.go
+++ b/utils/serder/serder_test.go
@@ -591,7 +591,7 @@ func Test_ObjectToJSON2(t *testing.T) {
 		union := types.NewTypeUnion[Base](&St1{}, St2{})
 		UseTypeUnionExternallyTagged(&union)
 
-		var val []Base = []Base{
+		var val = []Base{
 			&St1{Val: "asd", Type: "St1"},
 			St2{Val: 123, Type: "St2"},
 		}
@@ -607,7 +607,7 @@ func Test_ObjectToJSON2(t *testing.T) {
 		union := types.NewTypeUnion[Base](&St1{}, St2{})
 		UseTypeUnionInternallyTagged(&union, "Type")
 
-		var val []Base = []Base{
+		var val = []Base{
 			&St1{Val: "asd", Type: "St1"},
 			St2{Val: 123, Type: "St2"},
 		}
@@ -623,7 +623,7 @@ func Test_ObjectToJSON2(t *testing.T) {
 		union := types.NewTypeUnion[Base](&St1{}, St2{})
 		UseTypeUnionExternallyTagged(&union)
 
-		var val []Base = []Base{
+		var val = []Base{
 			nil,
 		}
 		data, err := ObjectToJSONEx(val)
@@ -638,7 +638,7 @@ func Test_ObjectToJSON2(t *testing.T) {
 		union := types.NewTypeUnion[Base](&St1{}, St2{})
 		UseTypeUnionInternallyTagged(&union, "Type")
 
-		var val []Base = []Base{
+		var val = []Base{
 			nil,
 		}
 		data, err := ObjectToJSONEx(val)