no pool

ChainSafe · Jan 28, 2022 · 8a8a00b · 8a8a00b
1 parent d9bb2b7
commit 8a8a00b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/dot/network/inbound.go b/dot/network/inbound.go
@@ -15,9 +15,7 @@ func (s *Service) readStream(stream libp2pnetwork.Stream, decoder messageDecoder
 	s.streamManager.logNewStream(stream)
 
 	peer := stream.Conn().RemotePeer()
-	buffer := s.bufPool.Get().(*[]byte)
-	defer s.bufPool.Put(buffer)
-	msgBytes := *buffer
+	msgBytes := make([]byte, maxMessageSize)
 
 	for {
 		n, err := readStream(stream, msgBytes[:])

diff --git a/dot/network/notifications.go b/dot/network/notifications.go
@@ -429,9 +429,7 @@ func (s *Service) readHandshake(stream libp2pnetwork.Stream, decoder HandshakeDe
 	go func() {
 		defer close(hsC)
 
-		buffer := s.bufPool.Get().(*[]byte)
-		defer s.bufPool.Put(buffer)
-		msgBytes := *buffer
+		msgBytes := make([]byte, maxMessageSize)
 
 		tot, err := readStream(stream, msgBytes[:])
 		if err != nil {