߲jdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z eje Zdddd d Zd Zed ed zdiZddZddZddZddZy)aWho holds the SQLite write lock on state.db right now (Linux ``/proc/locks``). The "database is locked for over Ns" failure names the victim but not the holder, and the open-descriptor scan (``hermes_state_holders``) cannot tell a reader from the one writer: every Hermes process has the DB open. SQLite's unix VFS takes ``fcntl`` byte-range locks whose offsets encode the lock kind, and the kernel exports them with the owning pid, so the holder can be named at the moment the deadline passes. ) annotationsN)Path)DictListTuplez WAL writezWAL checkpointz WAL recoverzshm dead-man switch)xyzi@PENDINGRESERVEDc|dk(r9|tvr||k(r t|Sd|cxkrdkrnn ||k(rd|dz Sd|d|S||k(r|tvr t|S|tdzk(ryd |d|S) N-shm{zWAL read slot z shm bytes -z SHARED rangez db bytes )_SHM_LOCK_NAMES_MAIN_LOCK_NAMES _PENDING_BYTE)sidecarstartends | jd\} }}tjt | dt |d}|t |f}t | }t | }| dk(r|n t | }|j|}||j|t||||f|S#t $rYwxYw) a?``(pid, lock kind, sidecar)`` for every WRITE lock on one of ``inodes``. ``inodes`` maps ``(st_dev, st_ino)`` to ``""`` (main file), ``"-wal"`` or ``"-shm"``. Read locks are dropped: they never block a writer in WAL mode. An OFD lock is reported with pid ``-1`` (the kernel does not export its owner). r z->NWRITE:EOF) splitlinessplitlenosmakedevint ValueErrorgetappendr)textinodesfoundlinefields__kind_clsaccesspid_sidentstart_send_smajor_sminor_sino_sdevkeypidrrrs rparse_proc_locksr@1s#)+E!K v;?fQi4/ ?Ebqz<5$ugu W   &+kk#&6 #GWe**S"-s7B/?@CE #Ce*CLE E>%s5zC**S/ ?  c?7E3?IJ)K* L    sA4C== D D c tjjdsgStjj tj |}i}dD]6} tj||z}|||j|jf<8 tddd5}|j}ddddd l m}g}t|D]D\} } }| dkDr|| nd } |j!| d | d t#||zj$F|S#t$rYwxYw#1swYuxYw#t$rgcYSwxYw) zOperator-facing lines naming the processes that hold a write-class lock on ``db_path``. Empty when nothing is held or the platform has no ``/proc/locks``. linux)z-walrz /proc/locksasciireplace)encodingerrorsNr)describe_holder_pidz.OFD lock, owner pid not exported by the kernelz holds z lock on )sysplatform startswithr'pathrealpathfspathstatOSErrorst_devst_inoopenreadhermes_state_holdersrHr@r,rname) db_pathbaser.rsthandler-rHlinesr?kindwhos rstate_db_write_lock_holdersr^QsG << " "7 + 77  BIIg. /D)+F'1 (B*1 299%& 1  -') D !;;=D !9 E.tV<PT7*-'!#&7g uGD64w3G3L3L2MNOP L    ! !  s<DD1 D%1D1 D"!D"%D.*D11 D?>D?ct|}|rdj|}nd}tjd|t |j |y)zQOne WARNING naming the write-lock holders at the moment a writer gave up waiting.z | zMno write-class lock held at the deadline (the holder released just before it)z2state.db write lock unavailable for %.0fs (%s): %sN)r^joinloggerwarningrrV)rW patience_sholdersdetails rlog_write_lock_holdersrfnsB)'2GG$` NNrss{# $$   8 $      9Az %@: r