Function ProbeIPs

scanner/ip.go:49–78

ProbeIPs runs ProbeIP concurrently. Output order matches input.

(ctx context.Context, ips []string, port uint16, timeout time.Duration,
	concurrency int, onResult func(IPResult))

// ProbeIPs runs ProbeIP concurrently. Output order matches input.
func ProbeIPs(ctx context.Context, ips []string, port uint16, timeout time.Duration,
	concurrency int, onResult func(IPResult)) []IPResult {
	if concurrency <= 0 {
		concurrency = 16
	}
	sem := make(chan struct{}, concurrency)
	out := make([]IPResult, len(ips))
	var wg sync.WaitGroup
	for i, s := range ips {
		addr, err := netip.ParseAddr(s)
		if err != nil {
			out[i] = IPResult{Err: "parse: " + err.Error()}
			continue
		}
		i, addr := i, addr
		wg.Add(1)
		sem <- struct{}{}
		go func() {
			defer wg.Done()
			defer func() { <-sem }()
			r := ProbeIP(ctx, addr, port, timeout)
			out[i] = r
			if onResult != nil {
				onResult(r)
			}
		}()
	}
	wg.Wait()
	return out
}

// RankIPs sorts reachable IPs by RTT ascending. Unreachable are dropped.
func RankIPs(in []IPResult) []IPResult {