Commit 6f6d3c34 authored by duanjinfei's avatar duanjinfei

delete todo

parent a6e4bd4c
...@@ -232,7 +232,7 @@ func monitorWorker(op *operate.DockerOp) { ...@@ -232,7 +232,7 @@ func monitorWorker(op *operate.DockerOp) {
} }
func monitorModelInfo(dockerOp *operate.DockerOp) { func monitorModelInfo(dockerOp *operate.DockerOp) {
// TODO: // TODO: 向api端获取model信息
modelInfo := &models.ModelInfo{ modelInfo := &models.ModelInfo{
TaskId: 1, TaskId: 1,
User: "", User: "",
......
...@@ -93,12 +93,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage) ...@@ -93,12 +93,10 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
log.Errorf("failed to unmarshal task cmd: %s", err.Error()) log.Errorf("failed to unmarshal task cmd: %s", err.Error())
return return
} }
// todo: 填充映射端口
var externalPort int64 var externalPort int64
for { for {
// 设置种子以确保每次运行时生成不同的随机数序列 // 设置种子以确保每次运行时生成不同的随机数序列
rand.Seed(time.Now().UnixNano()) rand.Seed(time.Now().UnixNano())
// 生成一个介于 0 和 100 之间的随机整数 // 生成一个介于 0 和 100 之间的随机整数
externalPort = rand.Int63n(10001) + 10000 externalPort = rand.Int63n(10001) + 10000
fmt.Println("t.DockerOp.UsedExternalPort[externalPort]:", t.DockerOp.UsedExternalPort[externalPort]) fmt.Println("t.DockerOp.UsedExternalPort[externalPort]:", t.DockerOp.UsedExternalPort[externalPort])
......
...@@ -84,7 +84,6 @@ func (d *DockerOp) GetContainerSign(taskMsg *nodemanagerv1.PushTaskMessage, task ...@@ -84,7 +84,6 @@ func (d *DockerOp) GetContainerSign(taskMsg *nodemanagerv1.PushTaskMessage, task
log.Error("HTTP request failed: ", err) log.Error("HTTP request failed: ", err)
return nil return nil
} }
// TODO: 解析Resp
all, err := io.ReadAll(resp.Body) all, err := io.ReadAll(resp.Body)
if err != nil { if err != nil {
log.Error("Failed to read docker response body:", err) log.Error("Failed to read docker response body:", err)
...@@ -98,7 +97,6 @@ func (d *DockerOp) GetContainerSign(taskMsg *nodemanagerv1.PushTaskMessage, task ...@@ -98,7 +97,6 @@ func (d *DockerOp) GetContainerSign(taskMsg *nodemanagerv1.PushTaskMessage, task
} }
sign := res.Content sign := res.Content
log.Info("Container sign:", sign) log.Info("Container sign:", sign)
// TODO: 返回签名
return common.Hex2Bytes(sign) return common.Hex2Bytes(sign)
} }
......
...@@ -98,7 +98,6 @@ func TestTaskHandler_computeTaskHandler(t1 *testing.T) { ...@@ -98,7 +98,6 @@ func TestTaskHandler_computeTaskHandler(t1 *testing.T) {
fields fields fields fields
args args args args
}{ }{
// TODO: Add test cases.
{ {
"test send task", "test send task",
fields{ fields{
......
...@@ -60,7 +60,7 @@ func (p *ProofWorker) ProofStorage() { ...@@ -60,7 +60,7 @@ func (p *ProofWorker) ProofStorage() {
} }
} }
}(p.productProofChan) }(p.productProofChan)
// todo: 需要修改为 Minute
timer := time.NewTicker(time.Minute) timer := time.NewTicker(time.Minute)
defer timer.Stop() defer timer.Stop()
randomMinute := getRandInt() randomMinute := getRandInt()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment