good morning!!!!

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

fix

parent 671ee0d7
No related branches found
No related tags found
No related merge requests found
......@@ -92,18 +92,35 @@ func serve(client fed.Conn, acceptParams frontends.AcceptParams, pools Pools) er
func Serve(acceptor Acceptor, pools Pools) error {
for {
conn, acceptParams, err := acceptor.Accept()
netConn, err := acceptor.Listener.Accept()
if err != nil {
if errors.Is(err, net.ErrClosed) {
return nil
}
log.Print("error accepting client: ", err)
log.Print("error accepting connection: ", err)
continue
}
conn := fed.WrapNetConn(netConn)
go func() {
err := serve(conn, acceptParams, pools)
defer func() {
_ = conn.Close()
}()
ctx := frontends.AcceptContext{
Conn: conn,
Options: acceptor.Options,
}
acceptParams, acceptErr := frontends.Accept(&ctx)
if acceptErr != nil {
log.Print("error accepting client: ", acceptErr)
return
}
err = serve(conn, acceptParams, pools)
if err != nil && !errors.Is(err, io.EOF) {
log.Print("error serving client: ", err)
return
}
}()
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment