Function TestDecoderResetWithOptions

zstd/decoder_test.go:2217–2268

(t *testing.T)

}

func TestDecoderResetWithOptions(t *testing.T) {
	dec, err := NewReader(nil, WithDecoderConcurrency(1), WithDecoderLowmem(true))
	if err != nil {
		t.Fatal(err)
	}
	defer dec.Close()

	// Test changing safe options
	t.Run("change-maxmemory", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, WithDecoderMaxMemory(1<<20))
		if err != nil {
			t.Errorf("ResetWithOptions should allow changing maxMemory: %v", err)
		}
	})

	t.Run("change-maxwindow", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, WithDecoderMaxWindow(1<<20))
		if err != nil {
			t.Errorf("ResetWithOptions should allow changing maxWindow: %v", err)
		}
	})

	t.Run("change-ignorechecksum", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, IgnoreChecksum(true))
		if err != nil {
			t.Errorf("ResetWithOptions should allow changing ignoreChecksum: %v", err)
		}
	})

	// Test error when changing unsafe options
	t.Run("change-concurrency-error", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, WithDecoderConcurrency(4))
		if err == nil {
			t.Error("ResetWithOptions should error when changing concurrency")
		}
	})

	t.Run("change-lowmem-error", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, WithDecoderLowmem(false))
		if err == nil {
			t.Error("ResetWithOptions should error when changing lowmem")
		}
	})

	// Test same value is allowed
	t.Run("same-concurrency-ok", func(t *testing.T) {
		err := dec.ResetWithOptions(nil, WithDecoderConcurrency(1))
		if err != nil {
			t.Errorf("ResetWithOptions should allow same concurrency: %v", err)
		}
	})
}

func TestDecoderDictDelete(t *testing.T) {
	dictContent := []byte("test dictionary content for decompression testing purposes")