17ae225
@@ -148,12 +148,21 @@
describe("a frozen mirror is said, and reconnected in one click", () => {
    );
  /** The sync after a reconnect runs in the background; wait for its refs. */
  async function mirrorReaches(oid: string, ms = 15_000): Promise<void> {
    const start = Date.now();
    while ((await mirrorMain()) !== oid) {
      if (Date.now() - start > ms)
        throw new Error(`mirror main never reached ${oid}`);
      await Bun.sleep(50);
  async function mirrorReaches(oid: string): Promise<void> {
    await refReaches(() => mirrorMain(), oid);
  }
  /**
   * Wait for a ref to reach an oid. No deadline of its own: the sync that
   * moves it is awaited, and the test's timeout is the only bound, so a
   * loaded machine slows it and never fails it.
   */
  async function refReaches(
    read: () => Promise<string | undefined>,
    oid: string,
  ): Promise<void> {
    while ((await read()) !== oid) {
      await Promise.race([syncsSettled(), Bun.sleep(50)]);
    }
  }
@@ -298,9 +307,7 @@
describe("a frozen mirror is said, and reconnected in one click", () => {
  afterAll(async () => {
    // A sync started by a reconnect may outlive the test that waited for its
    // refs; it must not write into a directory being removed.
    // Bounded: a sync wedged on a loaded machine must not take the hook's
    // own timeout, which fails the file under no name.
    await Promise.race([syncsSettled(), Bun.sleep(30_000)]);
    await syncsSettled();
    octo.stop();
    mona.stop();
    servers.stop();
@@ -678,12 +685,7 @@
describe("a frozen mirror is said, and reconnected in one click", () => {
    // And the fork, which has nothing of its own, follows its parent again.
    const forkDir = repoDir(app.reposRoot, "alice", "widgets-fork");
    const start = Date.now();
    while ((await resolveOid(forkDir, "refs/heads/main")) !== tip) {
      if (Date.now() - start > 10_000)
        throw new Error("the fork never followed");
      await Bun.sleep(50);
    }
    await refReaches(() => resolveOid(forkDir, "refs/heads/main"), tip);
    await syncOrigin(app, getOriginById(app.db, again)!);
  });
});
		@@ -148,12 +148,21 @@ describe("a frozen mirror is said, and reconnected in one click", () => {
148	148	);
149	149
150	150	/** The sync after a reconnect runs in the background; wait for its refs. */
151		async function mirrorReaches(oid: string, ms = 15_000): Promise<void> {
152		const start = Date.now();
153		while ((await mirrorMain()) !== oid) {
154		if (Date.now() - start > ms)
155		throw new Error(`mirror main never reached ${oid}`);
156		await Bun.sleep(50);
	151	async function mirrorReaches(oid: string): Promise<void> {
	152	await refReaches(() => mirrorMain(), oid);
	153	}
	154
	155	/**
	156	* Wait for a ref to reach an oid. No deadline of its own: the sync that
	157	* moves it is awaited, and the test's timeout is the only bound, so a
	158	* loaded machine slows it and never fails it.
	159	*/
	160	async function refReaches(
	161	read: () => Promise<string \| undefined>,
	162	oid: string,
	163	): Promise<void> {
	164	while ((await read()) !== oid) {
	165	await Promise.race([syncsSettled(), Bun.sleep(50)]);
157	166	}
158	167	}
159	168
		@@ -298,9 +307,7 @@ describe("a frozen mirror is said, and reconnected in one click", () => {
298	307	afterAll(async () => {
299	308	// A sync started by a reconnect may outlive the test that waited for its
300	309	// refs; it must not write into a directory being removed.
301		// Bounded: a sync wedged on a loaded machine must not take the hook's
302		// own timeout, which fails the file under no name.
303		await Promise.race([syncsSettled(), Bun.sleep(30_000)]);
	310	await syncsSettled();
304	311	octo.stop();
305	312	mona.stop();
306	313	servers.stop();
		@@ -678,12 +685,7 @@ describe("a frozen mirror is said, and reconnected in one click", () => {
678	685
679	686	// And the fork, which has nothing of its own, follows its parent again.
680	687	const forkDir = repoDir(app.reposRoot, "alice", "widgets-fork");
681		const start = Date.now();
682		while ((await resolveOid(forkDir, "refs/heads/main")) !== tip) {
683		if (Date.now() - start > 10_000)
684		throw new Error("the fork never followed");
685		await Bun.sleep(50);
686		}
	688	await refReaches(() => resolveOid(forkDir, "refs/heads/main"), tip);
687	689	await syncOrigin(app, getOriginById(app.db, again)!);
688	690	});
689	691	});