| Server IP : 2.57.91.36 / Your IP : 216.73.217.6 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/go/pkg/mod/github.com/gogo/protobuf@v1.3.2/io/ |
Upload File : |
package io_test
import (
"encoding/binary"
"io/ioutil"
"math/rand"
"reflect"
"testing"
"time"
"github.com/gogo/protobuf/test"
example "github.com/gogo/protobuf/test/example"
"github.com/gogo/protobuf/io"
)
func BenchmarkUint32DelimWriterMarshaller(b *testing.B) {
w := io.NewUint32DelimitedWriter(ioutil.Discard, binary.BigEndian)
r := rand.New(rand.NewSource(time.Now().UnixNano()))
msg := example.NewPopulatedA(r, true)
for i := 0; i < b.N; i++ {
if err := w.WriteMsg(msg); err != nil {
b.Fatal(err)
}
}
}
func BenchmarkUint32DelimWriterFallback(b *testing.B) {
w := io.NewUint32DelimitedWriter(ioutil.Discard, binary.BigEndian)
r := rand.New(rand.NewSource(time.Now().UnixNano()))
msg := test.NewPopulatedNinOptNative(r, true)
for i := 0; i < b.N; i++ {
if err := w.WriteMsg(msg); err != nil {
b.Fatal(err)
}
}
}
// Writing the same size messaged twice should not cause another
// reader buffer allocation
func TestUint32SameSizeNoAlloc(t *testing.T) {
buf := newBuffer()
writer := io.NewUint32DelimitedWriter(buf, binary.LittleEndian)
reader := io.NewUint32DelimitedReader(buf, binary.LittleEndian, 1024*1024)
err := writer.WriteMsg(&test.NinOptNative{Field15: []byte("numbercatinvention")})
if err != nil {
t.Fatal(err)
}
err = writer.WriteMsg(&test.NinOptNative{Field15: []byte("fastenselectionsky")})
if err != nil {
t.Fatal(err)
}
if err := writer.Close(); err != nil {
t.Fatal(err)
}
msg := &test.NinOptNative{}
if err := reader.ReadMsg(msg); err != nil {
t.Fatal(err)
}
firstRead := reflect.ValueOf(reader).Elem().FieldByName("buf").Pointer()
if err := reader.ReadMsg(msg); err != nil {
t.Fatal(err)
}
secondRead := reflect.ValueOf(reader).Elem().FieldByName("buf").Pointer()
if firstRead != secondRead {
t.Fatalf("reader buf byte slice pointer did not stay the same after second same size read (%d != %d).", firstRead, secondRead)
}
}