You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
279 lines
5.1 KiB
279 lines
5.1 KiB
// +build use_codec |
|
|
|
package benchmark |
|
|
|
import ( |
|
"testing" |
|
|
|
"github.com/ugorji/go/codec" |
|
) |
|
|
|
func BenchmarkCodec_Unmarshal_M(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
dec := codec.NewDecoderBytes(nil, h) |
|
|
|
b.SetBytes(int64(len(largeStructText))) |
|
for i := 0; i < b.N; i++ { |
|
var s LargeStruct |
|
dec.ResetBytes(largeStructText) |
|
if err := dec.Decode(&s); err != nil { |
|
b.Error(err) |
|
} |
|
} |
|
} |
|
|
|
func BenchmarkCodec_Unmarshal_S(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
dec := codec.NewDecoderBytes(nil, h) |
|
|
|
b.SetBytes(int64(len(smallStructText))) |
|
for i := 0; i < b.N; i++ { |
|
var s LargeStruct |
|
dec.ResetBytes(smallStructText) |
|
if err := dec.Decode(&s); err != nil { |
|
b.Error(err) |
|
} |
|
} |
|
} |
|
|
|
func BenchmarkCodec_Marshal_S(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&smallStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_M(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&largeStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_L(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&xlStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_S_Reuse(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&smallStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_M_Reuse(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&largeStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_L_Reuse(b *testing.B) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
var l int64 |
|
for i := 0; i < b.N; i++ { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&xlStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_S_Parallel(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var out []byte |
|
|
|
var h codec.Handle = new(codec.JsonHandle) |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&smallStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
}) |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_M_Parallel(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&largeStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
}) |
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_L_Parallel(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&xlStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = nil |
|
} |
|
}) |
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_S_Parallel_Reuse(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var out []byte |
|
|
|
var h codec.Handle = new(codec.JsonHandle) |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&smallStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
}) |
|
|
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_M_Parallel_Reuse(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&largeStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
}) |
|
b.SetBytes(l) |
|
} |
|
|
|
func BenchmarkCodec_Marshal_L_Parallel_Reuse(b *testing.B) { |
|
var l int64 |
|
|
|
b.RunParallel(func(pb *testing.PB) { |
|
var h codec.Handle = new(codec.JsonHandle) |
|
|
|
var out []byte |
|
enc := codec.NewEncoderBytes(&out, h) |
|
|
|
for pb.Next() { |
|
enc.ResetBytes(&out) |
|
if err := enc.Encode(&xlStructData); err != nil { |
|
b.Error(err) |
|
} |
|
l = int64(len(out)) |
|
out = out[:0] |
|
} |
|
}) |
|
b.SetBytes(l) |
|
}
|
|
|