- ln, err := net.Listen("tcp", *bind)
- if err != nil {
- log.Fatalln("Can not listen:", err)
+ conns := make(chan net.Conn)
+ if *bind != "" {
+ cols := strings.Split(*bind, ":")
+ port, err := strconv.Atoi(cols[len(cols)-1])
+ if err != nil {
+ log.Fatalln("Can not parse port:", err)
+ }
+
+ if *mcdOnce {
+ if err = startMCDTx(ctx, port, true); err != nil {
+ log.Fatalln("Can not do MCD transmission:", err)
+ }
+ return
+ }
+
+ ln, err := net.Listen("tcp", *bind)
+ if err != nil {
+ log.Fatalln("Can not listen:", err)
+ }
+ if err = startMCDTx(ctx, port, false); err != nil {
+ log.Fatalln("Can not do MCD transmission:", err)
+ }
+ ln = netutil.LimitListener(ln, *maxConn)
+ go func() {
+ for {
+ conn, err := ln.Accept()
+ if err != nil {
+ log.Fatalln("Can not accept connection on TCP:", err)
+ }
+ conns <- conn
+ }
+ }()