good morning!!!!

Skip to content
Snippets Groups Projects
Commit d215fc53 authored by Garet Halliday's avatar Garet Halliday
Browse files

rearrange

parent ec6cd0b6
Branches
Tags
No related merge requests found
...@@ -338,7 +338,9 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error { ...@@ -338,7 +338,9 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error {
packet, _ := ppool.Get() packet, _ := ppool.Get()
defer func() { defer func() {
if len(packet) <= maxPacketBufferSize {
ppool.Put(packet) ppool.Put(packet)
}
}() }()
if !initialized { if !initialized {
...@@ -370,6 +372,10 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error { ...@@ -370,6 +372,10 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error {
server = nil server = nil
} }
if len(packet) > maxPacketBufferSize {
packet = make(fed.Packet, 0, maxPacketBufferSize)
}
packet, err = client.GetConn().ReadPacket(true, packet) packet, err = client.GetConn().ReadPacket(true, packet)
if err != nil { if err != nil {
return err return err
...@@ -387,10 +393,6 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error { ...@@ -387,10 +393,6 @@ func (T *Pool) serve(client *pooledClient, initialized bool) error {
packet, err, serverErr = bouncers.Bounce(client.GetConn(), server.GetConn(), packet) packet, err, serverErr = bouncers.Bounce(client.GetConn(), server.GetConn(), packet)
} }
if len(packet) > maxPacketBufferSize {
packet = make(fed.Packet, 0, maxPacketBufferSize)
}
if serverErr != nil { if serverErr != nil {
return serverErr return serverErr
} else { } else {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment