| 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/manager/ |
Upload File : |
ó
}9Rc @ sÀ d d l Z d d l Z d d l m Z d d l m Z m Z d d l m Z d d l m
Z
d d l m Z m
Z
m Z d e f d „ ƒ YZ d e f d
„ ƒ YZ d e f d „ ƒ YZ d S(
iÿÿÿÿN( t Failure( t getProcessValuet getProcessOutputAndValue( t succeed( t log_failure( t
ManagerPlugint SUCCEEDEDt FAILEDt CharmScriptErrorc B s e Z d Z d „ Z d „ Z RS( s²
Raised when a charm-provided script fails with a non-zero exit code.
@ivar script: the name of the failed script
@ivar code: the exit code of the failed script
c C s, | | _ | | _ t j | | j ƒ ƒ d S( N( t scriptt codet Exceptiont __init__t _get_message( t selfR R
( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR s c C s d | j | j f S( Ns3 Failed charm script: %s exited with return code %d.( R R
( R ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR
s ( t __name__t
__module__t __doc__R R
( ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR s t
RunPartsErrorc B s e Z d Z d „ Z d „ Z RS( sË
Raised when a charm-provided health script run-parts directory contains
a health script that fails with a non-zero exit code.
@ivar stderr: the stderr from the failed run-parts command
c C s: d | j d ƒ d j ƒ | _ t j | | j ƒ ƒ d S( Ns %st :i ( t splitt stript messageR R R
( R t stderr( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR & s c C s d | j S( Ns Failed charm script: %s.( R ( R ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR
* s ( R R R R R
( ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR s t HAServicec B sƒ e Z d Z d Z d Z d Z d Z d Z d Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
d „ Z d
„ Z d „ Z d „ Z RS( sÏ
Plugin to manage this computer's active participation in a
high-availability cluster. It depends on charms delivering both health
scripts and cluster_add cluster_remove scripts to function.
s /var/lib/juju/unitst add_to_clustert remove_from_clusters health_checks.du standbyu onlinec C s- t t | ƒ j | ƒ | j d | j ƒ d S( Ns change-ha-service( t superR t registert register_messaget handle_change_ha_service( R t registry( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR < s c C sx i d d 6| d 6| d 6} | rb t | t ƒ sI | j d d ƒ | d <qb | j d d ƒ | d <n | j j j | t ƒ S( Ns operation-resultt typet statuss operation-ids utf-8t replaces result-text( t
isinstancet unicodet decodeR t brokert send_messaget True( R R! t datat operation_idR ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _respondA s
c C s t j | ƒ | j t | | ƒ S( N( t loggingt infoR+ R ( R R) R R* ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _respond_successN s
c C s# t | ƒ | j t | j ƒ | ƒ S( s Handle exception failures.( R R+ R t getErrorMessage( R t failureR* ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _respond_failureR s
c C s t j | ƒ | j t | | ƒ S( s Only handle string failures.( R, t errorR+ R ( R t failure_stringR* ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _respond_failure_stringW s
c C s™ d | j | | j f } t j j | ƒ sG t t j | ƒ ƒ d k rh d | } t j | ƒ t | ƒ Sd „ } t
d | g d t j ƒ} | j | ƒ S( so
Exercise any discovered health check scripts, will return a deferred
success or fail.
s %s/%s/charm/scripts/%si s4 Skipping juju charm health checks. No scripts at %s.c S s2 | \ } } } | d k r* t | ƒ ‚ n d Sd S( Ni s All health checks succeeded.( R ( t .0t stdout_datat stderr_dataR! ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt parse_outputk s s run-partst env(
t JUJU_UNITS_BASEt HEALTH_SCRIPTS_DIRt ost patht existst lent listdirR, R- R R t environt addCallback( R t unit_patht
health_dirR R8 t result( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _run_health_checks\ s .
c C s‚ d | j | f } | d k r/ | | j } n
| | j } t j j | ƒ so t j d | | f ƒ t d ƒ Sd „ } | | ƒ S( sì
Enables or disables a unit's participation in a cluster based on
running charm-delivered CLUSTER_ONLINE and CLUSTER_STANDBY scripts
if they exist. If the charm doesn't deliver scripts, return succeed().
s %s/%s/charm/scripts/u onlinesT Ignoring juju charm cluster state change to '%s'. Charm script does not exist at %s.sn This computer is always a participant in its high-availabilty cluster. No juju charm cluster settings changed.c S s. t | d t j ƒ} d „ } | j | | ƒ S( NR9 c S s* | d k r t | | ƒ ‚ n d | Sd S( Ni s
%s succeeded.( R ( R
R ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt validate_exit_code s ( R R< RA RB ( R RE RG ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt
run_scriptŠ s ( R: t CLUSTER_ONLINEt CLUSTER_STANDBYR< R= R> R, R- R ( R t _RC t
service_statet unit_dirR RH ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _change_cluster_participationu s
c C sG t d ƒ } | | j k r- | j | ƒ } n | j | j | | ƒ | S( s
Handle specific state change requests through calls to available
charm scripts like C{CLUSTER_ONLINE}, C{CLUSTER_STANDBY} and any
health check scripts. Assume success in any case where no scripts
exist for a given task.
N( R t Nonet STATE_ONLINERF RB RN ( R RC RL R* t d( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt _perform_state_change– s c C sC | d } yd } | d } | d } | d } d | | f } | | j | j g k rf d | } n | j d d ƒ } d
| j | f } t j j | j ƒ s© d } n t j j | ƒ sÈ d | } n | rÞ | j | | ƒ S| j | | | ƒ }
|
j | j
| | ƒ |
j | j | ƒ |
SWn | j t
ƒ | ƒ |
SXd
S( s) Parse incoming change-ha-service messagess operation-idu s service-names unit-names
service-states& %s high-availability service set to %su1 Invalid cluster participation state requested %s.t /t -s %s/%s/charmuZ This computer is not deployed with juju. Changing high-availability service not supported.uO This computer is not juju unit %s. Unable to modify high-availability services.N( t
STATE_STANDBYRP R" R: R< R= R> R4 RR RB R. t
addErrbackR1 R ( R R R* t
error_messaget service_namet unit_nameRL t change_messageRC RM RQ ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR ¦ s:
( R R R R: RI RJ R; RU RP R R+ R. R1 R4 RF RN RR R ( ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyR . s
! ( R, R< t twisted.python.failureR t twisted.internet.utilsR R t twisted.internet.deferR t landscape.lib.logR t landscape.manager.pluginR R R R R R R ( ( ( s? /usr/lib/python2.7/dist-packages/landscape/manager/haservice.pyt <module> s