Jake Hillion
29ada58125
All checks were successful
continuous-integration/drone/push Build is passing
43 lines
624 B
Go
43 lines
624 B
Go
package tcp
|
|
|
|
import (
|
|
"log"
|
|
"mpbl3p/proxy"
|
|
"net"
|
|
)
|
|
|
|
func NewListener(p *proxy.Proxy, local string, v proxy.MacVerifier) error {
|
|
laddr, err := net.ResolveTCPAddr("tcp", local)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
listener, err := net.ListenTCP("tcp", laddr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
go func() {
|
|
for {
|
|
conn, err := listener.AcceptTCP()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
err = conn.SetWriteBuffer(0)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
f := Flow{conn: conn, isAlive: true}
|
|
|
|
log.Printf("received new connection: %v\n", f)
|
|
|
|
p.AddConsumer(&f)
|
|
p.AddProducer(&f, v)
|
|
}
|
|
}()
|
|
|
|
return nil
|
|
}
|