From 3e421eae60f46f619a9db7c095d67330e733b398 Mon Sep 17 00:00:00 2001 From: yfh Date: Mon, 24 Feb 2025 21:58:03 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=81=E7=A7=BB=E4=BB=8E=20net.rpc=20?= =?UTF-8?q?=E5=88=B0=20gRPC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- node/app/node_server.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/node/app/node_server.go b/node/app/node_server.go index 98316a5..a18ba55 100644 --- a/node/app/node_server.go +++ b/node/app/node_server.go @@ -155,8 +155,6 @@ func (s *NodeServiceServer) sendToIotaChannels(data []common_models.IotaData) (c log.Println("Timeout while trying to send iotaData.") return nil, false } - - return nil, false // 如果所有通道都满了，返回 nil 和 false } // 将 IotaData 转换为 DeviceData, 转换后数据发送到 s.processChannels @@ -213,9 +211,7 @@ func (s *NodeServiceServer) HandleIotaChan(ch chan []common_models.IotaData, ind sendTime := time.Now() processChannel, ok := s.sendToProcessChannels(processDataArray, index) // 这里会一直等到有资源 if !ok { - // TODO processChannels 满了之后做什么处理？ log.Printf("3.iotaDataArray[%v] s.processChannels %d个通道都已满，被阻塞。", formattedTime, len(s.processChannels)) - } else { log.Printf("3.iotaDataArray[%v] 已发送至s.processChannels。processChannel[%p]数据量：%d/%d, \n发送耗时：%v ,iotaDataArray处理耗时：%v", formattedTime, processChannel, len(processChannel), cap(processChannel), time.Since(sendTime), time.Since(dataHandleTime))