-ķ
Oc       sĶ     d  k  Z   d  k Z  d  k Z  d  k Z  d  k Z  d  k i Z  d  k i	 Z
 	 d  k i Z 
 d  k Z  d  k Z  d k l Z  d  k Z  d  k Z  d  k Z  d k l Z  d e i i i f d     YZ Q d f  d     YZ z d   Z  d   Z £ d	   Z ± d
   Z Ź f  d  Z  Ó d   Z! Ł d   Z" ś e# a$ ū e i%   a& ü h  a' ż h  a( ž e   Z) ’ d a* d   Z+ 2e, d j o 3e i- e+    n d  S(   N(   s   CORBA(   s
   ClientCores   Consumerc      s>    d  Z    d   Z  d   Z ) d   Z L d   Z RS(   s+    CORBA proxy push consumer.  Handle events.c    s
     d  S(   N(    (   s   self(    (    s   main.pys   __init__ s   c    si      t  i     y ! |  i |  Wn+ # t j
 o } $ t i i	 d  n X& t  i
   d  S(   Ns   error processing event(   s   _locks   acquires   selfs   _pushs   argss	   Exceptions   es	   twccommons   Logs   logCurrentExceptions   release(   s   selfs   argss   e(    (    s   main.pys   push s   c 
   s4  ) * , | i   } - t | t i i i  o . d  Sn 0 t i	   a
 2 t | i  \ } } 3 | t j o 4 d  Sn 5 | \ } } }	 } 8 f  } 9 t | i  o : t | i  } n = t | | t  } > | t j o( ? t i i d |	 | f  B d  Sn E t | |  I t i   d  S(   Ns0   plugin for presentation type %s had no method %s(   s   argss   values   events
   isinstances   twcs   corbas
   ClientCores   Events   configs	   getValuess   _configs
   loadPlugins   types   partss   plugins   Nones   appNames   pPrefixs   pNames   fNames   lens   evals   getattrs   fns	   twccommons   Logs   warnings   applys   dss
   clearCache(
   s   selfs   argss   pPrefixs   fNames   appNames   fns   plugins   events   partss   pName(    (    s   main.pys   _push) s$   	c    s*   L M t  i i d  N t i d  d  S(   Ns*   unexpected disconnected from event channeli’’’’(   s	   twccommons   Logs   warnings   syss   exit(   s   self(    (    s   main.pys   disconnect_push_consumerL s   (   s   __doc__s   __init__s   pushs   _pushs   disconnect_push_consumer(    (    (    s   main.pys   Consumer s
   	#s   BuiltInsc      sA   Q S d   Z  X d   Z \ d   Z g d   Z r d   Z RS(   Nc    s   S U d GHd  S(   Ns   booga booga(    (   s   self(    (    s   main.pys   boogaS s   c    s   X Y t  i |  d  S(   N(   s   oss   systems   cmd(   s   selfs   cmd(    (    s   main.pys   systemX s   c    sE   \ ] _ t  o ` d  Sn b t d  c d a  d t i d  d  S(   Ns   locki   s#   locking out calls to plugin modules(   s   _lockPluginss	   sendEvents   Logs   info(   s   self(    (    s   main.pys   lockPlugins\ s   
	c    sF   g h j t  o k d  Sn m d a  n t d  o t i d  d  S(   Ni    s   unlocks!   access to plugin modules restored(   s   _lockPluginss	   sendEvents   Logs   info(   s   self(    (    s   main.pys   unlockPluginsg s   	c    s!   r u | d 7} w t |  d  S(   Ns   .init(   s   pluginIds
   loadPlugin(   s   selfs   pluginId(    (    s   main.pys
   loadPluginr s   (   s   boogas   systems   lockPluginss   unlockPluginss
   loadPlugin(    (    (    s   main.pys   BuiltInsQ s
   c    s#  z { t  } | t  } } t  } ~ t  }  |  i d  }  |  i d  }  | d j p
 | d j o  | | | | f Sn  |  |  }  |  | d }  |  |  }  t  }  | i d  }  | d j o"  | | d }  | |  } n  | i
 d d  }  | | | | f Sd  S(   Ns   .i’’’’i   s   /(   s   Nones   apps   fns   paths   plugins   ts   finds   pos1s   rfinds   pos2s   replace(   s   ts   plugins   paths   apps   pos2s   fns   pos1(    (    s   main.pys	   parseTypez s$   					c    s      y  t  |  } Wnf  t j
 oW  t i }  |  o  | d |  7} n  t i i | |  }  | t  |  <n X  | Sd  S(   Ns   /%s(	   s   _pmCaches   groups   pms   KeyErrors   _configs
   pluginRoots   paths	   twccommons   PluginManager(   s   groups   paths   pm(    (    s   main.pys   getPluginManager s   
c    s\   £ ¤ | t j o Ø t Sn Ŗ t o « t Sn ­ t |   } ® | i | t f  Sd  S(   N(	   s   names   Nones	   _builtInss   _lockPluginss   getPluginManagers   prefixs   pms   retrievePlugins   _config(   s   prefixs   names   pm(    (    s   main.pys	   getPlugin£ s   
c    s  ± ² “ t  |   } · | \ } } } } ø | t i j o ¹ t t f Sn ¼ t	 | |  } ½ | t j o ¾ t i i d | f  nt Ą t i i d |  f  Ā t | d t  } Ć | t j o4 Ä d t | | f <Å t i i d | | f  n Ē | | f Sd  S(   Ns   %s plugin not founds   received call to %ss   idlei   s    adding _idleHandlerMap for %s %s(   s	   parseTypes   pluginIds   partss   appNames   pPrefixs   pNames   fNames   _configs   Nones	   getPlugins   plugins	   twccommons   Logs   warnings   infos   getattrs   fns   _idleHandlerMap(   s   pluginIds   pPrefixs   appNames   plugins   partss   pNames   fNames   fn(    (    s   main.pys
   loadPlugin± s   !c    sz   Ź Ķ xm t  i   DĶ ]\ } Ī xP | i   DĪ ]? } Ļ t | |  t  } Š | t j o Ń t	 | |  n q, Wq Wd  S(   N(   s   _pmCaches   valuess   pms
   getPluginss   pls   getattrs   names   Nones   fns   applys   args(   s   names   argss   pls   fns   pm(    (    s   main.pys	   sendEventŹ s    	 	c      s6   Ó Ō x) Ō d o Õ t  i d  Ö t   q	 Wd  S(   Ni   f0.10000000000000001(   s   times   sleeps   idle(    (    (    s   main.pys   runÓ s    
c     s  Ł Ś Ū t  i   Ż g  } Ž x¼ t i   DŽ ]« } ß | \ }  } ą t |  |  } ę t
 | d t  } ē | t j o č | i |  é q, n ģ y ķ t | f   Wn+ ļ t j
 o } š t i i d  n Xq, Wō x | Dō ] } õ t | =qč W÷ t  i   d  S(   Ns   idles   error in idle handler(   s   _locks   acquires   dlists   _idleHandlerMaps   keyss   es   pPrefixs   pNames	   getPlugins   plugins   getattrs   Nones   fns   appends   applys	   Exceptions	   twccommons   Logs   logCurrentExceptions   release(   s   pPrefixs   es   plugins   dlists   pNames   fn(    (    s   main.pys   idleŁ s&   	 	

 	i    c  	   s/  t  i i t i i t i d   t  i i t  i i	  y§t  i i
 d  
t i t i t i  a t  i i t  t t i d  t i   a t t d  d j o t  i i t i  n d t i f } t i |  } | i   } | i   } t   i   } | i! |  t i" d  } | i$   } | i&    t' i(   !t' i) d  #t i* d t i+ d }  $t, i- |   %t  i i
 d  &t.   (t' i/   )d	 SWn2 +t0 j
 o# } ,t  i i2 d
  -d Sn X/d	 Sd  S(   Ni   s   initializing...s   LogLevels   corbaname::localhost:4000#%ss   RootPOAs   /s   .pids
   running...i    s   fatal error; aborting:i’’’’(3   s	   twccommons   Logs   setIdents   oss   paths   basenames   syss   argvs   setLevels   INFOs   infos   CORBAs   ORB_inits   ORB_IDs   _orbs   corbas   setOrbs   execfiles   configs	   getValuess   _configs   hasattrs   LogLevels   channels
   channelIORs   string_to_objects   for_consumerss   admins   obtain_push_suppliers   suppliers   Consumers   _thiss   consumers   connect_push_consumers   resolve_initial_referencess   poas   _get_the_POAManagers
   poaManagers   activates   dss   inits   enableCachings   pidFileNames   appNames   twcs   writePids   runs   uninits	   Exceptions   es   logCurrentException(	   s   pidFileNames   poas
   channelIORs   es   admins   consumers
   poaManagers   suppliers   channel(    (    s   main.pys   mains@   &
s   __main__(.   s   configs   oss   syss   times	   threadings   twc.DataStoreInterfaces   DataStoreInterfaces   dss   twc.dsmarshals	   dsmarshals   dsms   twccommon.Logs   Logs   twccommon.PluginManagers	   twccommons   twcs   omniORBs   CORBAs	   CosNamings   twccommon.corbas!   twccommon.corba.CosEventComm__POAs	   twc.corbas
   ClientCores   corbas   CosEventComm__POAs   PushConsumers   Consumers   BuiltInss	   parseTypes   getPluginManagers	   getPlugins
   loadPlugins	   sendEvents   runs   idles   Nones   _configs   Locks   _locks   _idleHandlerMaps   _pmCaches	   _builtInss   _lockPluginss   mains   __name__s   exit(   s   CORBAs   runs   Logs
   ClientCores	   sendEvents	   getPlugins   getPluginManagers
   loadPlugins   syss	   CosNamings	   parseTypes   Consumers   dss   twcs   BuiltInss   configs	   _builtInss	   threadings   idles   dsms	   twccommons   times   mains   os(    (    s   main.pys   ? s@   "<)	!				0