From bb7634af524f40f54d3a42c91efc66056c5e356a Mon Sep 17 00:00:00 2001
From: Garet Halliday <me@garet.holiday>
Date: Fri, 6 Oct 2023 15:33:51 -0500
Subject: [PATCH] lol
---
lib/gat/pool/pool.go | 17 +----------------
1 file changed, 1 insertion(+), 16 deletions(-)
diff --git a/lib/gat/pool/pool.go b/lib/gat/pool/pool.go
index 1995ee71..ac760634 100644
--- a/lib/gat/pool/pool.go
+++ b/lib/gat/pool/pool.go
@@ -14,7 +14,6 @@ import (
"gfx.cafe/gfx/pggat/lib/fed"
packets "gfx.cafe/gfx/pggat/lib/fed/packets/v3.0"
"gfx.cafe/gfx/pggat/lib/gat/metrics"
- "gfx.cafe/gfx/pggat/lib/util/pools"
"gfx.cafe/gfx/pggat/lib/util/slices"
)
@@ -312,11 +311,6 @@ func (T *Pool) ServeBot(
return T.serve(client, true)
}
-var ppool pools.Locked[fed.Packet]
-
-// max 256kb per connection
-const maxPacketBufferSize = 256 * 1024
-
func (T *Pool) serve(client *pooledClient, initialized bool) error {
T.addClient(client)
defer T.removeClient(client)
@@ -336,12 +330,7 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error {
}
}()
- packet, _ := ppool.Get()
- defer func() {
- if len(packet) <= maxPacketBufferSize {
- ppool.Put(packet)
- }
- }()
+ var packet fed.Packet
if !initialized {
server = T.acquireServer(client)
@@ -372,10 +361,6 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error {
server = nil
}
- if len(packet) > maxPacketBufferSize {
- packet = make(fed.Packet, 0, maxPacketBufferSize)
- }
-
packet, err = client.GetConn().ReadPacket(true, packet)
if err != nil {
return err
--
GitLab