From 55ba9ba3755c01bdde115dc95bc34e8be9a8ceb9 Mon Sep 17 00:00:00 2001 From: Luke Shumaker Date: Sat, 18 Jun 2016 05:56:00 -0400 Subject: revert the last commit --- proto/io.go | 57 +++------------------------------------------------------ 1 file changed, 3 insertions(+), 54 deletions(-) (limited to 'proto/io.go') diff --git a/proto/io.go b/proto/io.go index 0f231c8..34421b1 100644 --- a/proto/io.go +++ b/proto/io.go @@ -23,7 +23,6 @@ import ( "io" "net" "reflect" - "sync" "syscall" ) @@ -42,7 +41,6 @@ type nslcdObjectPtr interface { } type String []byte - func (s String) String() string { return string(s) } @@ -56,7 +54,7 @@ func (data String) nslcdWrite(fd io.Writer) { func (data *String) nslcdRead(fd io.Reader) { var len int32 Read(fd, &len) - buf := makeBytes(len) + buf := make([]byte, len) Read(fd, &buf) *data = String(buf) } @@ -96,7 +94,7 @@ func Write(fd io.Writer, data interface{}) { } var bytes []byte if af < 0 { - bytes = makeBytes(0) + bytes = make([]byte, 0) } else { bytes = data } @@ -165,7 +163,7 @@ func Read(fd io.Reader, data interface{}) { if len != _len { panic(NslcdError(fmt.Sprintf("address length incorrect: %d", len))) } - buf := makeBytes(len) + buf := make([]byte, len) Read(fd, &buf) *data = buf case *[]net.IP: @@ -186,52 +184,3 @@ func Read(fd io.Reader, data interface{}) { } } } - -// "Free" an object and its members, returning them to various pools. -// This keeps the GC sane. -func Free(data interface{}) { - switch data := data.(type) { - case *[]byte: - bytePool.Put(*data) - case *int32: - // do nothing - case *String: - bytes := []byte(*data) - bytePool.Put(bytes) - case *[]String: - for _, str := range *data { - Free(&str) - } - case *net.IP: - bytes := []byte(*data) - bytePool.Put(bytes) - case *[]net.IP: - for _, ip := range *data { - Free(&ip) - } - default: - p := reflect.ValueOf(data) - v := reflect.Indirect(p) - if p == v || v.Kind() != reflect.Struct { - panic(fmt.Sprintf("The argument to nslcd_proto.Free() must be a pointer: %T ( %#v )", data, data)) - } - for i, n := 0, v.NumField(); i < n; i++ { - Free(v.Field(i).Addr().Interface()) - } - } -} - -var bytePool = sync.Pool{ - New: func() interface{} { - return make([]byte, 0, 256) - }, -} - -func makeBytes(l int32) []byte { - buf := bytePool.Get().([]byte) - if cap(buf) < int(l) { - bytePool.Put(buf) - buf = make([]byte, l) - } - return buf[:l] -} -- cgit v1.2.3-2-g168b