Function TestNewCollectionCloseEvents

collection_test.go:37–102

(t *testing.T)

}

func TestNewCollectionCloseEvents(t *testing.T) {
	events := map[EventKind]int{}
	durations := map[EventKind]time.Duration{}

	co := CollectionOptions{
		OnEvent: func(e Event) {
			events[e.Kind]++
			durations[e.Kind] += e.Duration
		},
	}

	m, err := NewCollection(co)
	if err != nil || m == nil {
		t.Errorf("expected moss")
	}

	co2 := m.Options()
	if co2.OnEvent == nil {
		t.Errorf("expected non-nil on-event")
	}

	err = m.Start()
	if err != nil {
		t.Errorf("expected Start ok")
	}

	b, err := m.NewBatch(0, 0)
	if err != nil || b == nil {
		t.Errorf("expected b ok")
	}

	b.Set([]byte("a"), []byte("A"))

	err = m.Close()
	if err != nil {
		t.Errorf("expected Close ok")
	}

	if len(events) != 2 ||
		events[EventKindCloseStart] != 1 ||
		events[EventKindClose] != 1 {
		t.Errorf("expected 2 close events")
	}

	// On platforms where timing granularity is too coarse, the close operation
	// cannot be timed within that granularity (1ms) reliably.
	if !IsTimingCoarse &&
		durations[EventKindClose] <= 0 {
		t.Errorf("expected close to take some time")
	}

	b1, err := m.NewBatch(0, 0)
	if err != ErrClosed || b1 != nil {
		t.Errorf("expected err-close")
	}

	err = m.ExecuteBatch(b, WriteOptions{})
	if err != ErrClosed {