From 6bedc97c95406d432d3811da94036acbb1a653c1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Wed, 15 Dec 2021 20:46:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/api_stream.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/internal/nodes/api_stream.go b/internal/nodes/api_stream.go index 7dad1fb..222c054 100644 --- a/internal/nodes/api_stream.go +++ b/internal/nodes/api_stream.go @@ -140,15 +140,11 @@ func (this *APIStream) handleConnectedAPINode(message *pb.NodeStreamMessage) err return errors.Wrap(err) } - rpcClient, err := rpc.SharedRPC() + _, err = rpc.SharedRPC() if err != nil { return errors.Wrap(err) } - _, err = rpcClient.NodeRPC().UpdateNodeConnectedAPINodes(rpcClient.Context(), &pb.UpdateNodeConnectedAPINodesRequest{ApiNodeIds: []int64{msg.APINodeId}}) - if err != nil { - return errors.Wrap(err) - } remotelogs.Println("API_STREAM", "connected to api node '"+strconv.FormatInt(msg.APINodeId, 10)+"'") // 重新读取配置