diff --git a/lib/gat/pool/pool.go b/lib/gat/pool/pool.go index 1995ee71bd7b1b4b4d5d81577271defb1fc5b660..ac7606342a44596777bdc40ae10fed1ceda7389e 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