;ς
Rγ?c           @   sb  d  k  l Z l Z l Z l Z d k Z d k l Z l	 Z	 d k
 l Z d k Z d k Z d f  d     YZ e   Z d   Z d   Z d e i f d	     YZ d
   Z e i i i Z e i i i Z e e i i _ d f  d     YZ e a d   Z d e	 f d     YZ d e f d     YZ d   Z d   Z  e e e   Z! e" d j o e!   n d S(   (   s   ParValues   ParRootFunctions   processorIDs   numberOfProcessorsN(   s   InteractiveInterpreters   InteractiveConsole(   s   StringIOs   OKc           B   s   t  Z RS(   N(   s   __name__s
   __module__(    (    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   OK   s   c         C   s/   y |  i t j SWn t j
 o d Sn Xd  S(   Ni    (   s   objects	   __class__s   OKs   AttributeError(   s   object(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   is_ok   s    c          C   s   d } x | o{ t t t t  t t d t   t   }  t |   t d j o3 d } x* |  D] } t
 |  o
 d } qb qb Wq	 q	 Wd  S(   Ni    i   (   s   dones   puts   oks   ranges   processorIDs   numberOfProcessorss   syncs   statuss   lens   objects   is_ok(   s   statuss   objects   done(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   synchronize   s     $	 s   BSPSyncErrorc           B   s   t  Z RS(   N(   s   __name__s
   __module__(    (    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   BSPSyncError,   s   c          C   s9   t    } x% | D] }  t |   o
 t  q q W| Sd  S(   N(   s   syncs   messagess   objects   is_oks   BSPSyncError(   s   objects   messages(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys
   sync_check6   s    	 s   OutputStreamc           B   s#   t  Z d   Z d   Z d   Z RS(   Nc         C   s   | |  _  d  S(   N(   s   streams   self(   s   selfs   stream(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   __init__E   s    c         C   sB   t  t j	 o | o |  i i t   n |  i i |  t a  d  S(   N(   s   _pid_banners   Nones   strings   selfs   streams   write(   s   selfs   string(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   writeH   s
     c         C   s   t  |  i |  Sd  S(   N(   s   getattrs   selfs   streams   attr(   s   selfs   attr(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   __getattr__O   s    (   s   __name__s
   __module__s   __init__s   writes   __getattr__(    (    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   OutputStreamC   s   		c         C   s5   t  |  d  o t t |  i   Sn t |   Sd  S(   Ns   is_parvalue(   s   hasattrs   objects   ParValues   types   value(   s   object(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   type_parW   s    s   ParallelConsolec           B   s#   t  Z d   Z d   Z d   Z RS(   Nc         C   s5   h  d d <d t  <d t <} t i |  |  d  S(   Ns   __name__s   __console__s   __doc__s   type(   s   Nones   type_pars   localss   InteractiveConsoles   __init__s   self(   s   selfs   locals(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   __init__b   s    !c         C   s	  |  i i |  d i |  i  } t | t d t   t	   d t
 d d d a |  i | |  i  } t a t   t	   } | i d    xX | D]P \ } } } | p | o3 d | d d GH| o | Gn | o | Gqη q q W| o |  i   n | Sd  S(   Ns   
i   s   -- Processor %d i(   s   -c         C   s   t  |  d | d  S(   Ni    (   s   cmps   as   b(   s   as   b(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   <lambda>s   s    (   s   selfs   buffers   appends   lines   joins   sources   puts   ranges   numberOfProcessorss   syncs   processorIDs   _pid_banners	   runsources   filenames   mores   Nones   synchronizes   outputs   sorts   pids   stdouts   stderrs   resetbuffer(   s   selfs   lines   stdouts   pids   sources   stderrs   outputs   more(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   pushh   s,     	 c         C   s   d } d t i t i | t f } x? n o7 y |  i |  PWq% t j
 o d GHd } q% Xq, Wt	 t
 t d t   t   d  S(   Ns>   Type "copyright", "credits" or "license" for more information.s4   Python %s on %s
%s
(Parallel console, %d processors)i   s   KeyboardInterrupts    (   s   cprts   syss   versions   platforms   numberOfProcessorss   banners   selfs   interacts   KeyboardInterrupts   puts   Nones   ranges   sync(   s   selfs   cprts   banner(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   mainloop   s     (   s   __name__s
   __module__s   __init__s   pushs   mainloop(    (    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   ParallelConsole`   s   		s   ParallelInterpreterc           B   s   t  Z d   Z d   Z RS(   Nc         C   s5   h  d d <d t  <d t <} t i |  |  d  S(   Ns   __name__s   __console__s   __doc__s   type(   s   Nones   type_pars   localss   InteractiveInterpreters   __init__s   self(   s   selfs   locals(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   __init__   s    !c         C   sͺ   x£ n o t  i i   t   t  _ t  i i   t   t  _ t   d } | t j o Pn |  i	 |  t
   t t t  i i   t  i i   f d g  t   q
 Wd  S(   Ni   i    (   s   syss   stdouts   closes   StringIOs   stderrs   syncs   sources   Nones   selfs	   runsources   synchronizes   puts   processorIDs   getvalue(   s   selfs   source(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   mainloop   s     !
(   s   __name__s
   __module__s   __init__s   mainloop(    (    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   ParallelInterpreter   s   	c          C   sD   t  t i  t _ t  t i  t _ t   }  t |  _ |  i   d  S(   N(   s   OutputStreams   syss   stdouts   stderrs   ParallelConsoles   consoles	   raw_inputs   mainloop(   s   console(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   consoleͺ   s
    		c          C   s/   t    t _ t    t _ t   }  |  i   d  S(   N(   s   StringIOs   syss   stdouts   stderrs   ParallelInterpreters   interpreters   mainloop(   s   interpreter(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   interpreter±   s    	s   __main__(#   s   Scientific.BSPs   ParValues   ParRootFunctions   processorIDs   numberOfProcessorss   Scientific.BSP.cores
   Scientifics   codes   InteractiveInterpreters   InteractiveConsoles	   cStringIOs   StringIOs
   exceptionss   syss   OKs   oks   is_oks   synchronizes	   Exceptions   BSPSyncErrors
   sync_checks   BSPs   cores   puts   syncs   OutputStreams   Nones   _pid_banners   type_pars   ParallelConsoles   ParallelInterpreters   consoles   interpreters   parallel_consoles   __name__(   s   is_oks   syncs   parallel_consoles   InteractiveConsoles   interpreters   BSPSyncErrors   numberOfProcessorss   consoles
   Scientifics   synchronizes   ParValues   processorIDs   ParRootFunctions   OutputStreams   syss
   sync_checks   puts   oks   type_pars   ParallelConsoles   OKs   StringIOs   ParallelInterpreters   InteractiveInterpreters
   exceptions(    (    sA   /mit/python/lib/python2.3/site-packages/Scientific/BSP/Console.pys   ?   s.   					
			0		