OwlCyberSecurity - MANAGER
Edit File: controlsocket.pyc
� �t�ac @ s� d Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m Z d e f d � � YZ d e f d � � YZ d e e f d � � YZ d e e f d � � YZ d S( st Multiplexing control socket. Currently used for messages related to queueing and logging, but extensible to more. i����( t implements( t Factory( t BinaryBoxProtocolt IBoxReceivert IBoxSender( t Servicet DispatchingSenderc B s- e Z e e � d � Z d � Z d � Z RS( c C s | | _ | | _ d S( N( t sendert route( t selfR R ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyt __init__ s c C s! | j | d <| j j | � d S( Nt _route( R R t sendBox( R t box( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR $ s c C s | j j | � d S( N( R t unhandledError( R t failure( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR ( s ( t __name__t __module__R R R R R ( ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR s t DispatchingBoxReceiverc B s6 e Z e e � d � Z d � Z d � Z d � Z RS( c C s | | _ d S( N( t receiverMap( R R ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR / s c C s: x3 | j j � D]" \ } } | j t | | � � q Wd S( N( R t itemst startReceivingBoxesR ( R t boxSendert keyt receiver( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR 2 s c C s | j | d j | � d S( NR ( R t ampBoxReceived( R R ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR 6 s c C s+ x$ | j j � D] } | j | � q Wd S( N( R t valuest stopReceivingBoxes( R t reasonR ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR 9 s ( R R R R R R R R ( ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR , s t ControlSocketc B s; e Z d Z d � Z d � Z d � Z d � Z d � Z RS( s� An AMP control socket that aggregates other AMP factories. This is the service that listens in the master process. c C s i | _ d S( s3 Initialize this L{ControlSocket}. N( t _factoryMap( R ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR D s c C s | | j | <d S( sf Add another L{Factory} - one that returns L{AMP} instances - to this socket. N( R ( R R t otherFactory( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyt addFactoryJ s c C sI i } x0 | j j � D] \ } } | j | � | | <q Wt t | � � S( sT Build a thing that will multiplex AMP to all the relevant sockets. ( R R t buildProtocolR R ( R t addrR t kt f( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR! Q s c C s( x! | j j � D] } | j � q Wd S( sB Relay start notification to all added factories. N( R R t doStart( R R$ ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR% Z s c C s( x! | j j � D] } | j � q Wd S( sA Relay stop notification to all added factories. N( R R t doStop( R R$ ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR& a s ( R R t __doc__R R R! R% R& ( ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR > s t ControlSocketConnectingServicec B s e Z d � Z d � Z RS( c C s) t t | � j � | | _ | | _ d S( N( t superR( R t endpointFactoryt controlSocket( R R* R+ ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR k s c C s3 d d l m } | j | � } | j | j � d S( Ni����( t reactor( t twisted.internetR, R* t connectR+ ( R R, t endpoint( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyt privilegedStartServicep s ( R R R R0 ( ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyR( i s N( R' t zope.interfaceR t twisted.internet.protocolR t twisted.protocols.ampR R R t twisted.application.serviceR t objectR R R R( ( ( ( s/ /opt/cpanel-ccs/calendarserver/controlsocket.pyt <module> s +