=&org/compiere/server/AdempiereServerMgrjava/lang/Object.org/osgi/util/tracker/ServiceTrackerCustomizer!org/osgi/framework/BundleListener "org/compiere/server/IServerManagerserviceTracker&Lorg/osgi/util/tracker/ServiceTracker; SignatureLorg/osgi/util/tracker/ServiceTracker;Lorg/adempiere/server/IServerFactory;>; m_serverMgr(Lorg/compiere/server/AdempiereServerMgr;logLorg/compiere/util/CLogger; m_serversLjava/util/ArrayList;ULjava/util/ArrayList;m_ctxLjava/util/Properties;m_startLjava/sql/Timestamp;processorClassLjava/util/Set;#Ljava/util/Set;()VCode !  #%$org/compiere/util/CLogger &' getCLogger.(Ljava/lang/Class;)Lorg/compiere/util/CLogger; ) LineNumberTableLocalVariableTableget*()Lorg/compiere/server/AdempiereServerMgr; / ,0+(Z)Lorg/compiere/server/AdempiereServerMgr; 2 35$org/osgi/util/tracker/ServiceTracker 798-org/adempiere/server/AdempiereServerActivator :;getBundleContext$()Lorg/osgi/framework/BundleContext;=#org/adempiere/server/IServerFactory ?A@java/lang/Class BCgetName()Ljava/lang/String; 4E 3Fg(Lorg/osgi/framework/BundleContext;Ljava/lang/String;Lorg/osgi/util/tracker/ServiceTrackerCustomizer;)V H 4J Kopen MON org/osgi/framework/BundleContext PQaddBundleListener&(Lorg/osgi/framework/BundleListener;)V createNewZ StackMapTable 2Wjava/util/ArrayList V2 Z  \^]org/compiere/util/Env _`getCtx()Ljava/util/Properties; b djava/sql/Timestamp fhgjava/lang/System ijcurrentTimeMillis()J cl 3m(J)V o  q rsstartEnvironment()Zujava/util/HashSet t2 x this {}|org/compiere/Adempiere ~startup(Z)Z # info(Ljava/lang/String;)V ^ org/compiere/model/MSession ,5(Ljava/util/Properties;)Lorg/compiere/model/MSession; create getAD_Session_ID()I 3,(Ljava/util/Properties;ILjava/lang/String;)V setWebStoreSession(Z)VServer  setWebSession saveExsessionLorg/compiere/model/MSession;reload  CstopAllFailed to stop all servers  CgetClusterMemberId  getServerOwnerMap()Ljava/util/Map; org/adempiere/base/Core getCacheService+()Lorg/idempiere/distributed/ICacheService;cluster.server.owner.map.reload java/util/concurrent/TimeUnit SECONDSLjava/util/concurrent/TimeUnit; 'org/idempiere/distributed/ICacheService tryLockD(Ljava/util/Map;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z  java/util/Map entrySet()Ljava/util/Set;  java/util/Set iterator()Ljava/util/Iterator; java/util/Iterator next()Ljava/lang/Object;java/util/Map$Entry getValuejava/lang/String equals(Ljava/lang/Object;)Z getKey java/util/List add shasNext remove&(Ljava/lang/Object;)Ljava/lang/Object; unLock$(Ljava/util/Map;Ljava/lang/Object;)V'Failed to lock cluster server owner map org/adempiere/base/Service locator&()Lorg/adempiere/base/IServiceLocator; "org/adempiere/base/IServiceLocator list7(Ljava/lang/Class;)Lorg/adempiere/base/IServicesHolder;  "org/adempiere/base/IServicesHolder    getServices()Ljava/util/List;  sisEmpty   createServers((Lorg/adempiere/server/IServerFactory;)V java/util/logging/Level FINELjava/util/logging/Level; #  isLoggable(Ljava/util/logging/Level;)Z  makeConcatWithConstants(I)Ljava/lang/String; #" #fine % &CstartAll(Failed to restart all servers*java/lang/Exception clusterIdLjava/lang/String;mapLjava/util/Map; cacheService)Lorg/idempiere/distributed/ICacheService; reloadLockKeytoRemoveLjava/util/List;entryLjava/util/Map$Entry;key noServersIserverFactoryListfactory%Lorg/adempiere/server/IServerFactory;LocalVariableTypeTable5Ljava/util/Map;$Ljava/util/List;;Ljava/util/Map$Entry;7Ljava/util/List;Bjava/lang/Throwablev(Lorg/adempiere/server/IServerFactory;)V <E FGgetProcessorClass()Ljava/lang/Class; I Jcontains <M N>(Ljava/util/Properties;)[Lorg/compiere/server/AdempiereServer; PRQ#org/compiere/server/AdempiereServer STgetModel)()Lorg/compiere/model/AdempiereProcessor; V WX canRunHereO(Lorg/compiere/server/AdempiereServer;Lorg/compiere/model/AdempiereProcessor;)Z PZ [C getServerID ] , _ `aput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;c;js%org/compiere/model/AdempiereProcessor Pu vw isOKtoRunOnIP*(Lorg/compiere/model/AdempiereProcessor;)Z addScheduler3(Lorg/compiere/model/MScheduler;)Ljava/lang/String; {Z|org/compiere/model/MScheduler ~ getServerInstance8(Ljava/lang/String;)Lorg/compiere/server/ServerInstance;  GgetClass < d(Ljava/util/Properties;Lorg/compiere/model/AdempiereProcessor;)Lorg/compiere/server/AdempiereServer; b 3Q(Lorg/compiere/server/AdempiereServerMgr;Lorg/compiere/server/AdempiereServer;Z)V  start&(Ljava/lang/String;)Ljava/lang/String; schedulerLorg/compiere/model/MScheduler;serverIdremoveScheduler  getLocalServerControllerR(Ljava/lang/String;)Lorg/compiere/server/AdempiereServerMgr$LocalServerController; b sisAlive  stop V ,(I)Ljava/lang/Object; b kl V  V sizeserverController>Lorg/compiere/server/AdempiereServerMgr$LocalServerController;erroriownerId   getInActiveA()[Lorg/compiere/server/AdempiereServerMgr$LocalServerController;  org/adempiere/util/ServerContext `getCurrentInstance b scheduleFuture&Ljava/util/concurrent/ScheduledFuture; $java/util/concurrent/ScheduledFuture sisDone  setCurrentInstance(Ljava/util/Properties;)V \ getAD_Client_ID(Ljava/util/Properties;)I b  getServer'()Lorg/compiere/server/AdempiereServer; r java/util/Properties  3 #AD_Client_ID \  setContext,(Ljava/util/Properties;Ljava/lang/String;I)V P recalculateSleepMS b   SEVERE  valueOf&(Ljava/lang/Object;)Ljava/lang/String;  # C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V  INFO # warning (II)Ljava/lang/String;Failed to start all servers?[Lorg/compiere/server/AdempiereServerMgr$LocalServerController;currentContexttempeLjava/lang/Exception; noRunning noStoppedServer not foundServer is already running ) C getMessage  CtoStringFailed to start serverserverID    getActive b  java/lang/Thread yield  # severed  msleep     %'&(org/compiere/server/AdempiereServerGroup ,(,()Lorg/compiere/server/AdempiereServerGroup; %* +dumpmaxWait.Server is already stop 3Failed to stop serverdestroy V6 7clear V9 :;toArray(([Ljava/lang/Object;)[Ljava/lang/Object;retValuegetLocalServerControllersgetServerInstances'()[Lorg/compiere/server/ServerInstance; A =C"org/compiere/server/ServerInstance bE Fs isInterrupted PH Is isSleeping PK LM getStartTime()Ljava/sql/Timestamp; PO PC getStatistics PR SC getServerInfo BU 3Vw(Ljava/lang/String;Lorg/compiere/model/AdempiereProcessor;ZZZLjava/sql/Timestamp;Ljava/lang/String;Ljava/lang/String;)V 9Y%[Lorg/compiere/server/ServerInstance; responses controllers controllerresponse$Lorg/compiere/server/ServerInstance;6Ljava/util/List; getStatus*(Lorg/compiere/model/AdempiereProcessor;)I rZ d efgetServerStatus(Ljava/lang/String;)I processorijava/lang/StringBuilderkAdempiereServerMgr[ hm 3oServers= hq rsappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; hu rv(I)Ljava/lang/StringBuilder;x ,ContextSize= { ,Started= h} r~-(Ljava/lang/Object;)Ljava/lang/StringBuilder;] hsbLjava/lang/StringBuilder;getDescription { C getVersiongetServerCount#()Lorg/compiere/server/ServerCount;org/compiere/server/ServerCount 2   addStarted(I)V   addStopped serverCount!Lorg/compiere/server/ServerCount; addingServiceL(Lorg/osgi/framework/ServiceReference;)Lorg/adempiere/server/IServerFactory;(Lorg/osgi/framework/ServiceReference;>;)Lorg/adempiere/server/IServerFactory; M  getService9(Lorg/osgi/framework/ServiceReference;)Ljava/lang/Object; reference%Lorg/osgi/framework/ServiceReference;Lorg/osgi/framework/ServiceReference;>;modifiedServiceM(Lorg/osgi/framework/ServiceReference;Lorg/adempiere/server/IServerFactory;)V(Lorg/osgi/framework/ServiceReference;>;Lorg/adempiere/server/IServerFactory;)VserviceremovedService bundleChanged#(Lorg/osgi/framework/BundleEvent;)V org/osgi/framework/BundleEvent getType 4 closeevent Lorg/osgi/framework/BundleEvent;'(Ljava/lang/String;)Ljava/lang/Boolean; java/lang/Boolean (Z)Ljava/lang/Boolean;runNow P `  s interruptedATimeout waiting for server process to be available for execution.java/lang/InterruptedExceptionserverInstancecount -org/idempiere/server/cluster/ClusterServerMgr getClusterService-()Lorg/idempiere/distributed/IClusterService; )org/idempiere/distributed/IClusterService getLocalMember,()Lorg/idempiere/distributed/IClusterMember; (org/idempiere/distributed/IClusterMember CgetId+Lorg/idempiere/distributed/IClusterService;local*Lorg/idempiere/distributed/IClusterMember;7()Ljava/util/Map;cluster.server.owner.map  getMap#(Ljava/lang/String;)Ljava/util/Map;:(Lorg/osgi/framework/ServiceReference;Ljava/lang/Object;)V#org/osgi/framework/ServiceReference       SourceFileAdempiereServerMgr.javaqLjava/lang/Object;Lorg/osgi/util/tracker/ServiceTrackerCustomizer;Lorg/adempiere/server/IServerFactory;>;Lorg/osgi/framework/BundleListener;Lorg/compiere/server/IServerManager;BootstrapMethods $java/lang/invoke/StringConcatFactory (Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;# Server: Alive: Dead: (checking) - Running=, Stopped=Server=(interrupting) - Wait timeout for interruped  (waiting) -   Stopped:  Server  not found InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookupEntryLocalServerController NestMembers!      &1  "(* Y[+),-%.*D+),0> 73Y1 4Y6<> DGGI6 L *"M OPQ#P)R/S:U+ >RST:3@*U*VYXY*[a*cYekn*pW*VYXY*tYvw*"bikm$c)d4e?f+ @yrsFzW(*L+*LY*+L+++*. wx {|}!~$5:@D+Fy1T $!C: _(**L+*M,N:-,VYX:,:2:+޹W::,W:-,-,W=*VYXY*tYvw<N-3- *-:<:*((!*$'>()*" $(,>Gct(.8P+p _yH+, -.(/0,1,Gt23c#45 6,78[93(:;<* -=Gt2>c#4?[9@TD. A )?  B C+D>M*w,H*w,KW+*aLN---Y:662:O:*U*:  *:  :   Y Y\:      YT ( Y ^W:   Y   YW*YbY*dgW,w))*v "-6JQ\bgmrw+f y:; h,-ijJklQmnb+, m-. w/0 4o, <:pm-= T C<qq{ <qPqr <qPqrAP)<qq<WXC,t*+ yklmnxy, I+zM*,}<N-'- -: <:D>+>*a+:*+U*+z}*:*::  YY\:    Y[ (Y^W:  Y  YW*YbY*gW*, ) )*  ,CZhw     !$ 7!=G(+f IyID,*93C:;hkl+,-./0 4o, <*9@-=T '{ {<P {<PAP){ {!y+zM*,N--*,:6h*YbN,-YJ*YW*:3*:(,\: ,W*Y*Z-. /0234$5'9-::;H<R>X?]@cAhBuCDH9L+\ y, ,*t8X7+,c*-.u,< c*-=Tb__`/*a*V+ y!&CYs(*LM>+2::,,ŶO'Y,:ŶOŶا4:(ݺ!,:,,+O>66s+2:2%((ݺ3(ݺ:(ݺ+((!3)?)3?%()*-`a bcefi3|8}<j?mSo]prqwstuvx|}{|}~|}c "%(*?BLf+z sy fib8k88z8gk*Tp(b7O)bA bAb6bU) B!?*+M,,,N:-,ŶO&Y-:,ŶO,Ŷ,ا7:(+:-:--( (,,,,mp),*r !%),?I]bimpr+>y ,k),r$T b<M)"b)bA bAbB!CO(* L='+2N- :(-ݺ+ٸ=]+2N 6#(-ݺ5-(-Ч:(-ݺ+=>6s+2:&(ݺ ?((ݺ!:(ݺ"+((#!$))H))*) 3<?DHLOWfio    %>D+Oy Bi-8kAc8HSkL6,888z8gkT_ b) bb)0bE) A!v*+M,,,-, /N(1--( (,,,2%/2)*6   !!%%)&/'2(3*@+E-[.+*vyv ,pk3T bL)B!4K(*W*Y5*78 9:+ y$ TVYXL=/*YbN--- +-gW*Y+bM+,8W,*& BC EF0G6CDILJRK+4TyL :8kL<< LT  V($TVYXL=/*YbN--- +-gW*Y+bM+,8W,*& TU WX0Y6UD[L\R]+4TyL :8kL<< LT V"b"=R*YbL*Y+8W+*f gh+y <!>?1 VYXL*@M,Y:66W2N-GBY-ŶY-ŶO--D-ŶG-ŶJ-ŶN-ŶQT:+W+BWX*. no p q'r9sHt]rbukpux+4y{Z3 v[ K\b ]^< {Z_TP!`a? *+bc*}+ y gn! o+=Z*YbN+-Y=BY-ŶY-ŶO--D-ŶG-ŶJ-ŶN-ŶQT*Y*.  %7F[_m+*oyo ,e8HkT S"7+="*YbN+-Y-*Y*" %'5+*7y7 ,-8kT CEhYjlL+np*Ytwp*aytzp*n|pW+* ,9@+Ey :C.*+ y!IYL=2*YbN-- ++*Y+*" ,49G+*IyA =8 kT &bLM/*n*+ y! 6+?+ y :;< :p [*F+ y;<p [*L+ y;<p,+G G+G GI*PQRST%U+W+,y,To*+M,,,*+>.*YbM+,Y*YW*Y*6 Z[ \^"_*`/d4e@fNgWh\djl+*oyo ,ik198Tb'k*+M, , +,ŶG ,Ŷ@>WW,ŶG,ŶG ,Ŷ4:=*Fqrsv"x)y,|.}14:>B}Q[ei+*kyk,e.;8T bKC|L++M, ,*+ y T bL+ +۹*+y0TA- *+,<*+A- *+,<*+A) *+*+ b    bb