~k=FL h d dl Z d dlmZ d dlmZ d dlmZ d dlmZm Z d dl
m Z G d d Z dS ) N)NameMap)lvp_list) exec_utility)(_convert_memory_value_to_adaptive_format"check_pmem_lower_bound_from_string)LvectlExceptionc 0 e Zd Zd ZddZddZd Zd ZdS )
LveCtlPackagec d | _ d| _ d | _ t | _ | j d S )Nz/usr/sbin/lvectl) _lve_version
_UTILITY_PATH_packages_data_listr _name_map
link_xml_node)selfs $py/clpackages/lvectl_packages_lib.py__init__zLveCtlPackage.__init__ sA / $( $$&&&&& Fc L j dS ddg}|s| d t j | \ }}t j | }|dk rt
|d |d }g _ t fdt D }|D ]}|d } | d
v rd } |d }
i } t |d
| d< t |d | | d< d|v rt |d | | d< t |d | d< d|v rt |d | d< dt |d i| d< d|v rt |d | d< d d v rd } n| |v } |
| | | d }
j |
dS ) z
Loads all package info from lvectl
:param human_readable_numbers: PMEM and VMEM limits in KBytes, MBytes or GBytes
:return: None
Nzall-package-listz--jsonz--bytesr msgdatac 3 L K | ] }j | V d S )N)r get_name).0uidr s r z+LveCtlPackage._load_info..: s3 R Rt~ 6 6s ; ; R R R R R Rr RESELLER)zN/ArootIDSPEEDspeedVMEMvmemPMEMpmemEPepNPROCnprocallIOioIOPSiopsprovider)r F)packager/ limits
enabledLimits) r appendr r
jsonloadsr setr intr )r human_readable_numbers
lvectl_cmdret_codelvectl_data_str loaded_json json_dataactive_resellers package_data
reseller_name package_namepackage_limitsr3 package_result_dicts ` r
_load_infozLveCtlPackage._load_info$ s) # / F((3
% ) i ( ( ($01CZ$P$P!/j 11 q==!+e"455 5 ' #% R R R Rxzz R R RRR % " A " AL ( 4M '' &
'-L N&),w*?&@&@N7 #%M V$&& &N6 " %%)Q (** *v& $'|D'9#:#:N4 ,&&*-l7.C*D*Dw'$)3|D/A+B+B#CN4 %%),\&-A)B)Bv&\)) %
-1A A
' )(!. # #
$ + +,? @ @ @ @E" A " Ar c | | |s| j S g }| j D ]G}|d |k r9|r"|d |k r| | 2| | H|S )a
Get limits for supplied reseller and package
:param reseller_name_arg: Reseller name. If None - all resellers
:param package_name_arg: Package name. Only if reseller name is provided. If None - all packages
:param human_readable_numbers: PMEM and VMEM limits in KBytes, MBytes or GBytes
:return: Data list
List item format:
{
"package": "Basic_16",
"provider": "Reseller_Peter",
"limits": { "vmem": 768, "pmem": 768, "ep": 25, "nproc": 50, "iops": 100, "speed": { "all": 50 },
"io": { "all": 5 }, "inodes": { "soft": 100000, "hard": 200000 }
}
)r9 r/ r1 )rE r r4 )r reseller_name_argpackage_name_argr9
out_data_listr@ s r get_reseller_package_limitsz)LveCtlPackage.get_reseller_package_limits_ s $
/EFFF ,+ +
4 7 7LJ'+<<<# 7#I.2BBB%,,\::: "(( 666 r c $ d|||rd| dndddS )Nz3%(what)s set error for package=%(package)s%(error)sz []r0 )whatr1 error)messagecontext )r paramrB errs r __set_errorzLveCtlPackage.__set_error s< P$)l47%?[#[[[[R A AB B Br c |sdS d|v r&t |d }|rt | d|g}|dk r| d| | D ]?\ }}|dk r| r| d}| d| d | @t | j |d
\ }} }
|d k s|
r$t | d ||
dS )
a
Sets limits for supplied package
:param reseller_name: Reseller name
:param package_name: Package name
:param limits_to_set: new LVE limits. Available keys: speed, vmem, pmem,
maxEntryProcs, io, nproc, iops
All other keys are ignoring. If some parameter absent on current LVE version
(for example pmem on LVE4), it will be ignored too.
:return: None
Nr% zpackage-set-extr z --reseller=r! %z--=Tr Limits)r r r4 itemsisdigitr r
_LveCtlPackage__set_error) r rA rB
limits_to_setrN r:
limit_name limit_valuer;
lvectl_stdout
lvectl_stderrs r set_reseller_package_limitsz)LveCtlPackage.set_reseller_package_limits s; F ] " "6}V7LMME
-%e,,, ( 6
F " " ;M ; ; < < <'4':':'<'< ? ? #J W$$)<)<)>)>$!, / / / =: = = = = > > > >1=d>PR\^b1c1c.- q==M=!$"2"28\="Y"YZZ Z =r N)F)__name__
__module__ __qualname__r rE rJ r[ ra rQ r r r
r
sw
'
'
' 9A 9A 9A 9Av" " " " HB B B
[ [ [ [ [r r
)
r5 lveapir lvectllibr cllimits.libr cllimits.lib.utilsr r cllimitsr r
rQ r r rj s % % % % % %D D D D D D D D $ $ $ $ $ $T[ T[ T[ T[ T[ T[ T[ T[ T[ T[r