Method TestBuffer_Split

mem/buffers_test.go:260–300

(t *testing.T)

}

func (s) TestBuffer_Split(t *testing.T) {
	freed := make(chan struct{})
	data := []byte{1, 2, 3, 4}
	buf := mem.NewBuffer(&data, poolFunc(func(*[]byte) {
		close(freed)
	}))

	buf, split1 := mem.SplitUnsafe(buf, 2)
	if !bytes.Equal(buf.ReadOnlyData(), data[:2]) {
		t.Fatalf("Buffer did not contain expected data. got %v, want %v", buf.ReadOnlyData(), data[:2])
	}
	if !bytes.Equal(split1.ReadOnlyData(), data[2:]) {
		t.Fatalf("Buffer did not contain expected data. got %v, want %v", split1.ReadOnlyData(), data[2:])
	}

	// Check that splitting the buffer more than once works as intended.
	split1, split2 := mem.SplitUnsafe(split1, 1)
	if !bytes.Equal(split1.ReadOnlyData(), data[2:3]) {
		t.Fatalf("Buffer did not contain expected data. got %v, want %v", split1.ReadOnlyData(), data[2:3])
	}
	if !bytes.Equal(split2.ReadOnlyData(), data[3:]) {
		t.Fatalf("Buffer did not contain expected data. got %v, want %v", split2.ReadOnlyData(), data[3:])
	}

	// If any of the following frees actually free the buffer, the test will fail.
	buf.Free()
	split2.Free()
	select {
	case <-freed:
		t.Fatalf("Freed too early")
	default:
	}

	split1.Free()

	select {
	case <-freed:
	default:
		t.Fatalf("Still not freed")
	}
}

func (s) TestBuffer_Slice(t *testing.T) {
	freed := make(chan struct{})