From 7253635cd3bfc29426ba589547e94ef342af33f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BE=90=E6=97=AD?= <120582243@qq.com> Date: Sun, 26 Apr 2020 19:44:59 +0800 Subject: [PATCH] delete invalid copy (#1573) * prealloc * delete invalid copy --- util/socket/socket.go | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/util/socket/socket.go b/util/socket/socket.go index d1338ab5..91fac4bc 100644 --- a/util/socket/socket.go +++ b/util/socket/socket.go @@ -67,23 +67,9 @@ func (s *Socket) Local() string { } func (s *Socket) Send(m *transport.Message) error { - // make copy - msg := &transport.Message{ - Header: make(map[string]string), - Body: make([]byte, len(m.Body)), - } - - // copy headers - for k, v := range m.Header { - msg.Header[k] = v - } - - // copy body - copy(msg.Body, m.Body) - // send a message select { - case s.send <- msg: + case s.send <- m: case <-s.closed: return io.EOF }