Function BenchmarkDecode

encode_test.go:399–452

(b *testing.B)

}

func BenchmarkDecode(b *testing.B) {
	b.Run("int64", func(b *testing.B) {
		x := []byte("1234")
		for i := 0; i < b.N; i++ {
			decode(nil, x, oid.T_int8, formatText)
		}
	})
	b.Run("float64", func(b *testing.B) {
		x := []byte("3.14159")
		for i := 0; i < b.N; i++ {
			decode(nil, x, oid.T_float8, formatText)
		}
	})
	b.Run("bool", func(b *testing.B) {
		x := []byte{'t'}
		for i := 0; i < b.N; i++ {
			decode(nil, x, oid.T_bool, formatText)
		}
	})
	b.Run("uuid_binary", func(b *testing.B) {
		x := []byte{0x03, 0xa3, 0x52, 0x2f, 0x89, 0x28, 0x49, 0x87, 0x84, 0xd6, 0x93, 0x7b, 0x36, 0xec, 0x27, 0x6f}
		for i := 0; i < b.N; i++ {
			decodeUUIDBinary(x)
		}
	})
	b.Run("timestamptz", func(b *testing.B) {
		x := []byte("2013-09-17 22:15:32.360754-07")
		for i := 0; i < b.N; i++ {
			decode(&parameterStatus{}, x, oid.T_timestamptz, formatText)
		}
	})
	b.Run("timestamptz_thread", func(b *testing.B) {
		oldProcs := runtime.GOMAXPROCS(0)
		defer runtime.GOMAXPROCS(oldProcs)
		runtime.GOMAXPROCS(runtime.NumCPU())
		pqtime.Reset()

		x := []byte("2013-09-17 22:15:32.360754-07")
		f := func(wg *sync.WaitGroup, loops int) {
			defer wg.Done()
			for i := 0; i < loops; i++ {
				decode(&parameterStatus{}, x, oid.T_timestamptz, formatText)
			}
		}

		wg := &sync.WaitGroup{}
		b.ResetTimer()
		for j := 0; j < 10; j++ {
			wg.Add(1)
			go f(wg, b.N/10)
		}
		wg.Wait()
	})
}

func BenchmarkEncode(b *testing.B) {
	b.Run("int64", func(b *testing.B) {