Linux iad1-shared-b7-18 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64
Apache
: 67.205.6.31 | : 216.73.216.171
Cant Read [ /etc/named.conf ]
8.2.29
fernandoquevedo
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
README
+ Create Folder
+ Create File
/
usr /
lib /
python3 /
dist-packages /
hgext /
__pycache__ /
[ HOME SHELL ]
Name
Size
Permission
Action
__init__.cpython-310.pyc
257
B
-rw-r--r--
absorb.cpython-310.pyc
33.47
KB
-rw-r--r--
acl.cpython-310.pyc
11.77
KB
-rw-r--r--
amend.cpython-310.pyc
1.85
KB
-rw-r--r--
automv.cpython-310.pyc
3.07
KB
-rw-r--r--
beautifygraph.cpython-310.pyc
2.39
KB
-rw-r--r--
blackbox.cpython-310.pyc
5.19
KB
-rw-r--r--
bookflow.cpython-310.pyc
3.49
KB
-rw-r--r--
bugzilla.cpython-310.pyc
36.29
KB
-rw-r--r--
censor.cpython-310.pyc
3.7
KB
-rw-r--r--
children.cpython-310.pyc
1.94
KB
-rw-r--r--
churn.cpython-310.pyc
7.14
KB
-rw-r--r--
clonebundles.cpython-310.pyc
10.5
KB
-rw-r--r--
closehead.cpython-310.pyc
2.44
KB
-rw-r--r--
commitextras.cpython-310.pyc
2.13
KB
-rw-r--r--
eol.cpython-310.pyc
12.69
KB
-rw-r--r--
extdiff.cpython-310.pyc
16.42
KB
-rw-r--r--
factotum.cpython-310.pyc
3.9
KB
-rw-r--r--
fastexport.cpython-310.pyc
5.43
KB
-rw-r--r--
fetch.cpython-310.pyc
4.67
KB
-rw-r--r--
fix.cpython-310.pyc
28.83
KB
-rw-r--r--
githelp.cpython-310.pyc
24.92
KB
-rw-r--r--
gpg.cpython-310.pyc
9.28
KB
-rw-r--r--
graphlog.cpython-310.pyc
2.45
KB
-rw-r--r--
hgk.cpython-310.pyc
8.49
KB
-rw-r--r--
histedit.cpython-310.pyc
71.05
KB
-rw-r--r--
journal.cpython-310.pyc
16.34
KB
-rw-r--r--
keyword.cpython-310.pyc
25.98
KB
-rw-r--r--
logtoprocess.cpython-310.pyc
2.71
KB
-rw-r--r--
mq.cpython-310.pyc
102.34
KB
-rw-r--r--
notify.cpython-310.pyc
15.32
KB
-rw-r--r--
pager.cpython-310.pyc
1.66
KB
-rw-r--r--
patchbomb.cpython-310.pyc
25.23
KB
-rw-r--r--
phabricator.cpython-310.pyc
58.13
KB
-rw-r--r--
purge.cpython-310.pyc
498
B
-rw-r--r--
rebase.cpython-310.pyc
52.95
KB
-rw-r--r--
record.cpython-310.pyc
4.49
KB
-rw-r--r--
releasenotes.cpython-310.pyc
17.59
KB
-rw-r--r--
relink.cpython-310.pyc
5.29
KB
-rw-r--r--
remotenames.cpython-310.pyc
12.31
KB
-rw-r--r--
schemes.cpython-310.pyc
4.36
KB
-rw-r--r--
share.cpython-310.pyc
6.68
KB
-rw-r--r--
show.cpython-310.pyc
10.65
KB
-rw-r--r--
sparse.cpython-310.pyc
12.23
KB
-rw-r--r--
split.cpython-310.pyc
4.63
KB
-rw-r--r--
sqlitestore.cpython-310.pyc
26.77
KB
-rw-r--r--
strip.cpython-310.pyc
700
B
-rw-r--r--
transplant.cpython-310.pyc
22.64
KB
-rw-r--r--
uncommit.cpython-310.pyc
7.64
KB
-rw-r--r--
win32mbcs.cpython-310.pyc
5.34
KB
-rw-r--r--
win32text.cpython-310.pyc
5.62
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : sqlitestore.cpython-310.pyc
o �]Lb�� � @ sl d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m Z m Z m Z ddl mZ ddlmZmZmZmZmZmZmZmZmZmZmZmZ ddl m Z mZ dd l m Z m!Z! z dd lm"Z" e"j# W n e$yp dZ"Y nw i Z%e�&e%�Z&e&d d e"rd nddd� dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dd d d d d d!d"e- gZ4dGd#d$�Z5d%d&� Z6G d'd(� d(ej7�Z8ej9G d)d*� d*e:��Z;e �<e j=�ej9dd+�G d,d-� d-e:���Z>e �<e j?�ej9dd.�G d/d0� d0e:���Z@e �<e jA�G d1d2� d2e:��ZBG d3d4� d4ejC�ZDd5d6� ZEd7d8� ZFd9d:� ZGe �<e jH�G d;d<� d<e:��ZId=d>� ZJd?d@� ZKdAdB� ZLdCdD� ZMdEdF� ZNdS )Ham store repository data in SQLite (EXPERIMENTAL) The sqlitestore extension enables the storage of repository data in SQLite. This extension is HIGHLY EXPERIMENTAL. There are NO BACKWARDS COMPATIBILITY GUARANTEES. This means that repositories created with this extension may only be usable with the exact version of this extension/Mercurial that was used. The extension attempts to enforce this in order to prevent repository corruption. In addition, several features are not yet supported or have known bugs: * Only some data is stored in SQLite. Changeset, manifest, and other repository data is not yet stored in SQLite. * Transactions are not robust. If the process is aborted at the right time during transaction close/rollback, the repository could be in an inconsistent state. This problem will diminish once all repository data is tracked by SQLite. * Bundle repositories do not work (the ability to use e.g. `hg -R <bundle-file> log` to automatically overlay a bundle on top of the existing repository). * Various other features don't work. This extension should work for basic clone/pull, update, and commit workflows. Some history rewriting operations may fail due to lack of support for bundle repositories. To use, activate the extension and set the ``storage.new-repo-backend`` config option to ``sqlite`` to enable new repositories to use SQLite for storage. � )�absolute_importN��_)�nullrev�sha1nodeconstants�short)�attr) �ancestor�dagop�encoding�error� extensions� localrepo�mdiff�pycompat� registrar� requirements�util�verify)� repositoryr )�hashutil� storageutil)�zstd� storage� sqlite.compression� zstd� zlibT)�default� experimentals ships-with-hg-cores exp-sqlite-001s exp-sqlite-comp-001=zstds exp-sqlite-comp-001=zlibs exp-sqlite-comp-001=nones exp-sqlite-shallow-files� � � � z�CREATE TABLE delta ( id INTEGER PRIMARY KEY, compression INTEGER NOT NULL, hash BLOB UNIQUE ON CONFLICT ABORT, delta BLOB NOT NULL )zKCREATE TABLE filepath ( id INTEGER PRIMARY KEY, path BLOB NOT NULL )z4CREATE UNIQUE INDEX filepath_path ON filepath (path)ac CREATE TABLE fileindex ( id INTEGER PRIMARY KEY, pathid INTEGER REFERENCES filepath(id), revnum INTEGER NOT NULL, p1rev INTEGER NOT NULL, p2rev INTEGER NOT NULL, linkrev INTEGER NOT NULL, flags INTEGER NOT NULL, deltaid INTEGER REFERENCES delta(id), deltabaseid INTEGER REFERENCES fileindex(id), node BLOB NOT NULL )zJCREATE UNIQUE INDEX fileindex_pathrevnum ON fileindex (pathid, revnum)zBCREATE UNIQUE INDEX fileindex_pathnode ON fileindex (pathid, node)a� CREATE VIEW filedata AS SELECT fileindex.id AS id, filepath.id AS pathid, filepath.path AS path, fileindex.revnum AS revnum, fileindex.node AS node, fileindex.p1rev AS p1rev, fileindex.p2rev AS p2rev, fileindex.linkrev AS linkrev, fileindex.flags AS flags, fileindex.deltaid AS deltaid, fileindex.deltabaseid AS deltabaseid FROM filepath, fileindex WHERE fileindex.pathid=filepath.idzPRAGMA user_version=%dc C s� | � djd�dgt|� �d�t||gt|�� � ��}g }d}|D ]-\} } } | }| tkr3|�| �} n| t kr:| } n| t krDt �| �} nt d| ��|� | � q"||v r[||| } n|�� } |�� t�| |�} t| t�srt| �} | S )z&Resolve a delta chain for a file node.a WITH RECURSIVE deltachain(deltaid, baseid) AS ( SELECT deltaid, deltabaseid FROM fileindex WHERE pathid=? AND node=? UNION ALL SELECT fileindex.deltaid, deltabaseid FROM fileindex, deltachain WHERE fileindex.id=deltachain.baseid AND deltachain.baseid IS NOT NULL AND fileindex.id NOT IN ({stops}) ) SELECT deltachain.baseid, compression, delta FROM deltachain, delta WHERE delta.id=deltachain.deltaid�,�?)�stopsNs unhandled compression type: %d)�execute�format�join�len�tuple�list�keys�COMPRESSION_ZSTD� decompress�COMPRESSION_NONE�COMPRESSION_ZLIB�zlib�SQLiteStoreError�append�pop�reverser �patches� isinstance�bytes)�db�pathid�node� revisioncache�stoprids�zstddctx�res�deltas�lastdeltabaseid� deltabaseid� compression�delta�basetext�fulltext� rG �3/usr/lib/python3/dist-packages/hgext/sqlitestore.py�resolvedeltachain� s: �� � rI c C sB z | � d|||f�jW S tjy | � d|f��� d Y S w )Nz=INSERT INTO delta (compression, hash, delta) VALUES (?, ?, ?)z!SELECT id FROM delta WHERE hash=?r )r& � lastrowid�sqlite3�IntegrityError�fetchone)r9 rC �hashrD rG rG rH � insertdelta� s �����rO c @ s e Zd ZdS )r2 N)�__name__� __module__� __qualname__rG rG rG rH r2 s r2 c @ sT e Zd Ze�� Ze�� Ze�� Ze�� Ze�� Z e�� Z e�� Z e�� Z e�� Z dS )� revisionentryN)rP rQ rR r �ib�rid�revr; �p1rev�p2rev�p1node�p2node�linkrev�flagsrG rG rG rH rS s rS )�slotsc @ sh e Zd Ze�� Ze�� Ze�� Ze�� Ze�� Z e�� Z e�� Z e�� Z e�� Z e�� Zejdd�ZdS )�sqliterevisiondeltaN�r )rP rQ rR r rT r; rY rZ �basenoder\ �baserevisionsize�revisionrD �sidedata�protocol_flags�linknoderG rG rG rH r^ s r^ )�frozenc @ s0 e Zd Zejdd�Zejdd�Zejdd�ZdS )� sqliteproblemNr_ )rP rQ rR r rT �warningr r; rG rG rG rH rg ( s rg c @ sl e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � ZdOdd�Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� ZdPd"d#�Zd$d%� Zd&d'� ZdQd*d+�Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd d(d(ej d fd4d5�Z d6d7� Z dRd8d9�Z (dSd:d;�Z dTd=d>�Z!d?d@� Z"dAdB� Z#dCdD� Z$dUdEdF�Z% ( ( ( ( (dVdGdH�Z&dIdJ� Z'dPdKdL�Z( dWdMdN�Z)d S )X�sqlitefilestorez2Implements storage for an individual tracked path.c C sx t j| _|| _|| _d | _i | _i | _i | _t� d�| _ || _ |dkr0t j dd�| _t �� | _nd | _d | _| �� d S )N� r r! )�level)r �nullid�_db�_path�_pathid� _revtonode� _nodetorev� _revisionsr � lrucachedict�_revisioncache� _compenginer �ZstdCompressor�_cctx�ZstdDecompressor�_dctx� _refreshindex)�selfr9 �pathrC rG rG rH �__init__4 s zsqlitefilestore.__init__c C s� i | _ i | _i | _t| j�d| jf��}|sd | _d S |d d | _| j�d| jf�}t|�D ]M\}}|\}}}}}} } ||krFt t d���|t krNt j } n| j | } |t kr[t j } n| j | } t|||||| | | | d� } || j |< || j|< | | j|< q/d S )Nz$SELECT id FROM filepath WHERE path=?r zgSELECT id, revnum, node, p1rev, p2rev, linkrev, flags FROM fileindex WHERE pathid=? ORDER BY revnum ASCs1 sqlite database has inconsistent revision numbers� rU rV r; rW rX rY rZ r[ r\ )rp rq rr r+ rm r& rn ro � enumerater2 r r r rl rS )r{ r? �i�rowrU rV r; rW rX r[ r\ rY rZ �entryrG rG rH rz O sV ���� � �z sqlitefilestore._refreshindexc C s t | j�S �N)r) rr �r{ rG rG rH �__len__� s zsqlitefilestore.__len__c C s t t�t| j���S r� )�iterr �xranger) rr r� rG rG rH �__iter__� s zsqlitefilestore.__iter__c C s |t jkrdS || jv S �NF)r rl rq �r{ r; rG rG rH �hasnode� s zsqlitefilestore.hasnoder Nc C s t jt| j�||d�S )N)�start�stop)r �iterrevsr) rr )r{ r� r� rG rG rH �revs� s �zsqlitefilestore.revsc C sJ |t jkr t jt jfS || jvrt�|| jtd���| j| }|j|jfS �N� no node) r rl rr r � LookupErrorrn r rY rZ )r{ r; r� rG rG rH �parents� s zsqlitefilestore.parentsc C s> |t krt t fS || jvrt|��| j| j| }|j|jfS r� )r rp � IndexErrorrr rW rX �r{ rV r� rG rG rH � parentrevs� s zsqlitefilestore.parentrevsc C s6 |t jkrtS || jvrt�|| jtd���| j| S r� )r rl r rq r r� rn r r� rG rG rH rV � s zsqlitefilestore.revc C s* |t krtjS || jvrt|��| j| S r� )r r rl rp r� �r{ rV rG rG rH r; � s zsqlitefilestore.nodec C s t �| || j�S r� )r � fileidlookuprn r� rG rG rH �lookup� � zsqlitefilestore.lookupc C s4 |t krt S || jvrt|��| j| j| }|jS r� )r rp r� rr r[ r� rG rG rH r[ � s zsqlitefilestore.linkrevc C s4 |t krdS || jvrt|��| j| j| jt@ S r� )r rp r� rr r\ � FLAG_CENSOREDr� rG rG rH � iscensored� s zsqlitefilestore.iscensoredc C s2 | � |�}| � |�}t�| j||�}t�| j|�S r� )rV r �commonancestorsheadsr� r �maplistr; )r{ �node1�node2�rev1�rev2� ancestorsrG rG rH r� � s z$sqlitefilestore.commonancestorsheadsc C s t �|| j| j�S r� )r �descendantrevsr� r� )r{ r� rG rG rH � descendants� s zsqlitefilestore.descendantsc st |d u r|d u rt � �stjgS |d ur� �|�nt}� fdd�|p#g D �}tj� j� j||d�}� fdd�|D �S )Nc s h | ]}� � |��qS rG �rV ��.0�nr� rG rH � <setcomp>� � z(sqlitefilestore.heads.<locals>.<setcomp>)�startrev�stoprevsc � g | ]}� � |��qS rG )r; )r� rV r� rG rH � <listcomp>� r� z)sqlitefilestore.heads.<locals>.<listcomp>) r) r rl rV r r �headrevssubsetr� r� )r{ r� r� r� r� r� rG r� rH �heads� s �zsqlitefilestore.headsc C s. | � |�}| j�d| j||f�}dd� |D �S )NzZSELECT node FROM filedata WHERE path=? AND (p1rev=? OR p2rev=?) ORDER BY revnum ASCc S s g | ]}|d �qS )r rG )r� r� rG rG rH r� � s z,sqlitefilestore.children.<locals>.<listcomp>)rV rm r& rn )r{ r; rV r? rG rG rH �children� s � zsqlitefilestore.childrenc C sN |t krdS || jvrt|��| j| }| �|�r t| �|��S t| �|��S �Nr )r rp r� �renamedr) �readrb )r{ rV r; rG rG rH �size s zsqlitefilestore.sizeFTc s� |t jtfv r dS t|t�r� �|�}|� jvr"t�|� j t d���|� j v r,� j | S � fdd�� j D �}|s<d |d< t � j � j|� j |� jd�}� j| jttB @ rVd}|rc� �||� |� j |< |S )N� r� c s i | ] }� j | j|�qS rG )rr rU r� r� rG rH � <dictcomp>$ � z,sqlitefilestore.revision.<locals>.<dictcomp>����r> F)r rl r r7 �intr; rq r r� rn r rt rI rm ro ry rr r\ �FLAG_MISSING_P1�FLAG_MISSING_P2� _checkhash)r{ r; �raw� _verifyhashr= rF rG r� rH rb s2 � zsqlitefilestore.revisionc O s | j |i |��S r� )rb )r{ �args�kwargsrG rG rH �rawdata= r� zsqlitefilestore.rawdatac C s t �| �|��S r� )r �filtermetadatarb r� rG rG rH r� @ r� zsqlitefilestore.readc C s t �| |�S r� )r �filerevisioncopiedr� rG rG rH r� C s zsqlitefilestore.renamedc C s t �| ||� S r� )r �filedataequivalent)r{ r; rF rG rG rH �cmpF r� zsqlitefilestore.cmpc c s� � |dvr t �d| ��dd� |D �}|sd S | j�dd�dgt|� � t| jg| ��}i }|D ]\} } | j�d| j| f�}|�� d || < q2t j | ||t |j ||||d � D ]} | V qXd S ) N)s nodesr s linearNs" unhandled value for nodesorder: %sc S s g | ] }|t jkr|�qS rG )r rl r� rG rG rH r� W r� z1sqlitefilestore.emitrevisions.<locals>.<listcomp>zISELECT revnum, deltaid FROM fileindex WHERE pathid=? AND node in (%s)r# r$ z9SELECT revnum from fileindex WHERE pathid=? AND deltaid=?r )� deltaparentfn� revisiondata�assumehaveparentrevisions� deltamode�sidedata_helpers) r �ProgrammingErrorrm r& r( r) r* ro rM r � emitrevisionsr^ � __getitem__) r{ �nodes� nodesorderr� r� r� r� r? � deltabasesrV �deltaidrD rG rG rH r� I sD � ��� � � �z sqlitefilestore.emitrevisionsc C s6 |s|� d�r t�||�}| �|||||�}| �|�S )Ns )� startswithr �packmeta� addrevisionr; )r{ �filedata�meta� transactionr[ �p1�p2rV rG rG rH �add� s zsqlitefilestore.addc C sx |rt td���|d u} |pt�|||�}| r | �||||� | j�|�} | d ur+| S | �||||||�} || j|< | S )Ns flags not supported on revisions) r2 r r �hashrevisionsha1r� rq �get�_addrawrevisionrt ) r{ r� r� r[ r� r� r; r\ � cachedelta� validatehashrV rG rG rH r� � s � zsqlitefilestore.addrevisionc s^ d}|D �]&\}} } } } } }}d}|t j@ r|tO }|t j @ r$td��|rH| tjkr7� �| �s7tj} |tO }| tjkrH� �| �sHtj} |tO }� � | �}|t kr}� � |�r}t � d�}t� j| dd��}t| �| }| d |� t�||�kr}t�� j| ��|t@ s�t�| |� fdd��r�|tO }|| �}|� jv r�� j| }|jt@ r�| tjkr�| |_� j| |_| jt M _� j � d � j| |j|j f� |jt@ r�| tjkr�| |_ � j| |_ | jt M _� j � d � j| |j|j f� |r�|� � � |�� d}q| tjk�rt�!d | �}d }nd }| | f}� j"||||| | ||d �}|�r)|� |� d}q| S ) NTr s unhandled revision flags >lllF)r� c s t � �| ��S r� )r) r� )�xr� rG rH �<lambda>� s z*sqlitefilestore.addgroup.<locals>.<lambda>z0UPDATE fileindex SET p1rev=?, flags=? WHERE id=?z0UPDATE fileindex SET p2rev=?, flags=? WHERE id=?r� )� storedeltar\ )#r �REVISION_FLAG_CENSOREDr� r2 r rl r� r� r� rV r r� �struct�calcsizer) r� r �replacediffheaderr �CensoredBaseErrorrn r �deltaiscensoredrr r\ rY rq rW rm r& rU rZ rX �patchr� )r{ r@ � linkmapperr� � addrevisioncb�duplicaterevisioncb�maybemissingparents�emptyr; r� r� re � deltabaserD � wireflagsrc � storeflags�baserev�hlen�oldlen�newlenr[ r� �textr� rV rG r� rH �addgroup� s� � � � �� � � zsqlitefilestore.addgroupr� c C s� t �d|id�}t|�t| �|��krt�td���| j�d| j | j f�� � d }t | j�d||f��}|D ]f}|\}}} t | j|| i dd i| jd�} t�| ��� } | jd kra| j�| �} t} n | jd krnt�| �} t} n| jd krx| } t} nt�d | j ��t| �t| �kr�| } t} t| j| | | �}| j�d ||f� q7t�|��� } t| jt| |�}| j | j}|t O }| j�d||| j |f� | j�d|f� | � � | j � � d S )Ns censoredr� s5 censor tombstone must be no longer than censored dataz(SELECT deltaid FROM fileindex WHERE id=?r zGSELECT id, pathid, node FROM fileindex WHERE deltabaseid=? OR deltaid=?r� r� r r � none� unhandled compression engine: %sz;UPDATE fileindex SET deltaid=?, deltabaseid=NULL WHERE id=?zSUPDATE fileindex SET flags=?, deltaid=?, deltabaseid=NULL WHERE pathid=? AND node=?z DELETE FROM delta WHERE id=?)!r r� r) r� r �Abortr rm r& rr rU rM r+ rI ry r �sha1�digestru rw �compressr- r1 r0 r/ r� rO r\ r� ro rz rt �clear)r{ �tr� censornode� tombstone�censoreddeltaid�rowsr� rU r: r; rF � deltahash� deltablobrC r� �tombstonedeltaidr\ rG rG rH �censorrevision sp � ���� � �� � �z sqlitefilestore.censorrevisionc s0 t �|t� �d � fdd�� �� D �� j� j�S )Nr c r� rG r� r� r� rG rH r� { r� z1sqlitefilestore.getstrippoint.<locals>.<listcomp>)r �resolvestripinfor) r� r[ r� )r{ �minlinkrG r� rH � getstrippointw s �z sqlitefilestore.getstrippointc C s` t | �sd S | �|�\}}|t | �krd S | �|�D ]}| j�d| j| �|�f� q| �� d S )Nz/DELETE FROM fileindex WHERE pathid=? AND node=?)r) r r� rm r& ro r; rz )r{ r r� rV �_ignoredrG rG rH �strip� s � zsqlitefilestore.stripc C s g S r� rG r� rG rG rH �files� � zsqlitefilestore.filesc C s i S r� rG )r{ � nodeorrev�_dfrG rG rH rc � s zsqlitefilestore.sidedatac s\ i }|rg |d< |rg |d< |rt � �|d< |r&t� fdd�� jD ��|d< |r,d |d< |S )Ns exclusivefiless sharedfiless revisionscountc 3 s � | ] }t � �|��V qd S r� )r) rb )r� r; r� rG rH � <genexpr>� s � �z.sqlitefilestore.storageinfo.<locals>.<genexpr>s trackedsizes storedsize)r) �sumrq )r{ �exclusivefiles� sharedfiles�revisionscount� trackedsize� storedsize�drG r� rH � storageinfo� s �zsqlitefilestore.storageinfoc c s� � t � |d< | D ]6}| �|�}z| �|� W q ty> } z ttd�t|�|f |d�V |d �|� W Y d }~qd }~ww d S )Ns skipreads unpacking %s: %s)r r; )�setr; rb � Exceptionrg r r r� )r{ �staterV r; �erG rG rH �verifyintegrity� s � ����z sqlitefilestore.verifyintegrityc C s� |d u r|d u r| � |�\}}|t�|||�krd S z| j|= W n ty) Y nw t�|�r7t�| j||��t t d�| j ��)Ns integrity check failed on %s) r� r r� rt �KeyError�iscensoredtextr �CensoredNodeErrorrn r2 r )r{ rF r; r� r� rG rG rH r� � s � zsqlitefilestore._checkhashc C s� | j d u r| j�d| jf�} | j| _ |r#|\} } t| t�r"| �| �} n |d us)J �|} | tj kr3|} n t � | � | � | ��|�} | tj krGd } n| j| j} t�| ��� } | jdkrb| j�| �}t}n | jdkrot�| �}t}n| jdkry| }t}nt�d| j ��t |�t | �kr�| }t}t | j|| |�}t | �}|tj kr�t }n| j | }|tj kr�t }n| j | }| j�d| j |||||||| f �j}t |||||||||d� }|| j |< || j!|< || j|< |S )Nz&INSERT INTO filepath (path) VALUES (?)r r r� r� z�INSERT INTO fileindex ( pathid, revnum, node, p1rev, p2rev, linkrev, flags, deltaid, deltabaseid) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)r~ )"ro rm r& rn rJ r7 r� r; r rl r �textdiffrb rV rr rU r r� r� ru rw r r- r1 r0 r/ r r� r) rO r rq rS rp )r{ r; r� r� r[ r� r� r� r\ r? r� rD �baseidr r rC r� rV rW rX rU r� rG rG rH r� � s� � � � � ���� z sqlitefilestore._addrawrevision)r N)NN)FT)Nr N)NNF)r� r� )FFFFFr� )*rP rQ rR �__doc__r} rz r� r� r� r� r� r� rV r; r� r[ r� r� r� r� r� r� rb r� r� r� r� r �CG_DELTAMODE_STDr� r� r� r� r r r r rc r r! r� r� rG rG rG rH ri 0 sp = * �7 �$ � t] � �ri c s0 e Zd Zdd� Z� fdd�Zedd� �Z� ZS )�sqliterepositoryc C s dS r� rG r� rG rG rH �cancopyX r zsqliterepository.cancopyc sN � � � }tt� �j|i |��}|r|S � j�d� � fdd�}|�d|� |S )NzBEGIN TRANSACTIONc s � j �� d S r� )�_dbconn�commitr r� rG rH �committransactione s z7sqliterepository.transaction.<locals>.committransactions sqlitestore)�currenttransaction�superr) r� r+ r& � addfinalize)r{ r� r� �currentr r- �� __class__r� rH r� [ s z sqliterepository.transactionc C sF t �� j}| jr| jd |kr| jd S t| j�d��}||f| _|S )Nr r s db.sqlite)� threading�current_thread�identrm �makedb�svfsr( )r{ �tidr9 rG rG rH r+ l s zsqliterepository._dbconn)rP rQ rR r* r� �propertyr+ � __classcell__rG rG r2 rH r) W s r) c C st t �t�| ��}t|_|�d��� d }|dkr'tD ]}|�|� q|� � n |t kr,nt � t d���|�d� |S )z3Construct a database handle for a database at path.zPRAGMA user_versionr s( sqlite database has unrecognized versionzPRAGMA journal_mode=WAL)rK �connectr � strfromlocalr8 � text_factoryr& rM � CREATE_SCHEMAr, �CURRENT_SCHEMA_VERSIONr r� r )r| r9 r? � statementrG rG rH r7 } s r7 c C sF |� t� tr |� t� |� t� |� t� |� t� |� tj� d S r� ) r� � REQUIREMENTr �REQUIREMENT_ZSTD�REQUIREMENT_ZLIB�REQUIREMENT_NONE�REQUIREMENT_SHALLOW_FILESr �NARROW_REQUIREMENT)�ui� supportedrG rG rH � featuresetup� s rJ c C s |d dkr | ||�S d|v rt �td���h d�}t|�| }|r0t �td�d�t|�� ��d|d< | ||�}|�t� |�d d �}|d krQt sQt �td ���|d kr[|�t � n |d kre|�t � n|dkro|�t � n t �td�| ��|� d�r�|�t� |S )N� backends sqlites sharedrepos3 shared repositories not supported with SQLite store> � narrowfilesrK � shallowfilestores6 SQLite store does not support repo creation option: %ss , s revlogv1r r r sj storage.sqlite.compression set to "zstd" but zstandard compression not available to this Mercurial installr r� sD unknown compression engine defined in storage.sqlite.compression: %srM )r r� r r r( �sortedr� rB �configr rC rD rE r� rF )�origrH � createopts�known� unsupportedr rC rG rG rH �newreporequirements� sP � �� �� ��� rT c @ s e Zd ZdZdd� ZdS )�sqlitefilestoragez)Repository file storage backed by SQLite.c C sd |d dkr |dd � }t | jv rd}nt| jv r d}nt| jv r$d}nt�td���t| j||�S )Nr � /r r r r� sE unable to determine what compression engine to use for SQLite storage) rC r rD rE r r� r ri r+ )r{ r| rC rG rG rH �file� s ��zsqlitefilestorage.fileN)rP rQ rR r' rW rG rG rG rH rU � s rU c K s4 t |v rt|v r|�tj� tS | d||d�|��S )z=Produce a type conforming to ``ilocalrepositoryfilestorage``.)r �featuresNrG )rB rF r� r �!REPO_FEATURE_SHALLOW_FILE_STORAGErU )rP r rX r� rG rG rH �makefilestorage� s rZ c K s8 t |v rt|v rtst�td���tS | dd|i|��S )NsW repository uses zstandard compression, which is not available to this Mercurial installr rG )rB rC r r r� r r) )rP rH r r� rG rG rH �makemain s ��r[ c O s | |g|�R i |�� d|_ d S r� )�warnorphanstorefiles)rP r{ r� r� rG rG rH � verifierinit s r] c C sJ t j�t� t�t dt� t�t dt� t�t dt� t�t j dt � d S )Ns newreporequirementss makefilestorages makemains __init__) r �featuresetupfuncsr� rJ r � wrapfunctionrT rZ r[ r �verifierr] )rH rG rG rH �extsetup s �ra c C s t |t�r d |_d S d S r� )r7 r) rm )rH �reporG rG rH � reposetup) s �rc r� )Or' � __future__r rK r� r4 r1 �mercurial.i18nr �mercurial.noder r r �mercurial.thirdpartyr � mercurialr r r r r r r r r r r r �mercurial.interfacesr � interfaceutil�mercurial.utilsr r r � __version__� ImportError� configtable� configitem� testedwithrB rC rD rE rF r@ r/ r- r0 r� r� r� r? rI rO � StorageErrorr2 �s�objectrS � implementer�irevisiondeltar^ �iverifyproblemrg � ifilestorageri �localrepositoryr) r7 rJ rT �ilocalrepositoryfilestoragerU rZ r[ r] ra rc rG rG rG rH �<module> s� & 8 � � � ?A ,& A
Close
