dE Z?d_dFZ@d eAeeBe f fdGZCd eAeeBe f fdHZDdI ZEdJ ZFdK ZGdL ZHdM ZIdN ZJdO ZKd eBe&eef fdPZLdQ ZMdR ZNdS ZOdT ZPdU ZQdV ZRdW ZSedX ZTdY ZUdZ ZVd[ ZWd\ ZXd`d]ZYd^ ZZd S )f QuotaWrapperaB
Base quota class for inode quotas handling
* Update system quotas via setquota
* Retrieves system quotas via repquota
* Stores current quotas in /etc/container/cl-quotas.dat file
* Maintaines /etc/container/cl-quotas.cache file with resolved quotas. That file can be read by non-privileged users
z /proc/mountsz/usr/bin/quotasyncz/usr/sbin/setquotaz/usr/sbin/repquotaz%/usr/bin/getcontrolpaneluserspackagesz /etc/container/cl-quotas.datz /etc/container/cl-quotas.cacheNz.lockFc H | t j | t j | t j t | _ d | _ i | _ i | _ i | _
i | _ i | _ i | _
| | _ g d| _ t# j | _ | | _ | | j | _ d | _ d | _ d S )N)
bytes_used
bytes_soft
bytes_hard inodes_used inodes_soft inodes_hard)_assert_file_existsru PROC_MOUNTSREPQUOTASETQUOTAlist_quota_enabled_list_panel_present_grace_quota
_device_quota_package_to_uids_map_uid_to_packages_map_uid_to_homedir_map_get_saved_data_handler_dh_fieldsosgeteuid_euid_load_quota_devices_devices_get_mountpoint_device_map_mountpoint_device_mapped_device_user_map_all_package_listr4 s r& r" zQuotaWrapper.__init__ s !9::: !6777 !6777#'66 " $&!$&!#% //11nnn Z\\
0022
)-)H)H )W)W& $ !% r' c j t j | st d| d dS )z>
Checks if command is present and exits if no
zNo such command (r N)r r[ exists RuntimeErrorr[ s r& r} z QuotaWrapper._assert_file_exists s>
w~~d## A , ?@@ @ A Ar' c | S rM r, r4 s r& __enter__zQuotaWrapper.__enter__ s r' c J | j | j d S d S rM )LOCK_FDclose)r$ _type_value
_tracebacks r& __exit__zQuotaWrapper.__exit__ s, < # L $ #r' c R | | | S )z9
Returns user limits converted to tuples
_convert_data_to_tuples_get_current_quotasr$ rT s r& get_user_limitsz QuotaWrapper.get_user_limits s& ++D,D,DS,I,IJJJr' c P | | S )z=
Returns all user limits converted to tuples
r r4 s r& get_all_users_limitsz!QuotaWrapper.get_all_users_limits s$ ++D,D,D,F,FGGGr' c T | | | S )z
:param packname: Package name for get limits. If None, returns all packages,
else - only supplied package
Returns package limits converted to tuples (called only from main)
)packnamer _get_package_quotasr# s r& get_package_limitsz QuotaWrapper.get_package_limits s) ++D,D,Dg,D,V,VWWWr' c V | | |d S )zY
Returns all packages limits converted to tuples (called only from main)
Tr all_packagesr r# s r& get_all_packages_limitsz$QuotaWrapper.get_all_packages_limits s, ++D,D,Dgdh,D,i,ijjjr' c H |dk rdS |dv rdS | | S )z
Preprocessed passed limit: 'default' --> '0', 'unlimited' --> -1, else calls _check_limit
:param limit:
:return:
r 0) unlimited-1r ) _check_limitr8 s r& _preprocess_limitz QuotaWrapper._preprocess_limit s9 I 3 ' ' '4 '''r' c ^ | j d| d S )Npackages:)r getsplitr# s r& _get_package_from_dhz!QuotaWrapper._get_package_from_dh s& x||J0066s;;;r' c l i }i }| j d rt | j d dk r| }| j d D ]`}|r ||vr | j d| $| | }t | dk rM|d |d f||< a|r| | | j
D ]}||v r || ||< d||< |S )z
Retrive all available packages with their limits
:param clean_dead_packages: if True - remove all nonexistent packages from cl-quotas.dat
:return: Dictionary: { 'package_name': (soft_limit, hard_limit) }
r r r r ) r has_sectionlenitems_get_all_package_listoptions
remove_optionr _write_data_get_package_to_users_mapr keys)r$ clean_dead_packagespackage_limits_dict db_packageslist_of_packagesr% package_limitss r& _get_all_packages_with_limitsz*QuotaWrapper._get_all_packages_with_limits sj ! 8
+ + #DHNN:4N4N0O0ORS0S0S # 9 9 ; ; 8++J77
L
L& 7:J+J+JH**:w??? !%!:!:7!C!C~&&!++ '5a'8.:K'K G$$"
# """ &&(((05577 : :G+%%/:7/C#G,,/9#G,,""r' TrT softhardsave
force_save
only_storec
| | | | | }}| ||| \ } }
| | |
\ } } | | | }
| | f|
d |
d fk s|r-|dk r| | | }|rS| d|
d d|
d d| d| d
}| j |d
|z | j |< t d nft j d ||
d |
d | | |g}t | t d
|
| t d| d |rB| |||| \ }}| ||| t d |dk r|dk s |dk r,|dk r&| ||| t d
|dk r%| t d dS dS )a6
Set limits for users
* Resolve limits according to those saved in cl-quota.dat
Limits are resolved in the following order:
user limits --> package limits --> root user (uid=0) limits
* Apply new limits when resolved limits differ from those in cache or when `force_save` is True
* Write updated values to cl-quota.dat if `save` is True
Always update cl-quota.dat in case both zeroes or both unlimited are provided
:param uid: user id
:param soft: soft limit value
:param hard: hard limit value
:param save: save limits to cl-quota.dat
:param force_save: save limits to cl-quota.dat even if they are not changed
:param only_store: store limits in memory, but do not apply them
:return: None
rT r r r r r{ r| r rx ry
z4Your quota limits have been stored only successfullyz-uz/Your quota limits have been stored successfullyz Your quota limits for device z have been applied successfully.)r z+Quota limits have been stored successfully.r z3Global quota limits have been applied successfully.N) _check_adminr _combine_user_limits_convert_for_sys_utilityr _get_home_device_fetch_homedirr r printru r r _sync_quota_files_get_user_limits_to_save_save_user_limits_apply_all_limits)r$ rT r r r r r soft_validatedhard_validated
soft_resolved
hard_resolvedsoft_convertedhard_convertedcacheddevicestdincmd
soft_user_dat
hard_user_dats r& set_user_limitzQuotaWrapper.set_user_limit s 8
*.)?)?)E)EtG]G]^bGcGc (,'@'@S~dr'@'s's$
} *.)F)FM`m)F)n)n& ))#..s3
N +}0EvmG\/] ] ]ak ]czz ..t/B/B3/G/GHH d " v vVL%9 v vF<d |
d z }
| j | d
|
z | j | < #|r1| ||| \ }}| ||| |s| dS dS )a,
Sets limits for package
:param package: package name
:param soft: soft limit value
:param hard: hard limit value
:param save: save limits to cl-quota.dat
:param only_store: store limits in memory, but do not apply them
:return: None
Tr N)rT r% r r r r{ r| r rx ry r r r )r r r r !_get_saved_package_limits_if_none_save_package_limits_check_package_exists_get_device_user_mapr r _combine_package_limitsr appendKeyErrorr joinr r _get_package_limits_to_save_flush_device_quota)r$ r% r r r r r r r r device_user_map
cached_quotasr std_inrT r r soft_cached hard_cached soft_data hard_datas r& set_package_limitz QuotaWrapper.set_package_limit` s# (
*.)?)?)E)EtG]G]^bGcGc 4<<t 7 7T 7 J JJJ4#A#A#C#CCC+/+Q+Q ,9 ,9 (M= % %g}m L L L F))'22 F 3355 0022
%**,, Y YFF55g>>
of 555 /3/K/KW> 0L 0X 0X,
} 261N1NTahu1N1v1v. / A A
D 6{{a ))F++d2-1-?-C-CFB-O-ORX-X"6* E#'#C#CG^]k#l#l Iy % %gy) D D D ' $ $ & & & & & ' 's A!F77
GGc | | d }| D ]"\ }\ }}| |||dd #| | dS )zN
Read limits from file and applies them to packages and users
T)r F)r r N)r r r r _remove_unexisting_usersr )r$ r r% r r s r& synchronizezQuotaWrapper.synchronize s
;;PT;UU%3%9%9%;%; U U !G\dD " "7D$Ut " T T T T %%''' """""r' c fdt t D } d t j }t j
|t j }| |
t j dS )zF
Caches the limits to non-privileged user to see them
c B g | ]gfd j D z S )c , g | ]} | S r, r, )rc fieldcurrent_quotasks r& rf z;QuotaWrapper.save_user_cache... s# FFF>!$U+FFFr' r )rc r r r$ s @r& rf z0QuotaWrapper.save_user_cache.. sK
CFFFFF FFF F
r' )keyT)quotingN)r r sortedr int_get_global_lock_prepare_writerru CACHEFILEcsvwriter
QUOTE_MINIMAL writerows _end_writer
_release_lock)r$
cache_content file_handlercsv_outr s ` @r& save_user_cachez QuotaWrapper.save_user_cache s
1133
N / / 1 1s;;;
d###++L,BCC *\33DEEE-((( /000 r' skip_rootc | D ]%}|dk r|r | |dddd &| dS )z=Set limits for all users. Skip root user if skip_root is Truer NFT)r r r r )_get_uid_to_packages_mapr r r )r$ r$ rT s r& r z QuotaWrapper._apply_all_limits sv 00227799 X XCczziz $TRV W W W W """""r' c d}| j D ]/}t j d|g}t || j | d}0|r| i | _ dS )z Write all device quotas to diskFz-bu)r TN)r r ru r r r )r$ quotas_writtenr r s r& r z QuotaWrapper._flush_device_quota s~ $(--// " "F (%8C D$6v$> ? ? ? ? !NN % " " $ $ $ r' r c |8t | }| dk rdS t j |g}nt j dg}t | dS )a
In order to sync inodes limits in kernel with limits in user.quota file run `quotasync` command.
Otherwise `repquota` called right after `setquota` may return old limits existed before `setquota` call.
Skipped on the XFS filesystem because XFS does not require a separate quota synchronization step
as it handles these operations in real-time. Additionally, the specific functionality required by `quotasync`
to sync the disk quota information is not implemented, resulting in an error.
Nxfsz-a)r lowerru QUOTASYNCr )r$ r fs_typer s r& r z QuotaWrapper._sync_quota_files s_ )&11G}}%'' )62CC )40CCr' c " | j d rt| j d D ]C} | | # t $ r | j d| Y @w xY w| dS dS )zARemove all records from cl-quota.dat for users which do not existusersN)r r r r r. r r r s r& r
z%QuotaWrapper._remove_unexisting_users s 8 ( ( x''00
9
99'',,,,* 9 9 9H**7C888889 s A%A65A6c T | | dS # t $ r Y dS w xY w)z Check whether package existsTF)r r r# s r& r z"QuotaWrapper._check_package_exists sF * *7 3 3 3 4 & 55 s
''r r c | | \ }}| ||| \ }}| |dd \ } }
|| k s|r||}||
k s|r||}||fS )z
Derive package limit values to save to cl-quota.dat
If None passed as limit to method, then replace it by the user's value from cl-quota.dat
Update cl-quota.dat only if the derivation result changes
rT r N)_get_user_limitsr ) r$ rT r r r r r r r soft_none_resolvedhard_none_resolveds r& r z%QuotaWrapper._get_user_limits_to_save s (,'<'<'<'E'E$
}'+'@'@S~dr'@'s's$
}151J1JsY]dh1J1i1i. . . . .: ..B\ *M . . .: ..B\ *M m++r' c T | | \ }}||n|}||n|}||fS )z3Derive package limit values to save to cl-quota.datr% )_get_package_limits)r$ r% r r p_softp_hards r& r z(QuotaWrapper._get_package_limits_to_save sF 11'1BB $2#= 6#1#= 6v~ r' c v | j ,dt ddg k | _ | j S )z6
Return True if control panel present
NUnknownz/usr/bin/cldetectz--detect-cp-nameonly)r r rstripr4 s r& _check_present_panelz!QuotaWrapper._check_present_panel* s> &"+{}|d |vr g ||d < ||d |d ?|| _ | j S )zF
Returns dictionary mapping devices to lists of users
Nr r )r _get_list_of_uidsr r r r )r$ devices_mapdevice_user_pairsrT pairs r& r z!QuotaWrapper._get_device_user_mapI s ,( ( ))++ C
!(($*?*?@S@STW@X@X*Y*Y[^)_````
% 1 1DAwk))') DG$ Q ' 'Q 0 0 0 0 + $$s =A((
A54A5r9 c ||dk r|S t j d }| | }|st | | d S )Nr z(\d+)r )recompilesearchr6 group)r$ r9
limit_pattern
pattern_matchs r& r zQuotaWrapper._check_limit] s` =ETMML
8,,
%,,U33
7/66 6 ""1%%%r' c v |dk r3| ||| \ }}|dk r|nd|dk r|nd}}||fS | ||| \ }}| | D ] }| ||| \ }} | d|| \ }}|dk r|nd|dk r|nd}}||fS )a
Determines user limits by resolving them according to the limits inheritance rule:
user limits ---(overridden by provided as method param if provided not None)--->
---> package limits ---> root user (uid=0) limits
uid: user id
soft: Optional[str] = None: limit value, can be:
* None -- value not passed
* "-1" -- unlimited
* "0" -- default (next value from hierarchy should be considered)
* "1", "2", ... -- precice limit values
hard: soft: Optional[str] = None: limit value, values range the same as for soft
return: Tuple[str, str]: (soft_limit, hard_limit), they can be:
* "-1" -- unlimited
* "1", "2", ... -- precice limit values
r r r )r% r r ) _get_user_limits_override_noner& $_get_package_limits_override_default!_get_user_limits_override_default)r$ rT r r r% s r& r z!QuotaWrapper._combine_user_limitsf s $ #:: <<4VZ<[[JD$"&#++$$4RV$D: 88StRV8WW
d44S99 j jG BB7Y]dhBiiJD$$;;$UY;ZZ
d "ckkddtTS[[TTddTzr' c | | \ }}| ||n| }| ||n| }||fS )a Get user limits from cl-quota.dat. If limit is None, then override it by user's limit
:param str uid: user id
:param Optional[str] soft: limit value, can be:
* None -- value not passed, should be overridden by user's limit
* "-1" -- unlimited
* "0" -- default (next value from hierarchy should be taken)
* "1", "2", ... -- values
:param Optional[str] hard: limit values same as for soft
:return Tuple[str, str]: derived limits
r2 Nr9 r3 r r$ rT r r user_soft user_hards r& rU z+QuotaWrapper._get_user_limits_override_none sg $ 4 4 4 = = 9 t/?ttY OO t/?ttY OOTzr' c | | \ }}| |dk r|n| }| |dk r|n| }||fS )a Get user limits from cl-quota.dat. If limit is default, then override it by user's limit
:param str uid: user id
:param Optional[str] soft: limit value, can be:
* "-1" -- unlimited
* "0" -- default (next value from hierarchy should be taken)
* "1", "2", ... -- values
:param Optional[str] hard: limit values same as for soft
:return Tuple[str, str]: derived limits
r2 r rY rZ r[ s r& rW z.QuotaWrapper._get_user_limits_override_default sm $ 4 4 4 = = 9 ts{{tt JJ ts{{tt JJTzr' c | j d| d \ }}n&# t j t j f$ r d\ }}Y nw xY w||fS )z*Try to get user's limits from cl-quota.datr/ r r )r r r rF NoSectionError
NoOptionError)r$ rT r\ r] s r& r3 z QuotaWrapper._get_user_limits sp ,#'8<<#=#=#C#CC#H#H Iyy +\-GH , , ,#+ Iyyy ,)##s 14 AAc | | \ }}| |dk r|n| }| |dk r|n| }||fS )zeGet package limits from cl-quota.dat. If passed limit is default, then override it by package's limitr7 r rY )r8 r r$ r% r r pack_soft pack_hards r& rV z1QuotaWrapper._get_package_limits_override_default sk # 7 7 7 H H 9 DCKKyyT JJ DCKKyyT JJTzr' c | | \ }}n&# t j t j f$ r d\ }}Y nw xY w||fS )z-Try to get package's limits from cl-quota.datr )r rF r` ra r$ r% r r s r& r8 z QuotaWrapper._get_package_limits s] " 227;;JD$$ +\-GH " " "!JD$$$ "Tzs >>c * | dk rd} |dk rd}| |fS )zAConverts limits for setquota utility which threats 0 as unlimitedr r r, r s r& r z%QuotaWrapper._convert_for_sys_utility s* 4<<D 4<<DTzr' c
| | \ }}t r|t rn| | }||k r8| |d }|| d x}} || d x}}
n3| | \ } }
n| | \ } }
|dk r|n||n| }|dk r|n||n|
}| d|| \ }}|dk r|nd
|dk r|nd
}}||fS ) z[
Determines package limits taking into account saved user and default ones
r2 Tr r{ r| r7 r Nr r )r3 IS_DArs _get_da_real_packager r8 rW ) r$ r% rT r r u_softu_hardda_real_packageda_real_quotasr9 r: s r& r z$QuotaWrapper._combine_package_limits sT
..3.77 G133 G # 7 7C 7 @ @O '))!%!9!9?ae!9!f!f . ?
NNv . ?
NNvv!%!9!9'!9!J!J ! 5 5g 5 F FNFF
3 vvT5ETT6 3 vvT5ETT6 ;;$UY;ZZ
d "ckkddtTS[[TTddTzr' c | | \ }}||dk r|}||dk r|}n!# t j t j f$ r Y nw xY w| | }| | }||fS )zF
Applies saved package limits if none has been passed
Nr )r rF r` ra r rc s r& r z.QuotaWrapper._get_saved_package_limits_if_none s #'#<#z(QuotaWrapper._populate..C s !d1Q4j/A r' )rB r map enumerater )r$ itemr s `r& r zQuotaWrapper._populateB sH d4%A%A%A%AIdl[\[][]N^D_D_ ` `aabbccr' c h t | S rM )r r r r4 s r& r} z"QuotaWrapper._get_list_of_packagesE s( D224499;;<<# t t t f$ r$}t dt | z d}~ww xY wt
t }t
t | _ | D ]f\ }}t | }|d |d nt }|| | | j | | g t d }n8# t t f$ r$}t dt | z d}~ww xY w|D ]!}|
||nt g "|
t g |S )a
Retrieve package-uids map from cpapi. Only for custom panels. See LU-610 for details.
Null packages coming from cpapi are considered to be 'default' package.
:return: Dictionary with data.
Example response:
{'default': ['1038', '1043', '1046'], 'res1_pack1': ['1044'], 'pack1': ['1042']}
Coorresponding self._uid_to_packages_map value:
{'1038': ['default'], '1042': ['pack1'], '1043': ['default'], '1044': ['res1_pack1'], '1046': ['default']}
z%s. Can not get usersNr% T raise_exc %s. Can not get admin packages)r OSErrorr r r rC r r r r r~ r r
setdefault) r$ users_packagesrG packages_usersrT uid_datas_uidr%
admin_pkgss r& _get_packages_uids_from_cpapiz*QuotaWrapper._get_packages_uids_from_cpapii s L '\\NN3]C L L L'(?3q66(JKK K L %T**$/$5$5! + 1 1 3 3 = =MCHHE-5i-@-Lhy))RdG 7 # * *5 1 1 1 %e , 3 3G < < < < U'$777JJ34 U U U'(HCPQFF(STT T U " b bG % %1DggJ\^` a a a a!!"4b999 s, A AA 8D D> D99D>c i }| j dk r|S | sTt t t t |t < d |t D | _ |S | S )z
Gets map of packages and users
:rtype dict
:return Dictionary with data. Example:
{'default': ['1038', '1043', '1046'], 'res1_pack1': ['1044'], 'pack1': ['1042']}
r c i | ] }|t g S r, )r~ )rc is r&
z8QuotaWrapper._load_package_uids_data.. s (g(g(gQ-?,@(g(g(gr' ) r r> r r rC rj r~ r r )r$ r s r& r z$QuotaWrapper._load_package_uids_data s :??O((** +/C 9J9J0K0K+L+LH' ((g(g(SeJf(g(g(gD %O11333r' c f | j r| j S g | _ t d }|D ] }| j | n8# t t f$ r$}t dt
| z d}~ww xY w t d }| D ]!}|D ] }| j | "n8# t t f$ r$}t dt
| z d}~ww xY wt | j vr | j t | j S )zm
Retrives all (root and resellers) panel package list
:return: List of package names
Tr r Nz!%s. Can not get reseller packages)
r r r r r r rC r r r~ )r$ list_admin_packagesr% rG dict_resellers_packages
packages_lists r& r z"QuotaWrapper._get_all_package_list s ! *) ) U%'D ""04"@"@"@ .
7
7&--g6666
734 U U U'(HCPQFF(STT T U X&84&H&H&H #!8!?!?!A!A
;
;
, ; ;G*11'::::;
; 34 X X X'(KsSTvv(VWW W X T%; ; ; " ) )*< = = =%%s0 6A A< A77A< AC C< C77C<c D ]F t t fd| j dd }|< 7# t $ r Y Cw xY wS )zI
Convert dict to tuples for passing to printing routines
c $ | | fS rM r, )r r r s r& r z6QuotaWrapper._convert_data_to_tuples.. s ac1 -> r' r N)r tupler r r )r$ r entryr s ` @r& r z$QuotaWrapper._convert_data_to_tuples s 99;; C
c#>#>#>#>#> abbAQ R RSS !S
s 3A
AAc
i }d} j }t j dg}t | }t j dt j }| D ]}| d r|s | }t | dk r | }|d dd } | dk ro ||vr | }||v rn
| | rEt t! t# fd t% |d
d || < # t& t( t* f$ r Y w xY w| d r1|| d d }`d
|v rZ| | }
|
rC j t t! t# d |
| |S )zZ
Gets current quota settings from repqouta utility for further processing
Nz-unaz2(block|inode)\sgrace\stime:?\s(\d[\w:]+)(?:;|$|\s)# r r r c : j | d | d fS Nr r r )r r$ s r& r z3QuotaWrapper._load_current_quotas.. s 4<!;MqQRt:T r' r z***z/devgracec F | d | d fS r )r+ )r s r& r z3QuotaWrapper._load_current_quotas.. s 1 qQRt@T r' ) r ru r r rN rO
IGNORECASE
splitlinesrZ r r #_remove_redundant_fields_from_input_find_unknown_device_is_home_devicer rB r r r r
IndexErrorr. findstripfindallr r _add_default) r$ r r devicesr r grace_regex_patternlinepartsrT founds ` r& ry z!QuotaWrapper._load_current_quotas sJ
-$f-3 j)^`b`m n nOO%% a aDs##
a
u::?? D DU K KEAhqrrl#:: W,,!%!:!:6!B!B ((T-A-A$BUBUVYBZBZ\b-c-c(!%d30T0T0T0TW`afghgigiajWkWk+l+l&m&m!n!n# *.AB H ''
a dii / / 0 017799D +33D99 aK&&tD6T6TW\1]1],^,^'_'_``` ""$$%%%s
B EE43E4c |d d }t j d | fd|dd D |S )Nr z^\d+$c > g | ]} | |S r, )rP )rc r is_digit_patterns r& rf zDQuotaWrapper._remove_redundant_fields_from_input.. s- L L Lu-=-D-DU-K-K LU L L Lr' )rN rO r )r$ r stripped_partsr s @r& r z0QuotaWrapper._remove_redundant_fields_from_input s` rr :h// L L L Labb L L L N N N r' c t | j dk r5| j d t j D | j | S # t
$ r t
| w xY w)Nr c B i | ] }t |j |j S r, )rC rb ra )rc r s r& r z/QuotaWrapper._fetch_homedir.. s' ,i,i,iQVS ->-> ,i,i,ir' )r r r pwdgetpwallr r. r s r& r zQuotaWrapper._fetch_homedir s t' ( (A - - $ + +,i,iZ]ZfZhZh,i,i,i j j j ++C0 0 + + +%c** * +s A A6c i }t t j }t j d }|D ]}| d r| | }|d }d|d i}|D ]~}| d s| d r | d d |d < K| d
r | d d |d < ||v r || | |g||< | t | dk rt |S ) aj
Gets mounted filesystems list and picks ones with quota on
Example of returned data structure:
{'/dev/mapper/VolGroup-lv_root': [
{'mountpoint': '/', 'quota_file': 'quota.user', 'quota_type': 'vfsv0'},
{'mountpoint': '/var', 'quota_file': 'quota.user', 'quota_type': 'vfsv0'}
],
'/dev/mapper/VolGroup-lv_root2': [
{'mountpoint': '/', 'quota_file': 'quota.user', 'quota_type': 'vfsv0'},
{'mountpoint': '/var', 'quota_file': 'quota.user', 'quota_type': 'vfsv0'}
]
}
z |,zrootfs /r
mountpointr z usrquota=zusruota==
quota_filezjqfmt=
quota_type) openru r~ rN rO rZ r r r r rO ) r$ r proc_mounts_stream
split_pattr line_splitedr mountpoint_dataline_splited_elements r& r z QuotaWrapper._load_quota_devices sy !,": ; ;Z''
& 4 4Dz**
%++D11L!!_F +l1o >O(4
W
W$'22;?? WCWCbCbcmCnCn W4H4N4Ns4S4STU4VOL11)44X>> W4H4N4Ns4S4STU4VOL1 &&7777#2"3 """ w<<1 (** *r' c > i } t t j }t j |d }n_# t t f$ rK t j t j d icY
S w xY w
n#
w xY wt j }|D ]xd |k rj| d t t t! fdt# t% j i ny|s4t j t j d iS |S )zJ
For non-privileged user we outputting data from the file
,) delimiterr r c 4 j | | dz fS )Nr r )r rowr$ s r& r z/QuotaWrapper._load_user_cache..: s Q #AaC * r' )r r ru r r readerr IOErrorrC r rB fromkeysr r r r r ranger )r$ r focvs_inrT r s ` @r& rx z QuotaWrapper._load_user_cache' s
! ! ! # # #l,--BZc222FF! G G G
OOT]]4<%E%EF F F G
D $*oo C1v}}#a&$tC* * * * *#dl++,,-. -. (/ (/ #0 #0 1 2 2 2 G
OOT]]4<%E%EF Fs+ AA
B?
AB&B? %B&&B? ?Cc d }g }| D ])\ }}|D ]!}|d }| ||f "*| |d |S )z
return list tuple ('mountpoin tpath', 'device') reverse sorted by deep mountpoint path
[('/mountpoint_path/path', '/device'), ('/mountpoint_path', '/device')]
c Z | d dk rd}n| d d }|S )Nr rY )count)device_mountpoint deep_paths r& sort_by_deep_pathzBQuotaWrapper._get_mountpoint_device_map..sort_by_deep_pathH s7 #s** -a 0 6 6s ; ; r' r T)r reverse)r r sort)r$ r r mountpoint_device_mapr mountpoint_data_listr mountpoint_paths r& r z'QuotaWrapper._get_mountpoint_device_mapC s
!# ,3MMOO H H (F(#7
H
H"1,"?%,,ov-FGGGG
H ""'8$"GGG$$r' c d } |t j | }| j D ]'\ }}| || r|c S (dS )z3
Returns device user homedir is on
c , | r| d dk r| dz
} | S )NrX rY r, r s r&
_add_slashz1QuotaWrapper._get_home_device.._add_slashZ s$
RC Kr' N)r r[ dirnamer rZ )r$ homer r mounpoint_pathr s r& r z QuotaWrapper._get_home_deviceV s *RW__T 2 233&*&D "NF!!**^"<"<==
r' c 4 | | |k S )z;
Checks if a device is user homedir device
)r )r$ r r s r& r z QuotaWrapper._is_home_devicec s $$T**f44r' c t j | t }t j | t j | f}| j D ]Q}t j | t }|t j | t j | fk r|c S Rd S # t $ r |cY S w xY wrM )r statr majorminorr r r )r$ r dev dev_to_findcurrent_devices r& r z!QuotaWrapper._find_unknown_devicei s '&//&)C 8C=="(3--8K"&-"4"4"6"6
*
*gn--f5 28C=="(3--"@@@)))) A
*
* MMM s B0B6 3B6 6 CCc g d | j dd d \ }}|dk rd}|dk rd} ||g n8# t j t j f$ r ddg Y nw xY wdt t t fdt | j iS )zw
Insert 'default' quota.
Calls only from _load_current_quotas, after parsing repquota's output
)r| r r r| r/ r r r c 0 | d | d fS r r, )r r s r& r z+QuotaWrapper._add_default.. s qtVAaD\.B r' ) r r r r rF r` ra rB r r r r )r$ r\ r] r s @r& r zQuotaWrapper._add_defaultt s
&%% &#'8<<#=#=#C#CC#H#H IyD D MM9i0 1 1 1 1 +\-GH & & & MM3* % % % % % &T$s$B$B$B$BYt|E\E\ ] ]^^__``s AA 2BBc l |d}|d}|dk r<|dk r6| j d r | j d| nU| j d s| j d | j d||d| | dS )z#
Saves user limits
Nr r/ r )r r r add_sectionsetr )r$ rT r r s r& r z QuotaWrapper._save_user_limits s <D <D 3;;43;;48+?+?+H+H; H " "7C 0 0 0 08''00
.$$W--- HLL#$$$'= > > > r' c |d}|d}|dk r<|dk r6| j d r | j d| nU| j d s| j d | j d||d| | | | dS )z&
Saves package limits
Nr r r )r r r r r r _copy_package_limits_to_cpanelrg s r& r z!QuotaWrapper._save_package_limits s <D <D 3;;43;;48+?+?
+K+K; H " ":w 7 7 7 78''
33
1$$Z000 HLLWtt.D E E E ++G44444r' c | t j sdS d| }t | }t | dk rdS | | \ }}||dS | |d | }| D ]\ }}|dk rd||< | dd | d
d f} |d |d
f}
| |
k rdS d D ]E} d t | z d
z t || z dz } | | Ft ||d dS )zV
Copy package quota limits from cl-quotas.dat to cpanel packages data
Nz/var/cpanel/packages/r Tr r| r r{ r r| r{ r| lve_r r w) ro is_cpanelr r _parse_cpanel_package_datar r r rC r r )
r$ r% package_pathcpanel_package_linesold_cpanel_datamodified_cpanel_lines quotas_datar valueold_cpanel_limitscurrent_quota_limits
limit_type limit_strings
r& r z+QuotaWrapper._copy_package_limits_to_cpanel s $&& F8w88 -l ; ; # $ $ ) ) F151P1PQe1f1f.. "'<'D F..wT.JJ7S &++-- ( (JC||#' C , 0 0 D DoFYFYZgilFmFm n +M :K
> D D F F
a=I--2>> 455
"%t:K:K!zz ===r' c T |dk r8|dk r2 | j || nj# t j $ r Y nYw xY w| j | s| j | | j |||d| | dS )z&
Saves data to a file
r r N)r r rF r` r r r r )r$ r r r item_types r&
_save_datazQuotaWrapper._save_data s 3;;43;;
&&y$7777 .
8'' 22
0$$Y/// HLLDTTT44*@ A A A s * <<c ^ t j | } t j d| \ }}t j |d }|| _ |S # t t f$ rC t j | rt j
| t d w xY w)zH
Open temporary file for writing and return file object
lvetmp_)prefixdirr zCould not save data) r r[ r tempfilemkstempfdopen_tmpr r r unlinkrK )r$ filepathr[ fd temp_pathr! s r& r z QuotaWrapper._prepare_writer s wx(( : $ ,I4 H H HMB 9R--L!DI ! : : :w~~i((
% )$$$"#899 9 :s 6A AB,c t t z t z t z }t j | j | t j || dS # t $ r Y dS w xY w)z0
Routines after writing to file
N) r r r r r renamer' chmodr )r$ r[ masks r& r zQuotaWrapper._end_writer si W$w.8D Idi & & & HT4 DD s AA
A A c | d | t j }| j | | t j | dS )z7
Actual place of saving data to a file
TN)r r ru rE r writer r )r$ r! s r& r zQuotaWrapper._write_data sq
d###++L,ABB |$$$ ./// r' c |r dt _ t j t t j d t _ n$# t
t f$ r t d w xY w t j t j
t j d S # t
$ r t d w xY wd S )NTrz Can't open lock file for readingzCan't get lock) ru
LOCK_WRITEr r LOCK_FILEr r rK fcntlflockfilenoLOCK_EX)r$ r1 s r& r z QuotaWrapper._get_global_lock s +&*L # '
K'+L,BC'H'H $$W%
K
K
K&'IJJJ
K
9 L 0 7 7 9 95=IIIII
9
9
9&'7888
9 ( 's $A !A"&;B# #B=c t j s8t j .t j d t _ d S d S d S rM )ru r4 r r r4 s r& r zQuotaWrapper._release_lock sH ' (l.B.N & & ( ( (#'L ( (.N.Nr' rM )F)NNTFF)NNTF)Tr )NF)[r) r* r+ rE r~ r, r r GETPACKSrE r r r5 r4 r" staticmethodr} r r r r r r r r r rC r boolr r r r# r r r r
r r r r r> r rF r r r r rU rW r3 rV r8 r r r rk r r r r} rI r rz r& r r
r r r r ry r r r rx r r r r r r r r r r r r r r r r, r' r& ru ru s !K%I$H$H7H.H0IG7"IJ& & &, A A \A ! ! !K K K H H H X X Xk k k k
(
(
(< < < # # # #J #'"& $ $KI KIKI 3-KI 3- KI
KI
KI KI KI KI KI` #'"& $
G' G'G' 3-G' 3- G'
G'
G'
G' G' G' G'R # # # ,# #4 # # # # d
$ % , ,, %SM, %SM ,
,
x}hsm+ ,
, , , ,0 08
OWX[} afgjlogoap # # #4 4 4 )B % % %(&(3- &HSM & & & & 8C= xX[} hmnqsvnvhw @ # Xc] YabeYf rwx{ ~A yA sB $S 3 SXY\^aYaSb "$C $E#s(O $ $ $ $C s RU Z_`ceh`hZi 3 5c? x} HSM eT\]`TacklocpTpNq \ %( 08
EMc] W\]`be]eWf > F F F F F F $, , , ,\d d d= = =< < <) ) ) )1 1 1) ) ) )) tCcN/C ) ) ) ) V4c49n)= 4 4 4 4$& & &6
" " "H + + +% % %N 8%T%S/5J % % % %& 5 5 5 a a a$ $5 5 5$C C C: > > \>&
:
:
: 9 9 9 9( ( ( ( (r' ru )> configparserrF r r6 r r rN r$ collectionsr r r r r r r typingr r
r r rs ro clcommonr
clcommon.clpwdr clcommon.clquotar clcommon.cpapir r r clcommon.cpapi.cpapiexceptionsr r clcommon.utilsr r r r r detectis_darj DEFAULT_PACKAGEr~ r! r r. r2 r6 r; rK rO rR r^ rj r= rs objectru r, r' r& rK s} $ # # #
# # # # # # ; ; ; ; ; ; ; ; ; ; ; ; ; ; . . . . . . . . . . . . ' ' ' ' ' ' 0 0 0 0 0 0 I I I I I I I I I I T T T T T T T T !!##! F F F F FY F F F
@ @ @ @ @) @ @ @
< < < <