| Server IP : 182.53.201.61 / Your IP : 216.73.217.175 Web Server : Apache/2.2.15 (Fedora) System : Linux km10.dyndns.org 2.6.31.5-127.fc12.i686.PAE #1 SMP Sat Nov 7 21:25:57 EST 2009 i686 User : apache ( 48) PHP Version : 5.3.3 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib/python2.6/site-packages/scservices/core/ |
Upload File : |
,Jc @ sh d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k l Z d d k Td d k
Ty d d k Z Wn e j
o n Xd d k
l Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d Z d
e f d YZ d e f d
YZ d e f d YZ d e f d YZ d e f d YZ e e g Z d S( iN( t getstatusoutput( t *( t HookableSeti i i i i t InvalidServiceExceptionc B s e Z RS( ( t __name__t
__module__( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR ; s t Servicec B sn e Z d Z d Z d Z d Z d Z d d Z d Z d d Z
d Z d Z d
Z
RS( s Represents an abstract service.c C sG t t | i | | _ | | _ | | _ t | _ d | _ d S( Ni ( t superR t __init__t namet mont herdert
AsyncCmdQueuet _asynccmdqueuet conf_updates_running( t selfR R
R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR D s c C s/ d | i i | i i t t | | i f S( Ns <%s.%s object at %s: "%s">( t __class__R R t hext idR ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt __repr__M s c C s% | i o | i i | | n d S( s Notify the herder of a change.N( R t notify( R t change( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt
notify_herderQ s
c C s- t i } | i | i | | i d S( s+ Load configuration from disk synchronously.N( t gobjectt MainLoopt _async_loadt _sync_load_finishedt run( R t mainloop( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt loadW s c C s1 | i | d j o
t | _ n
t | _ d S( N( t quitt Nonet Truet validt False( R R t
__exception__( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR ^ s
c C s | i t i | i | i S( sI Load configuration from disk asynchronously, notify herder on completion.( R t serviceherderst SVC_CONF_UPDATINGR t _async_load_finished( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt
async_loade s c C s | i t i d S( N( R R$ t SVC_CONF_CHANGED( R R# ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR& k s c O sS y | i | Wn t j
o } | | d <n X| i d 8_ | | | d S( NR# i ( t _async_load_processt ExceptionR ( R t cmdt callbackt pt kt e( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _async_load_readyn s c O s
t d S( s, Load configuration from disk asynchronously.N( t NotImplementedError( R R, R- R. ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR v s c C s
t d S( s, Process asynchronously loaded configuration.N( R1 ( R R+ ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR) { s N( R R t __doc__R R R R R R R' R& R0 R R) ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR @ s t ChkconfigServicec B sw e Z d Z d Z e i d e i Z d Z e d Z
d Z d Z d Z
d Z d Z d
Z RS( s6 Represents an abstract service handled with chkconfig.s LC_ALL=C /sbin/chkconfigs/ ^chkconfig\s+version\s+(?P<version>[\d\.]+)\s*$c C s t t | i | | | d | _ t t d p t i d t i } xk | D]c } | i } t i i
| } | o8 | i d } t t
d | i d t _ PqR qR W| i n d S( Ni t chkconfig_versions %s -vt versionc S s
t | S( ( t int( t x( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt <lambda> s t .( R R3 R t _chkconfig_runningt hasattrt ost popent _chkconfig_invocationt stript _chkconfig_version_ret matcht groupt tuplet mapt splitR4 t close( R R R
R t
ckver_pipet linet mR5 ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
$ c C sj t | i d pM t i g } t i d j o | i d | i n d i | | i _ n | i i S( Nt _chkconfig_actual_invocationi i i( s --type %st ( i i i( ( R; R R3 R> R4 t appendt chkconfig_typet joinRJ ( R t invoke( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt chkconfig_invocation s c C s
| i d j S( Ni ( R: ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt is_chkconfig_running s c C s | i d 8_ d S( Ni ( R: ( R R+ ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _change_enablement_ready s c C s< | i d 7_ | i i d | i | i | f | i d S( Ni s %s "%s" "%s"( R: R
t queueRP R RR ( R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _change_enablement s c C s | i d d S( s Enable this service.t onN( RT ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt enable s c C s | i d d S( s Disable this service.t offN( RT ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt disable s c C s
t d S( N( R1 ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt get_enabled s ( R R R2 R> t ret compilet
IGNORECASER@ R t propertyRP RQ RR RT RV RX RY ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR3 s t SysVServicec B sC e Z d Z d Z e i d Z e i d Z e i d Z e i d Z e
d" Z d
Z d Z
d Z d
Z d Z d Z e e 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# d Z$ d! Z% RS(# s) Represents a service handled by SysVinit.t sysvs ^(?P<name>\S+)\s+0:(?P<r0>off|on)\s+1:(?P<r1>off|on)\s+2:(?P<r2>off|on)\s+3:(?P<r3>off|on)\s+4:(?P<r4>off|on)\s+5:(?P<r5>off|on)\s+6:(?P<r6>off|on)\s*$s1 ^service (?P<name>.*) does not support chkconfig$s6 ^error reading information on service (?P<name>.*):.*$st ^service (?P<name>.*) supports chkconfig, but is not referenced in any runlevel \(run 'chkconfig --add (?P=name)'\)$i i i i c C s
t t | i | | | y t | | _ Wn t j
o
t n Xt | _ d | _ t
| _ d | _
t | _ t | _ | i i o[ t | i i | _ t | _ h | _ xK | i i D] } | i i | | i q Wn | i i d | i | i d S( Ni s /var/lock/subsys/%s( R R^ R t SysVServiceInfot infot InvalidServiceInfoExceptionR R" t
configuredt status_updates_runningt SVC_STATUS_UNKNOWNt statusR t
status_outputR! R t _status_asynccmdqueuet pidfilest sett pidst
pids_pidfilesR
t
watch_filet _pidfile_changedR t _var_lock_subsys_changed( R R R
R t file( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s(
c
O s[ | f | } | i i d | i | i f d t d | i d | d | | i d 7_ d S( s, Load configuration from disk asynchronously.s %s --list "%s"t combined_stdoutt ready_cbt
ready_argst ready_kwargsi N( R
RS RP R R R0 R ( R R, R- R. ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c C sZ | i } | i } | d j o_ | i i | p | i i | o t | q~ | i i | o t | _ d Sd Sn | i i | } | p | i
d | i j o
| n t } xB t
d d D]1 } | i
d | d j o | i | q q Wt | i _ | i i | i i | t | i _ t | _ | i d 8_ d S( s, Process asynchronously loaded configuration.i NR i i s r%dRU ( t exitcodet outputt no_chkconfig_reRA t chkconfig_error_reR t chkconfig_unconfigured_reR" Rc t init_list_reRB R Rj t xranget addt runlevelst
hooks_enabledt cleart updateR R ( R R+ Ru Rv RI R} t runlevel( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR) s0
!
c C s h g d 6g d 6} xE t d d D]4 } | | | i j o d p d i t | q$ Wx d D] } t | | p qc n t d | i d i | | | i | f \ } } | d j o< t d | i | i d i | | | i | | f qc qc Wt
| _ d S(
s$ Save runlevel configuration to disk.RU RW i i s %s --level %s %s %s 2>&1t sM Saving service '%s' failed, command was '%s --level %s %s %s'.
Output was:
%sN( s ons off( R{ t
_runlevelsRL t strt lenR RP RN R t OSErrorR Rc ( R t runlevel_changest it whatRf Rv ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _runlevels_save_hook5 s$ ! )
c C s: t | d p# t | _ | i i | i n | i S( NR ( R; R R t add_hookR ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _get_runlevelsN s c C sV | i | i | j o; | i i | i i | i i | | i i n d S( N( R} R t freeze_hooksR R t
thaw_hooks( R R} ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _set_runlevelsT s
c G s" | t i j o | i n d S( N( t gamint GAMEndExistt async_status_update( R t patht actionR- ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyRo ^ s c G sy | t i t i t i f j o | i | nF | t i j o5 t | i d j o | i n | i | n d S( Ni (
R t
GAMCreatedt
GAMChangedt GAMExistst _watch_pidfilet
GAMDeletedR Rk R t _unwatch_pidfile( R R R R- ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyRn b s c C s | i | y t | d } Wn t j
o d SXx[ | D]S } xJ | i D]< } y t | } | i | | WqQ t j
o qQ XqQ Wq> W| i d S( Nt r( R t opent IOErrorRE R6 t
_watch_pidt
ValueErrorRF ( R R t pidfileRH t _pidt pid( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR j s
c C sg t } x6 | i D]+ } | | i | j o | i | q q Wx | D] } | i | | qI Wd S( N( Rj Rk Rl R| t _unwatch_pid( R R t unwatch_pidsR ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR { s
c G s" | t i j o | i n d S( N( R R R ( R R R R- ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _proc_pid_changed s c C s} | | i j o. | i i | | i i d | | i n | i i | p t | i | <n | i | i | d S( Ns /proc/%d( Rk R| R
Rm R Rl t has_keyRj ( R R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c C sd | i | i | t | i | d j o2 | i | =| i i | | i i d | n d S( Ni s /proc/%d( Rl t discardR Rk R
t
stop_watch( R R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c C s | i | i S( s( Determine service status asynchronously.( t _async_status_updatet _async_status_update_finished( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c C s | i t i d S( N( R R$ t SVC_STATUS_CHANGED( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c
O s[ | f | } | i i d | i d t d | i d | d | | i d 7_ t | _ d S( Ns& env LC_ALL=C /sbin/service "%s" statusRq Rr Rs Rt i ( Rh RS R R t _status_update_readyRd t SVC_STATUS_REFRESHINGRf ( R R, R- R. ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c O sS | i d 8_ | i d j o d | _ t | _ n | i | | | | d S( Ni i ( Rd Re Rf t _status_update_process( R R+ R, R- R. ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c C s} | i } | d j o
t | _ nK | d j p
| d j o
t | _ n$ | d j o
t | _ n
t | _ | i | _ d S( s1 Process asynchronously determined service status.i i i i N( Ru t SVC_STATUS_RUNNINGRf t SVC_STATUS_DEADt SVC_STATUS_STOPPEDRe Rv Rg ( R R+ Ru ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c C sP | i d j o t St | i d j o t S| i | i j o t St Sd S( s- Determines the enablement state of a service.i N( R t SVC_ENABLED_REFRESHINGR R} t SVC_ENABLED_NOt _fallback_default_runlevelst SVC_ENABLED_YESt SVC_ENABLED_CUSTOM( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyRY s c C s; | d j o
t | _ n | i i d | i | f d S( Nt startt stopt restarts$ env LC_ALL=C /sbin/service "%s" "%s"( s starts stops restart( R Rf R
RS R ( R R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _change_status s
c C s | i d d S( s Start this service.R N( R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c C s | i d d S( s Stop this service.R N( R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c C s | i d d S( s Restart this service.R N( R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c C s | i d d S( s Reload this service.t reloadN( R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s ( i i i i (& R R R2 RM RZ R[ Rz Rw Rx Ry Rj R R R R) R R R R] R} Ro Rn R R R R R R R R R R RY R R R R R ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR^ s@ " &
t
XinetdServicec B sh e Z d Z d Z e i d Z d Z d Z d Z d Z
d Z e e
e Z
d Z RS( s' Represents a service handled by xinetd.t xinetds( ^(?P<name>\S+)\s+(?P<enabled>off|on)\s*$c C sY t t | i | | | y t | | _ Wn t j
o
t n X| i d S( N( R R R t XinetdServiceInfoRa Rb R R ( R R R
R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s c
O s[ | f | } | i i d | i | i f d t d | i d | d | | i d 7_ d S( s, Load configuration from disk asynchronously.s %s --list %sRq Rr Rs Rt i N( R
RS RP R R R0 R ( R R, R- R. ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s
c C s | i } | i } | d j o_ | i i | p | i i | o t | q~ | i i | o t | _ d Sd Sn | i i | } | p | i
d | i j o$ t i
d | | f IJd | _ n | i
d d j | _ d S( s, Process asynchronously loaded configuration.i NR s( %s: unable to parse chkconfig output:
%st enabledRU ( Ru Rv Rw RA Rx R Ry R" Rc t xinetd_list_reRB R t syst stderrR R ( R R+ Ru Rv RI ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR) s
!
c C s$ t | d p
d | _ n | i S( Nt _enabled( R; R R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _get_enabled, s
c C s t | d d } | | _ | | j o t d | i | i | i o d p d f \ } } | d j o@ t d h | i d 6| i d 6| i o d p d d 6 q n d S(
NR s
%s %s %s 2>&1RU RW i sX Saving service '%(name)s' failed, command was '%(invocation)s %(name)s %(action)s 2>&1'.R t
invocationR ( t getattrR R R RP R R R ( R R t old_enabledRf Rv ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt _set_enabled1 s
c C s? | i d j o t S| i d j o t S| i o t p t S( Ni ( R R R R t SVC_ENABLED_ERRORR R ( R ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyRY B s
( R R R2 RM RZ R[ R R R R) R R R] R RY ( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyR s (! R< R t copyRZ t timeR R t utilR t asynccmdt servicesinfoR$ t AttributeErrort slip.util.hookableR R Re R R R R R R R R R* R t objectR R3 R^ R t service_classes( ( ( s< /usr/lib/python2.6/site-packages/scservices/core/services.pyt <module> s>
AK &Y