INNER CODE UNIT · Python

r

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

                    r = os.preadv(fd, [mv[got:want]], offs[i] + got)
                    if r <= 0:
                        break
                    got += r
        except Exception as e:
            err.append(e)
        finally:
            os.close(fd)

    t0 = time.time()
    th = [threading.Thread(target=worker, args=(k,)) for k in range(qd)]
    for x in th:
        x.start()
    for x in th:
        x.join()
    dt = time.time() - t0
    if err:
        raise err[0]

View source record →