move internal node when renaming

seaweedfs · Apr 17, 2021 · 787d297 · 787d297
1 parent e426e83
commit 787d297
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/fs/serve.go b/fs/serve.go
@@ -1756,6 +1756,18 @@ func (s *Server) delNodeId(node Node) {
 	delete(s.nodeRef, node)
 }
 
+func (s *Server) InvalidateInternalNode(oldNode Node, newNode Node, callbackFn func(internalNode Node)) {
+	s.meta.Lock()
+	id, ok := s.getNodeId(oldNode)
+	if ok {
+		snode := s.node[id]
+		callbackFn(snode.node)
+		s.setNodeId(newNode, id)
+		s.delNodeId(oldNode)
+	}
+	s.meta.Unlock()
+}
+
 func (s *Server) invalidateNode(node Node, off int64, size int64) error {
 	s.meta.Lock()
 	id, ok := s.getNodeId(node)