HgddlZddlmZmZmZmZddlmZddlm Z m Z m Z ddl m Z ddlmZejeZd ed ed eed ged ffdZGdd eZdS)N)ListOptionalDictCallable)Device)DriveGroupSpecDeviceSelectionDriveGroupValidationError)FilterGenerator) _MatchInvalidfreturnDriveSelectionr rc ddddtdtddttffd }|S)Nselfrnamedsr rc ||S#t$r/}t|jjd||jdd}~wwxYw)N.r)rr spec service_idargs)rrrers J/usr/lib/python3/dist-packages/ceph/deployment/drive_selection/selector.pywrapperz to_dg_exception..wrappersf Y1T2;;  Y Y Y+ty/C,L,Ld,L,LafUViXX X Ys  A*AA)strrrr)rrs` rto_dg_exceptionrs\Y&YcYx@Q7RYW[\bWcYYYYYY NceZdZ ddZdZdZdZdZdede e d e d e fd Z ed Zed Zd e fdZdS)rNc||_||_|pd|_|d|jj|_|d|jj|_|d|jj |_ |d|jj |_ dS)Nr data_devices wal_devices db_devicesjournal_devices) copydisksrexisting_daemonsassign_devicesr#_datar$_walr%_dbr&_journal)rrr(r)s r__init__zDriveSelection.__init__s ZZ\\  0 5A((9OPP '' ty7LMM &&|TY5IJJ++,=ty?XYY r c|jSN)r+rs rr#zDriveSelection.data_devices(s zr c|jSr1)r,r2s rr$zDriveSelection.wal_devices,s yr c|jSr1)r-r2s rr%zDriveSelection.db_devices0s xr c|jSr1)r.r2s rr&zDriveSelection.journal_devices4s }r device_filterdevices disk_pathrc|jpd}d|D}|dkrKt||jz|kr0td||dSdS)a Check for the property and apply logic If a limit is set in 'device_attrs' we have to stop adding disks at some point. If limit is set (>0) and len(devices) >= limit :param List[Device] devices: Already populated device set/list :param str disk_path: The disk identifier (for logging purposes) :return: True/False if the device should be added to the list of devices :rtype: bool rc g|] }|j | S) ceph_device.0ds r z1DriveSelection._limit_reached..QsDDD!amDADDDr z,Refuse to add {} due to limit policy of <{}>TF)limitlenr)loggerdebugformat)rr6r7r8rAnon_ceph_devicess r_limit_reachedzDriveSelection._limit_reached8s$#(qEDwDDD 199#.//$2GG5PP LLGNN5"" # # #4ur c|jr4td|jdSt d|)z3 Check for mandatory identification fields zFound matching disk: {}Tz(Disk {} doesn't have a 'path' identifier)pathrCrDrE Exception)disks r_has_mandatory_identsz$DriveSelection._has_mandatory_identsYs] 9 I LL299$)DD E E E4:AA$GGII Ir cB|stdgS|jjstdgS|jr!td|jSt }|jD]֊tdjj s@j s9tdjj |j sj rj rd}j D]E}d| vr-|dt|jjkr |d}nF|r5tdj||s4td j`|||jr5td jn'|vr|jjd kr\t'fd t)|Ds4td j#|jjdkr\t+fdt)|Ds4tdjtdj||D]%}||jvr|j|&t1d|DdS)a Assign drives based on used filters Do not add disks when: 1) Filter didn't match 2) Disk doesn't have a mandatory identification item (path) 3) The set :limit was reached After the disk was added we make sure not to re-assign this disk for another defined type[wal/db/journal devices] return a sorted(by path) list of devices zdevice_filter is Nonezdata_devices is Nonez%device filter is using explicit pathszProcessing disk {}z/Ignoring disk {}. Disk is unavailable due to {}osdspec_affinityz+{} is already used in spec {}, skipping it.z*Ignoring disk {}. Missing mandatory identszIgnoring disk {}. Limit reachedANDc3BK|]}|VdSr1comparer>mrKs r z0DriveSelection.assign_devices..-SSq199T??SSSSSSr z3Ignoring disk {}. Not all filter did match the diskORc3BK|]}|VdSr1rRrTs rrVz0DriveSelection.assign_devices..rWr z,Ignoring disk {}. No filter matched the diskzAdding disk {}cg|]}|Sr;r;)r>xs rr@z1DriveSelection.assign_devices..s***Qq***r c|jSr1rI)devs rz/DriveSelection.assign_devices..sCHr )key)rCrDrr#pathslistr(rErI availabler<rejected_reasonslvskeysrrrLrG filter_logicallr anyappendremovesorted)rr6r7other_osdspec_affinitylv taken_devicerKs @rr*zDriveSelection.assign_deviceses"  LL0 1 1 1Iy%  LL/ 0 0 0I   ' LL@ A A A & &&&J4 !4 !D LL-44TY?? @ @ @> $*:  55;VDItG\5]5]> d&6 48 )+&(""B)RWWYY6601S9M5N5NNN578J5K2!E)LL"006tyBX0Y0Y[[[--d33  @GG ##$$$""='49EE  >EEI   wy%..SSSSOM4R4RSSSSSLLMTT I''(((y%--SSSSOM4R4RSSSSSLLFMM I''((( LL)00;; < < < NN4 $ 0 0Ltz)) !!,///**'***0D0DEEEEr cd|jDd|jDd|jDd|jDdddfdDS) Ncg|] }|j Sr;r]r=s rr@z+DriveSelection.__repr__..s888QV888r cg|] }|j Sr;r]r=s rr@z+DriveSelection.__repr__..s666qAF666r cg|] }|j Sr;r]r=s rr@z+DriveSelection.__repr__..s444a16444r cg|] }|j Sr;r]r=s rr@z+DriveSelection.__repr__..s>>>1>>>r )z data devicesr$z db deviceszjournal deviceszDeviceSelection({})z, c3PK|] }d||V!dS)z{}={}N)rE)r>r` selections rrVz*DriveSelection.__repr__..s5VVcgnnS)C.99VVVVVVr )r+r,r-r.rEjoinrf)rrvs @r__repr__zDriveSelection.__repr__s88TZ88866DI6664448444>> >>> + + %++ IIVVVVY^^EUEUVVV V V   r r1)__name__ __module__ __qualname__r/r#r$r%r&r rrrboolrG staticmethodrLrr*rxr;r rrrs#' Z Z Z Z&f   B I I\ IXFXF_XFt  #       r )loggingtypingrrrr inventoryr drive_groupr r r filterr matchersr getLoggerryrCrrobjectrr;r rrs111111111111TTTTTTTTTT############  8 $ $xH.>.67H.I.K-1(^.<%=p p p p p Vp p p p p r