Function pushOneWrite

script/computerd-soak.mjs:231–257

(stub, i, bytes)

// path silenced the outbound loop and A never saw any of B's
// writes.
async function pushOneWrite(stub, i, bytes) {
  const hash = new Uint8Array(await crypto.subtle.digest("SHA-256", bytes));
  await stub.sync.pushObjects(
    new ReadableStream({
      start(c) {
        c.enqueue({ hash, bytes });
        c.close();
      },
    }),
  );
  await stub.sync.push({
    senderRev: 0,
    changes: new ReadableStream({
      start(c) {
        c.enqueue({
          kind: "file",
          path: `/soak_${i}.bin`,
          mode: 0o644,
          mtime: Date.now(),
          size: bytes.byteLength,
          chunks: [{ hash, size: bytes.byteLength }],
        });
        c.close();
      },
    }),
  });
}

async function main() {
  if (!DISABLE_FUSE) await ensureImage();