ujxdZddlmZddlZddlZd dZd dZd dZddZejd dd Z y)am Detection of the CPU allocation actually available to this process. Used to bound the default worker count for parallel I/O, so that a default :func:`~pandas.read_csv` does not oversubscribe a machine on which the process has been given only a slice of the CPUs -- a CPU affinity mask, or a cgroup CPU quota as set by ``docker --cpus`` and Kubernetes CPU limits. ) annotationsNc t|d5}t|jjcdddS#1swYyxYw#tt f$rYywxYwNzutf-8)encoding)openintreadstripOSError ValueErrorpathfhs ]/var/www/html/python-recuperauto-other/env/lib/python3.12/site-packages/pandas/compat/_cpu.py_read_sysfs_intrsS $ ) *Rrwwy() * * * Z s- A 'A A A A A AAc t|d5}|jjcdddS#1swYyxYw#ttf$rYywxYwr)rr r r r r s r_read_sysfs_strrsN  $ ) %R779??$ % % % Z s* A7 AAAAAAc|j}|r|ddk(ry t|d}t|dkDrt|dnd}|dkDr |dkDr||z Sy#t$rYywxYw)z CPU count from a cgroup v2 ``cpu.max`` value. The format is ``" "`` (both in microseconds) or ``"max"`` when the CPU time is unlimited; returns ``None`` when unlimited or malformed. rmaxNi)splitrlenr )textpartsquotaperiods r_parse_cgroup_v2_quotar$s{ JJLE E!H%E!H "%e*q.U1Xf qyVaZv~  s,A A%$A%ctd}| t|Std}td}|r|dkDr |r |dkDr||z Sy)zECPUs allowed by the process's cgroup CFS quota, or None if unlimited.z/sys/fs/cgroup/cpu.maxNz#/sys/fs/cgroup/cpu/cpu.cfs_quota_usz$/sys/fs/cgroup/cpu/cpu.cfs_period_usr)rrr)rrrs r_cgroup_cpu_quotar8sT 3 4D %d++ A BE C DF v&1*v~ r)maxsizecg}ttdr. |jttjdt }|$|jtdt||r t|SdS#t $rYJwxYw)a% Number of CPUs the process may actually use, or None if unconstrained. Takes the tighter of the CPU affinity mask (``taskset``, SLURM cpusets) and the cgroup CFS quota (Docker ``--cpus``, Kubernetes CPU limits), so a default worker count does not oversubscribe a restricted environment. Returns ``None`` only where neither limit is probed -- in practice macOS and Windows. macOS exposes no affinity mask at all; Windows does (via ``GetProcessAffinityMask`` and job-object rate limits) but it is not implemented here, so a restricted Windows process falls back to the logical CPU count clamped by ``_MAX_DEFAULT_WORKERS``. On Linux ``sched_getaffinity`` always succeeds, so an unconstrained box reports its full logical CPU count rather than ``None``. Cached for the process lifetime: the CPU allocation is static in practice (affinity is normally set once at startup, and a live quota change via ``docker update`` or an in-place pod resize is rare), and this is on the ``read_csv`` hot path. sched_getaffinityrNr) hasattrosappendrr#r rrrmin)limitsrs ravailable_cpu_countr)Gs*Fr&'  MM#b22156 7  E  c!SZ() 3v;*d*    s-B B  B )rstrreturn int | None)rr*r+z str | None)rr*r+ float | None)r+r-)r+r,) __doc__ __future__r functoolsr%rrrr lru_cacher)r rr3sJ#  ( Q+ +r