Function busyWrite

xenomint/sqlite/sqlite_test.go:810–827

func BenchmarkStorageSequentialDirtyRead(b *testing.B) { var ( st, q, dm, _, _ = setupBenchmarkStorage(b) dest = dm() err error ) for i := 0; i < b.N; i++ { if err = st.DirtyReader().QueryRow(q, rrkg.next()).Scan(dest...); err != nil { b.Fatalf("failed to query v

(
	b *testing.B,
	wg *sync.WaitGroup, sc <-chan struct{},
	st xi.Storage, kg keygen, e string, src [][]interface{},
)

//)

func busyWrite(
	b *testing.B,
	wg *sync.WaitGroup, sc <-chan struct{},
	st xi.Storage, kg keygen, e string, src [][]interface{},
) {
	defer wg.Done()
	var err error
	for {
		select {
		case <-sc:
			return
		default:
			if _, err = st.Writer().Exec(e, src[kg.next()]...); err != nil {
				b.Errorf("failed to execute: %v", err)
			}
		}
	}
}

func busyWriteTx(
	b *testing.B,