瀏覽代碼

add logic to grpc leave handler to publish peer update message

Matthew R Kasun 3 年之前
父節點
當前提交
eec491564b
共有 1 個文件被更改,包括 4 次插入0 次删除
  1. 4 0
      controllers/node_grpc.go

+ 4 - 0
controllers/node_grpc.go

@@ -142,6 +142,10 @@ func (s *NodeServiceServer) DeleteNode(ctx context.Context, req *nodepb.Object)
 	if err != nil {
 		return nil, err
 	}
+	// notify other nodes on network of deleted peer
+	if err := mq.NewPeer(node); err != nil {
+		logger.Log(0, "failed to inform peers of deleted node "+err.Error())
+	}
 
 	return &nodepb.Object{
 		Data: "success",