fix: don't abort accept when accepting a single connection fails

listen.go

@@ -23,22 +23,24 @@ func (r *Relay) Listener() *RelayListener {
 }
 
 func (l *RelayListener) Accept() (manet.Conn, error) {
-	select {
-	case c := <-l.incoming:
-		err := l.Relay().writeResponse(c.stream, pb.CircuitRelay_SUCCESS)
-		if err != nil {
-			log.Debugf("error writing relay response: %s", err.Error())
-			c.stream.Reset()
-			return nil, err
+	for {
+		select {
+		case c := <-l.incoming:
+			err := l.Relay().writeResponse(c.stream, pb.CircuitRelay_SUCCESS)
+			if err != nil {
+				log.Debugf("error writing relay response: %s", err.Error())
+				c.stream.Reset()
+				continue
+			}
+
+			// TODO: Pretty print.
+			log.Infof("accepted relay connection: %q", c)
+
+			c.tagHop()
+			return c, nil
+		case <-l.ctx.Done():
+			return nil, l.ctx.Err()
 		}
-
-		// TODO: Pretty print.
-		log.Infof("accepted relay connection: %q", c)
-
-		c.tagHop()
-		return c, nil
-	case <-l.ctx.Done():
-		return nil, l.ctx.Err()
 	}
 }