File: //lib/python3/dist-packages/hgext/fsmonitor/__pycache__/watchmanclient.cpython-310.pyc
o
�]LbZ � @ st d dl mZ d dlZd dlmZmZ d dlmZmZ ddl m
Z
G dd� de �Z G d d
� d
e �Z
G d d � d e�ZdS )
� )�absolute_importN)�encoding�util)�procutil�
stringutil� )�
pywatchmanc @ s( e Zd Zddd�Zdd� Ze�e�ZdS ) � UnavailableTFc C s& || _ || _| j dkrd| _|| _d S )Ns timed out waiting for responseF)�msg�warn�
invalidate)�selfr
r r � r �@/usr/lib/python3/dist-packages/hgext/fsmonitor/watchmanclient.py�__init__ s
zUnavailable.__init__c C s | j rd| j S d| j S )Ns! warning: Watchman unavailable: %ss Watchman unavailable: %s)r r
�r
r r r � __bytes__ s
zUnavailable.__bytes__N)TF)�__name__�
__module__� __qualname__r r r � strmethod�__str__r r r r r s
r c s e Zd Z� fdd�Z� ZS )�WatchmanNoRootc s || _ tt| ��|� d S �N)�root�superr r )r
r r
�� __class__r r r * s zWatchmanNoRoot.__init__)r r r r �
__classcell__r r r r r ) s r c @ sT e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zej d d
� �Z
dd� Z dd� Z dS )�client� �?c C sb d }| j s d}d}| j |�dd�v rd| j }d}|r t||��|| _d | _|| _|| _d| _d S )Ns couldn't get userT� fsmonitors blacklistuserss user %s in blacklistF)�_user�
configlistr �_timeout�_watchmanclient�_root�_ui�
_firsttime)r
�uir �timeout�errr r r r r 0 s
zclient.__init__c C s$ || _ | jd ur| j�|� d S d S r )r$ r% �
setTimeout)r
r* r r r �
settimeoutB s
�zclient.settimeoutc C s( | � d�}t�|d�stddd��|jS )Ns clock�clocks# clock result is missing clock valueT)r )�commandr � safehasattrr r. )r
�resultr r r �getcurrentclockG s
�zclient.getcurrentclockc C s
d | _ d S r )r% r r r r �clearconnectionO s
zclient.clearconnectionc C s | j d up| jS r )r% r( r r r r � availableR s zclient.availablec C s zt �� W S ty Y d S w r )�getpass�getuser�KeyErrorr r r r r" U s
�z client._userc
G s� |d | j f|dd � }z#| jd u r*d| _| j�dd�}tj| jdt� |�d�| _| jj
|� W S tj yT } zd|j v rHt
| j t�|j ���tt�|j ���d }~w tjyg } ztt�|���d }~ww ) Nr r Fr! s watchman_exeT)r* �useImmutableBser�binpathzunable to resolve root)r& r% r( r' �
configpathr r r$ r � tonativestr�query� CommandErrorr
r r � forcebytestrr �
WatchmanError)r
�args� watchmanargs� watchman_exe�exr r r �_command] s0
��
����zclient._commandc G sP z z| j |� W W S ty | � d� | j |� Y W S w ty' d | _� w )Ns watch)rD r r r% )r
r@ r r r r/ t s
� �zclient.commandN)r )
r r r r r- r2 r3 r4 r �
propertycacher" rD r/ r r r r r / s
r )�
__future__r r5 � mercurialr r �mercurial.utilsr r � r � Exceptionr r �objectr r r r r �<module> s