telınha

264pub fn race(targets: []const Target, version: u16, timeout_ms: u32, cancel: *const std.atomic.Value(bool), fail: *Failure) Error!Winner {265  if (targets.len == 0) return error.UnknownHost;266  const n = @min(targets.len, max_targets);267  const r = gpa.create(Race) catch return error.ThreadFailed;268  r.* = .{ .refs = .init(1), .total = n, .targets = undefined };269  @memcpy(r.targets[0..n], targets[0..n]);270  for (0..n) |i| {271    _ = r.refs.fetchAdd(1, .monotonic);272    sync.spawn(attempt, .{ r, i, @as(u32, @intCast(i)) * 250, version }) catch {273      _ = r.refs.fetchSub(1, .monotonic);274      r.mutex.lock();275      r.finished += 1;276      r.mutex.unlock();277    };278  }279  defer r.release();280  const t0 = sync.nowMs();281  r.mutex.lock();282  defer r.mutex.unlock();283  while (r.winner == null and r.finished < r.total) {284    if (cancel.load(.acquire) or sync.nowMs() - t0 > timeout_ms) {285      r.cancel.store(true, .release);286      fail.err = if (cancel.load(.acquire)) error.Cancelled else error.ConnectFailed;287      return fail.err;288    }289    r.cond.timedWait(&r.mutex, 50);290  }291  if (r.winner) |w| return w;292  fail.err = if (r.version_mismatch) |v| blk: {293    fail.server_version = v;294    break :blk error.VersionMismatch;295  } else if (r.not_telinha) error.NotTelinha else if (r.refused) error.ConnectionRefused else if (r.unknown and r.total == 1) error.UnknownHost else error.ConnectFailed;296  return fail.err;297}