2 E FG H IJ E KL E M N O P Q R S T UV W XYZ [\ ] ^ _` ab Ec d e fg h i j kl m n o p q rs 0Et uv wx yz {| :} ~ =  E     G  G J   E ~      Z  ] ] ] ] ]  ] f ]  [   J  Z  f q q   ]  E 0    Z q qm                  =    J J  E  EparallelScheduleLptolemy/data/expr/Parameter; pipeliningparallelExecutionVERBOSEZconfigFileNameLjava/lang/String;clientServerInteractionManager;Lptolemy/distributed/client/ClientServerInteractionManager;actorsThreadsMapLjava/util/HashMap; synchronizer/Lptolemy/distributed/client/ThreadSynchronizer; commandsMap()VCodeLineNumberTableLocalVariableTablethis?Lptolemy/distributed/domains/sdf/kernel/DistributedSDFDirector; Exceptions"(Lptolemy/kernel/util/Workspace;)V workspaceLptolemy/kernel/util/Workspace;5(Lptolemy/kernel/CompositeEntity;Ljava/lang/String;)V container Lptolemy/kernel/CompositeEntity;nameattributeChanged"(Lptolemy/kernel/util/Attribute;)V attributeLptolemy/kernel/util/Attribute; StackMapTablefireparallelExecutionValuepipeliningValue initialize newReceiver()Lptolemy/actor/Receiver; preinitializewrapupbufferingPhasefiringLptolemy/actor/sched/Firing;actorLptolemy/actor/Actor; clientThread)Lptolemy/distributed/client/ClientThread;level%Lptolemy/actor/sched/ScheduleElement;firingsLjava/util/Iterator;auxIiterationsValue schedulerLptolemy/actor/sched/Scheduler;scheduleLptolemy/actor/sched/Schedule;levels levelNumber connectActors currentPortLptolemy/actor/IOPort; receivers[[Lptolemy/actor/Receiver;eLjava/rmi/RemoteException; Lptolemy/kernel/ComponentEntity;portsReceiversMap portTypesallPortsserver"Lnet/jini/core/lookup/ServiceItem;distributedActor-Lptolemy/distributed/common/DistributedActor; keysIteratorJcreateServicesReceiversMap/([[Lptolemy/actor/Receiver;)Ljava/util/HashMap;portlistLjava/util/LinkedList;IDLjava/lang/Integer;jreceiver[Lptolemy/actor/Receiver;servicesReceiversMap!distributeActorsOntoServersexitClientThreadsauxActorLjava/lang/Object;actorsIteratorcommands getActors()Ljava/util/LinkedList;entityentitiesLptolemy/actor/CompositeActor; allActorList getServersinitinitializeJini throwableLjava/lang/Throwable;mapActorsOntoServers auxServerauxClientThreadserversIteratoractorsservers parallelFirepipelinedParallelFireprintActorsOntoServersMap SourceFileDistributedSDFDirector.java A\ptolemy\distributed\config\ClientServerInteractionManager.config java/util/HashMap -ptolemy/distributed/client/ThreadSynchronizer 4  ptolemy/data/BooleanToken   equals FALSE    > Director: fire   java/lang/StringBuilderparallelExecution:    pipelining:  A @$> DistributedSDFDirector: initialize 5 : %  =ptolemy/distributed/domains/sdf/kernel/DistributedSDFReceiver'> DistributedSDFDirector: preinitialize parallelSchedule: >Director: wrapup & Buffering... ptolemy/data/IntToken  *ptolemy/kernel/util/IllegalActionException*Attempted to fire system with no scheduler        ptolemy/actor/sched/Schedule !ptolemy/actor/sched/Firing "# $%'ptolemy/distributed/client/ClientThread & '() *+ ,- $. removing: / 0% 12 3Finished Buffering...Connecting Actors!>> Creating Ports Receivers Map: 456ptolemy/kernel/ComponentEntity 789ptolemy/actor/IOPort : ;< = >< ?8 @ Aptolemy/actor/TypedIOPort BCPort:  D EF G  HI JK L(+ptolemy/distributed/common/DistributedActorSetting connections to:  in: MNOSetting port Types: P2 Q2java/rmi/RemoteExceptionR STU VW VXptolemy/actor/Actor YZjava/util/LinkedList [\ ]Z Distributing Actors Onto ServersLoading class: ^ _`a b cdGetting actorsptolemy/actor/CompositeActor e8 fgGetting servers h,>ptolemy/distributed/domains/sdf/kernel/DistributedSDFScheduler Scheduler ij kptolemy/data/expr/Parameter l mn os tuInitializing Jini9ptolemy/distributed/client/ClientServerInteractionManagerptolemy/kernel/CompositeEntityRequired services: v w x(ptolemy.ptII.diry zj 4 java/lang/ThrowableFailed to initialize Jini {Mapping Actors Onto Servers +, 3, net/jini/core/lookup/ServiceItem | }Not enough servers B ~Actors-Servers Map: <--- =ptolemy/distributed/domains/sdf/kernel/DistributedSDFDirector&ptolemy/domains/sdf/kernel/SDFDirector,ptolemy/kernel/util/NameDuplicationExceptionptolemy/actor/sched/Schedulerjava/util/Iterator#ptolemy/actor/sched/ScheduleElementinvalidateSchedulegetToken()Lptolemy/data/Token;FALSELptolemy/data/BooleanToken;java/lang/SystemoutLjava/io/PrintStream;java/io/PrintStreamprintln(Ljava/lang/String;)VsetToken(Lptolemy/data/Token;)V booleanValue()Zappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;(Z)Ljava/lang/StringBuilder;toString()Ljava/lang/String;-(Ljava/lang/Object;)Ljava/lang/StringBuilder; iterationsintValue()I getScheduler!()Lptolemy/actor/sched/Scheduler; getSchedule ()Lptolemy/actor/sched/Schedule;iterator()Ljava/util/Iterator;hasNext_stopRequestednext()Ljava/lang/Object;firingIteratorgetActor()Lptolemy/actor/Actor;get&(Ljava/lang/Object;)Ljava/lang/Object;getIterationCountsetIterationCount(I)Vjava/lang/IntegervalueOf(I)Ljava/lang/Integer;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;((I)Lptolemy/actor/sched/ScheduleElement; getFullNameremove setCommands(Ljava/util/HashMap;)VcommandsProcessedkeySet()Ljava/util/Set; java/util/SetportList()Ljava/util/List;java/util/ListisOutputgetRemoteReceivers()[[Lptolemy/actor/Receiver;isInput getReceiversconnectedPortListisEmptygetNamegetType()Lptolemy/data/type/Type;-ptolemy/distributed/util/DistributedUtilitiesreceiversArrayToString.([[Lptolemy/actor/Receiver;)Ljava/lang/String;printconvertReceiversToIntegers1([[Lptolemy/actor/Receiver;)[[Ljava/lang/Integer; getService$()Lnet/jini/core/lookup/ServiceItem;service serviceID Lnet/jini/core/lookup/ServiceID;net/jini/core/lookup/ServiceIDsetConnections setPortTypes#ptolemy/kernel/util/KernelExceptionstackTraceToString)(Ljava/lang/Throwable;)Ljava/lang/String;ptolemy/actor/Receiver getContainer()Lptolemy/actor/IOPort; ()Lptolemy/kernel/util/NamedObj; containsKey(Ljava/lang/Object;)ZgetID()Ljava/lang/Integer;addjava/lang/ObjectgetClass()Ljava/lang/Class;java/lang/Class exportMoMLloadMoML(Ljava/lang/String;)ZdeepEntityListaddLast(Ljava/lang/Object;)V getServices uniqueName&(Ljava/lang/String;)Ljava/lang/String;-(Lptolemy/actor/Director;Ljava/lang/String;)V(Z)VG(Lptolemy/kernel/util/NamedObj;Ljava/lang/String;Lptolemy/data/Token;)Vptolemy/data/type/BaseTypeBOOLEAN BooleanType InnerClasses(Lptolemy/data/type/BaseType$BooleanType; setTypeEquals(Lptolemy/data/type/Type;)Vsize(I)Ljava/lang/StringBuilder;setRequiredServicesptolemy/util/StringUtilities getPropertyH(Lptolemy/kernel/util/Nameable;Ljava/lang/Throwable;Ljava/lang/String;)VT(Lptolemy/distributed/client/ThreadSynchronizer;Lnet/jini/core/lookup/ServiceItem;)Vstart_iterationCount&ptolemy/data/type/BaseType$BooleanType! :*****Y* Y *Y * &  *59 :=;*+****Y* Y *Y * &   +6:;;=<*+,****Y* Y *Y * &  !,7; <<<=@+**+*)****+&  (0:?@@ -= * *<*=*8Y !"#Y$!*%# *& *'*(>   ' +2Kgkrv} e+W W =J* )***<*+*,*-*.**/6 ,-023!5%6)7-8195<E=I?J!)%=20Y1F @* 2*3*(Y4!*"#& YZ]_`-a3b<`?f @/=**5* 6*<*7"xz {~!%)*! = Q8*9:;<*?,@N-A:6*Y B*CDE:F:B?DG:H: * IJ:  KL*  MNWd6o-OF:BZDG:  H: YP! Q!#* IJ:   KL*  RW`6B* * S* TU)).47BS_fp|  #)3>EHP|-&  H A   _fQ;6.#47*)#E`!=q *VW*XYL+B+DZMYNY:,[\:BD]:^:_ `:a b:cdefgNWc*-Yh!i!j!k!#l_-e*mNWa-enNW>*,IJo:pq:*[Yr!,s!t!uv!#Yw!,s!t!uv!#-xy :{Ww2z6$-7?HS]iqy  #(29 I!Y"b e#u$%#(),*+-.p iq7v?n He SZ (  2{$P .,^6xS= YM+N-66-2:62w2|:}~: ,* IJo,* IJoYNW,* IJoI: 20:   Wyc,Z8:;)<1==>G@NBWA]CdDjEtCxHIJIKL;:Q\ =hG^   ! !"0^^#V$,%s* *XYL+B{+DZM*,IJoN-pq:*1Y!,!t!-uv!#,W :{WGzRXY\]%^/_:`>bGeNf^gphyf|knqoprs>/k>\  GS _U&IYL*XYM,B,DN+*-IMNW* +S* T. }%/269AH*%'($)IA*#+,P* *LYM+\N-B-DZ:~ ,,. )2=EKN4=-)%.P9/1012!3,R* * 4pY**W*Y*Y**Y*Y**Y*Y*& %/EOeo p=5* *Y*YL*M,\N-B-DZ:~ +*Y!+#*+*Y!*!#L=Y*+^&.8ALTZ]d>L-8%.&0.} 67"(28!"-9 =:X* *L*M+,R,N+:B:D:-D:JY* :*NW§ *J$)/9B J!\#h$m%p&s'{+-RB+'(J#;(\</A))G=l>g?22@@ *?+@M,AN-B|*Cu-DE::Y:B=DG:H:*IJ:  KL MNW* S* T^;= >DEG-H8I?KHMRN^OePkQsR}STSUWZ[\f ^+e$s 8d?]HT# *C=A *9:;<*?,@N*d6-W--ddOF:B;DG:H:*IJ:KL* RW* * S* TRhjlm!s&v.x7yDzI|S}_~flt~\ _)f"tIB&x.p!'A=Ba*XYL+BE+DZM*,IJoNY-uv!!,s!#. (37QZ]`*(57&  Ka JCDr pq