Function TestWriteProtectionMechanism

sdk/data/stream/async_flush_sequencer_test.go:61–97

(t *testing.T)

}

func TestWriteProtectionMechanism(t *testing.T) {
	// Create a mock streamer
	s := &Streamer{
		inode: 12345,
	}

	// Create a mock handler
	handler := &ExtentHandler{
		id: 1,
	}

	// Test write protection
	s.startWriteProtection(handler)

	// Verify handler is protected
	if !s.isHandlerProtected(handler) {
		t.Errorf("Handler should be protected after startWriteProtection")
	}

	// Test with different handler
	otherHandler := &ExtentHandler{
		id: 2,
	}
	if s.isHandlerProtected(otherHandler) {
		t.Errorf("Other handler should not be protected")
	}

	// End write protection
	s.endWriteProtection()

	// Verify handler is no longer protected
	if s.isHandlerProtected(handler) {
		t.Errorf("Handler should not be protected after endWriteProtection")
	}

	log.LogDebugf("Write protection test passed")
}