INNER CODE UNIT · Python

worker

FareedKhan-dev/kimi-k3-in-c · tools/devbw.py:47

    def worker(k: int):
        try:
            fd = os.open(path, os.O_RDONLY | getattr(os, "O_DIRECT", 0))
        except OSError as e:
            err.append(e); return
        try:
            _raw, buf = aligned_buf(SZ)
            mv = memoryview(buf).cast("B")
            for i in range(k, N, qd):
                got, want = 0, SZ
                while got < want:
                    r = os.preadv(fd, [mv[got:want]], offs[i] + got)
                    if r <= 0:
                        break
                    got += r
        except Exception as e:
            err.append(e)
        finally:

View source record →