| Server IP : 61.19.30.66 / Your IP : 216.73.216.15 Web Server : Apache/2.2.22 (Ubuntu) System : Linux klw 3.11.0-15-generic #25~precise1-Ubuntu SMP Thu Jan 30 17:39:31 UTC 2014 x86_64 User : www-data ( 33) PHP Version : 5.3.10-1ubuntu3.48 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /usr/lib/python2.7/dist-packages/landscape/monitor/ |
Upload File : |
ó
}9Rc @ sœ d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z d d l m
Z
d d l m Z d d l
m Z d e f d „ ƒ YZ d S( iÿÿÿÿN( t fetcht
HTTPCodeErrort PyCurlErrort
FetchError( t CoverageMonitor( t get_active_device_info( t
MonitorPlugint SwiftDeviceInfoc B s} e Z d Z d d e j d d d „ Z d „ Z d „ Z e d „ Z d „ Z d
„ Z
d „ Z d „ Z d
„ Z
d „ Z RS( s swift-device-infoi, i< s /etc/swift/object-server.confs /etc/swift/object.ring.gzc C sp | | _ | | _ | | _ t | _ t | _ | | _ | | _ d | _
| | _ g | _ g | _ t
| _ d S( N( t run_intervalt _monitor_intervalt _create_timeR t _fetchR t _get_network_devicest
_swift_configt _swift_ringt Nonet _swift_recon_urlt _swift_device_infot _swift_device_info_to_persistt Truet enabled( t selft intervalt monitor_intervalt create_timet swift_configt
swift_ring( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt __init__ s c C s’ t t | ƒ j | ƒ t | j d d d | j ƒ| _ | j j j | j
| j j ƒ | j j j d | j j d d ƒ| j
d | j t ƒ d S( Ngš™™™™™é?s swift device info snapshotR t stopt priorityiÐ s swift-device-info( t superR t registerR R R
t _monitort registryt reactort
call_everyR t logt call_ont call_on_acceptedt
send_messagesR ( R R! ( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyR ! s
"c C s> | j r: i d d 6| j d 6} | j | _ g | _ | Sd S( Ns swift-device-infot type( R R R ( R t message( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt create_swift_device_info_message+ s
c sW ˆ j ƒ } | rS t j d ƒ ˆ j j j | d | ƒ} | j ‡ f d † ƒ n d S( Ns0 Queueing message with updated swift device info.t urgentc s
ˆ j ƒ S( N( t persist_swift_info( t x( R ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt <lambda>9 s ( R* t loggingt infoR! t brokert send_messaget addCallback( R R+ R) t d( ( R sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyR' 4 s
c C s | j j j d | j ƒ d S( Ns swift-device-info( R! R1 t call_if_acceptedR' ( R ( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt exchange; s c C sZ x= | j D]2 } | d } | j | f } | j j | | ƒ q
Wd | _ | j j ƒ d S( Nt device( R t persist_namet _persistt setR R! t flush( R t swift_device_infot device_namet key( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyR, ? s
c C s | j s
d S| j j ƒ | j ƒ } g } x~ | D]v } | d } | j | ƒ | j | f } | j j | ƒ } | s„ | | k r3 | | j k r© | j j | ƒ q© q3 q3 W| j j | j ƒ } | r
x? | j ƒ D]. } | | k rÕ | j j
| j | f ƒ qÕ qÕ Wn d S( NR7 ( R R t pingt _get_swift_devicest appendR8 R9 t getR t keyst remove( R t current_swift_devicest current_device_namest
swift_infoR= R> t prev_swift_infot persisted_devices( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt runJ s$
c C sI | j } t j j | ƒ s< t | _ t j d | j ƒ g S| j d k r | j ƒ } | d k rg g S| j ƒ } g | D] } | d ^ qz } xF | j
D]; } | rš | d | k rš d | d | d f | _ Pqš qš W| j d k r t | _ t j d | j ƒ g Sn | j ƒ } g | D]& } i d | d d 6| d d 6^ q S(
NsQ This does not appear to be a swift storage server. '%s' plugin has been disabled.t
ip_addresst ips http://%s:%d/recon/diskusaget ports= Local swift service not found. '%s' plugin has been disabled.s /dev/%sR7 t mounted( R
t ost patht existst FalseR R/ R0 R8 R R t _get_ringR t devst errort _get_swift_disk_usage( R t config_filet ringt network_devicesR7 t local_ipst devt recon_disk_info( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyR@ a s6 c C s¹ d } y | j | j ƒ } WnJ t k
r7 } d } n2 t t f k
rh } d | j t | ƒ f } n X| d k rœ t | _ t j
d | | j f ƒ d S| s¦ d St j
| ƒ } | S( s
Query the swift storage usage data by parsing the curled recon data
from http://localhost:<_swift_service_port>/recon/diskusage.
Lots of recon data for the picking described at:
http://docs.openstack.org/developer/swift/admin_guide.html
s5 Swift service is running without swift-recon enabled.s& Swift service not available at %s. %s.s! %s '%s' plugin has been disabled.N( R R R R R R t strRR R R/ RU R8 t jsont loads( R t
error_messaget contentRU t swift_disk_usages( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyRV Š s" c C sy t j j | j ƒ s& t j d ƒ d Sy d d l m } Wn/ t k
rk t
| _ t j d | j
ƒ d SX| | j ƒ S( s6 Return ring-file object from self._swift_ring locations' Swift ring files are not available yet.iÿÿÿÿ( t RingsG Swift python common libraries not found. '%s' plugin has been disabled.N( RO RP RQ R R/ t warningR t swift.common.ringRc t ImportErrorRR R RU R8 ( R Rc ( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyRS § s
i ( t __name__t
__module__R8 t timeR R R* RR R' R6 R, RJ R@ RV RS ( ( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyR s
) ( R/ Ri RO R^ t landscape.lib.fetchR R R R t landscape.lib.monitorR t landscape.lib.networkR t landscape.monitor.pluginR R ( ( ( sE /usr/lib/python2.7/dist-packages/landscape/monitor/swiftdeviceinfo.pyt <module> s "