()
| 781 | } |
| 782 | |
| 783 | func (s *Streamer) endWriteProtection() { |
| 784 | s.writeProtectionLock.Lock() |
| 785 | defer s.writeProtectionLock.Unlock() |
| 786 | s.writeInProgress = false |
| 787 | s.writeHandler = nil |
| 788 | log.LogDebugf("Write protection ended for streamer(%v)", s.inode) |
| 789 | } |
| 790 | |
| 791 | func (s *Streamer) isHandlerProtected(handler *ExtentHandler) bool { |
| 792 | s.writeProtectionLock.Lock() |