Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\ZooKeeperServer.class
???? 1? \o #p cq \r \s \t \u \vw q \xy q \z{ | \} \~ q? ? ?? \?? \?? 9? ?? 9? ???? #? \?? ?? \? ??? #? ?? ???? \?? \? ????? \? ??? 9?? ;q \? #? #? \? #?? Bq #???????? #? ?? B? #? B? H? \? #? 9????? ?? ?? \?? H? \? #??? ? ?? \?????????? ?? ??????? k?? o? \? ?? ??? t? \????? \? \? \? \? \? \? c?? ??? ?? ??? ?? \? ??? ?? ??????? #? \? ??? \ ?A\ ? ? \ ? ?? \ \ \ ? ? ?q ? ?B ? ?! " # $ ?%&' ?() ?*+, ?-. ? \/0 ?1 \2 ? c34567 ?8 ?9 \: ?; ?<?= \>??@A ?q ?=?BC kD?EFG ?DH ?I JKL ??M \N #OPQR ?ST #U ?VW ?X YZ[ ?q ?\]^ ?_ Y`abcd ?? #f ghijk \lm ?n ?o ?p ?q ??rs ?/ \tu \v \wx qy \ z {|} q ?~ ?? P? ????? P??? ???? ? P? *? ???? \?? ?? ?? ?? ???? 8q 8?? ?? ?? ?? ????? A? ?????? ?????????? P? ?{ ?? #?? Un??? c?? c?? ??? ??? w8 \????? ChangeRecord InnerClasses MissingSessionException BasicDataTreeBuilder? DataTreeBuilder LOG Lorg/slf4j/Logger; jmxServerBean 1Lorg/apache/zookeeper/server/ZooKeeperServerBean; jmxDataTreeBean *Lorg/apache/zookeeper/server/DataTreeBean; DEFAULT_TICK_TIME I ConstantValue ? tickTime minSessionTimeout maxSessionTimeout sessionTracker ,Lorg/apache/zookeeper/server/SessionTracker; txnLogFactory 8Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog; zkDb (Lorg/apache/zookeeper/server/ZKDatabase; hzxid J ok Ljava/lang/Exception; firstProcessor .Lorg/apache/zookeeper/server/RequestProcessor; running Z superSecret requestsInProcess outstandingChanges Ljava/util/List; Signature LLjava/util/List<Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; outstandingChangesForPath Ljava/util/HashMap; aLjava/util/HashMap<Ljava/lang/String;Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; serverCnxnFactory /Lorg/apache/zookeeper/server/ServerCnxnFactory; serverStats )Lorg/apache/zookeeper/server/ServerStats; removeCnxn +(Lorg/apache/zookeeper/server/ServerCnxn;)V Code LineNumberTable LocalVariableTable this -Lorg/apache/zookeeper/server/ZooKeeperServer; cnxn (Lorg/apache/zookeeper/server/ServerCnxn; <init> ()V ?(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;IIILorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;Lorg/apache/zookeeper/server/ZKDatabase;)V treeBuilder =Lorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder; y(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;ILorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;)V Exceptions +()Lorg/apache/zookeeper/server/ServerStats; dumpConf (Ljava/io/PrintWriter;)V pwriter Ljava/io/PrintWriter; (Ljava/io/File;Ljava/io/File;I)V snapDir Ljava/io/File; logDir x(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;Lorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;)V getZKDatabase *()Lorg/apache/zookeeper/server/ZKDatabase; setZKDatabase +(Lorg/apache/zookeeper/server/ZKDatabase;)V loadData session Ljava/lang/Long; i$ Ljava/util/Iterator; deadSessions Ljava/util/LinkedList; LocalVariableTypeTable (Ljava/util/LinkedList<Ljava/lang/Long;>; takeSnapshot e Ljava/io/IOException; getZxid ()J getNextZxid setZxid (J)V zxid getTime close sessionId closeSession killSession (JJ)V expire? Session 7(Lorg/apache/zookeeper/server/SessionTracker$Session;)V 4Lorg/apache/zookeeper/server/SessionTracker$Session; touch id to registerJMX startdata startup setupRequestProcessors finalProcessor syncProcessor createSessionTracker startSessionTracker isRunning ()Z shutdown unregisterJMX incInProcess decInProcess getInProcess ()I generatePasswd (J)[B r Ljava/util/Random; p [B checkPasswd (J[B)Z passwd createSession .(Lorg/apache/zookeeper/server/ServerCnxn;[BI)J timeout Ljava/nio/ByteBuffer; setOwner (JLjava/lang/Object;)V owner Ljava/lang/Object;? revalidateSession -(Lorg/apache/zookeeper/server/ServerCnxn;JI)V sessionTimeout rc reopenSession /(Lorg/apache/zookeeper/server/ServerCnxn;J[BI)V finishSessionInit ,(Lorg/apache/zookeeper/server/ServerCnxn;Z)V rsp ,Lorg/apache/zookeeper/proto/ConnectResponse; baos Ljava/io/ByteArrayOutputStream; bos %Lorg/apache/jute/BinaryOutputArchive; bb valid U(Lorg/apache/zookeeper/server/ServerCnxn;Lorg/apache/zookeeper/proto/RequestHeader;)V requestHeader *Lorg/apache/zookeeper/proto/RequestHeader; getServerId submitRequest S(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)V type xid authInfo si %Lorg/apache/zookeeper/server/Request; 0Ljava/util/List<Lorg/apache/zookeeper/data/Id;>; s(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List<Lorg/apache/zookeeper/data/Id;>;)V ((Lorg/apache/zookeeper/server/Request;)V Ljava/lang/InterruptedException; validpacket ELorg/apache/zookeeper/server/ZooKeeperServer$MissingSessionException; RequestProcessorException HLorg/apache/zookeeper/server/RequestProcessor$RequestProcessorException; getSnapCount snapCount sc Ljava/lang/String; getGlobalOutstandingLimit limit setServerCnxnFactory 2(Lorg/apache/zookeeper/server/ServerCnxnFactory;)V factory getServerCnxnFactory 1()Lorg/apache/zookeeper/server/ServerCnxnFactory; getLastProcessedZxid getOutstandingRequests truncateLog getTickTime setTickTime (I)V getMinSessionTimeout setMinSessionTimeout min getMaxSessionTimeout setMaxSessionTimeout max getClientPort setTxnLogFactory ;(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)V txnLog getTxnLogFactory :()Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog; getState ()Ljava/lang/String; dumpEphemerals getNumAliveConnections processConnectRequest @(Lorg/apache/zookeeper/server/ServerCnxn;Ljava/nio/ByteBuffer;)V msg clientSessionId incomingBuffer bia $Lorg/apache/jute/BinaryInputArchive; connReq +Lorg/apache/zookeeper/proto/ConnectRequest; readOnly shouldThrottle (J)Z outStandingCount processPacket Ljava/lang/RuntimeException; rh (Lorg/apache/zookeeper/proto/ReplyHeader; authPacket 'Lorg/apache/zookeeper/proto/AuthPacket; scheme ap 9Lorg/apache/zookeeper/server/auth/AuthenticationProvider; authReturn? +Lorg/apache/zookeeper/KeeperException$Code; Lorg/apache/jute/Record; bais Ljava/io/InputStream; h processSasl W(Ljava/nio/ByteBuffer;Lorg/apache/zookeeper/server/ServerCnxn;)Lorg/apache/jute/Record; authorizationID #Ljavax/security/sasl/SaslException; saslServer 1Lorg/apache/zookeeper/server/ZooKeeperSaslServer; Ljava/lang/NullPointerException; clientTokenRecord +Lorg/apache/zookeeper/proto/GetSASLRequest; clientToken responseToken processTxn? ProcessTxnResult u(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult; cst +Lorg/apache/zookeeper/txn/CreateSessionTxn; hdr $Lorg/apache/zookeeper/txn/TxnHeader; txn 7Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult; opCode <clinit> SourceFile ZooKeeperServer.java~????wtxtyt|}?? java/util/ArrayList?? java/util/HashMap?? 'org/apache/zookeeper/server/ServerStats????mn java/lang/StringBuilder Created server with tickTime ???? minSessionTimeout )? maxSessionTimeout ,? datadir ???? snapdir ???6??? &org/apache/zookeeper/server/ZKDatabase?1?? clientPort=???/??( dataDir=?}??6?? dataLogDir= tickTime=&? maxClientCnxns=????? minSessionTimeout= maxSessionTimeout= serverId=??? 6org/apache/zookeeper/server/persistence/FileTxnSnapLog?? @org/apache/zookeeper/server/ZooKeeperServer$BasicDataTreeBuilder?????????? java/util/LinkedList?????????? java/lang/Long??????????????? java/io/IOException #Severe unrecoverable error, exiting(? Closing session 0x?? ? #ZooKeeperServer --- killSession: 0x z{ ?? Expiring session 0x , timeout of ? ms exceeded? Corg/apache/zookeeper/server/ZooKeeperServer$MissingSessionException No session with sessionid 0x % exists, probably expired and removed?? /org/apache/zookeeper/server/ZooKeeperServerBean?op (org/apache/zookeeper/server/DataTreeBean?qr java/lang/Exception Failed to register with JMX????????????? 1org/apache/zookeeper/server/FinalRequestProcessor 0org/apache/zookeeper/server/SyncRequestProcessor?? 0org/apache/zookeeper/server/PrepRequestProcessor?? .org/apache/zookeeper/server/SessionTrackerImpl? shutting down??!"???#$ Failed to unregister with JMX?t java/util/Random??%&??'()?*+,-.-/??? Session 0x is valid: ?0??????1? *org/apache/zookeeper/proto/ConnectResponse?2 java/io/ByteArrayOutputStream345 len67 connect89:? :org/apache/zookeeper/server/quorum/ReadOnlyZooKeeperServer;<??=>?@A?BCDE Invalid session 0x for client FG , probably expiredH? Established session 0x with negotiated timeout I? -Exception while establishing session, closing?? #org/apache/zookeeper/server/Request? J? java/lang/InterruptedException Unexpected interruption java/lang/RuntimeException Not started??????tKLM?? *Received packet at server of unknown type ? 9org/apache/zookeeper/server/UnimplementedRequestProcessorN? Dropping request: O6P? Forg/apache/zookeeper/server/RequestProcessor$RequestProcessorException Unable to process request: zookeeper.snapCountQRSTU ;SnapCount should be 2 or more. Now, snapCount is reset to 2 zookeeper.globalOutstandingLimit??%D tickTime set to minSessionTimeout set to maxSessionTimeout set to V? standalone7?8? 1org/apache/zookeeper/server/ByteBufferInputStream?EW4X )org/apache/zookeeper/proto/ConnectRequestYZ *Session establishment request from client client's lastZxid is 0x[?\] #Connection request from old client *; will be dropped if server is in r-o mode 2Refusing session request for not-read-only client <org/apache/zookeeper/server/ServerCnxn$CloseRequestException CloseRequestException^_`a? $Refusing session request for client as it has seen zxid 0x our last zxid is 0x?? client must try another serverb?c>d(e? %Client attempting to renew session 0x at ?? .Client attempting to establish new session at ??? (org/apache/zookeeper/proto/RequestHeader headerfgh? got auth packet %org/apache/zookeeper/proto/AuthPacketijk6lmnoQp>qrs 6Caught runtime exception from AuthenticationProvider: due to tQ 'No authentication provider for scheme: has u6 "Authentication failed for scheme: &org/apache/zookeeper/proto/ReplyHeaderv?w??xyz %Authentication succeeded for scheme: auth success VW response{|}??~? Responding to client SASL token. )org/apache/zookeeper/proto/GetSASLRequest?> Size of client SASL token: ?[??????6 /adding SASL authorization for authorizationID: org/apache/zookeeper/data/Id sasl???? !javax/security/sasl/SaslException $Client failed to SASL authenticate: zookeeper.allowSaslFailedClients true?(? BMaintaining client connection despite SASL authentication failure. =Closing client connection due to SASL authentication failure. java/lang/NullPointerException Pcnxn.saslServer is null: cnxn object did not initialize its saslServer properly.? Size of server SASL response: *org/apache/zookeeper/proto/SetSASLResponse?&???ad )org/apache/zookeeper/txn/CreateSessionTxn?? *****>>>>> Got ?? +org/apache/zookeeper/server/ZooKeeperServer??? Server environment:??? No prob?? java/lang/Object 9org/apache/zookeeper/server/SessionTracker$SessionExpirer SessionExpirer 0org/apache/zookeeper/server/ServerStats$Provider Provider 8org/apache/zookeeper/server/ZooKeeperServer$ChangeRecord ;org/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder 2org/apache/zookeeper/server/SessionTracker$Session? <org/apache/zookeeper/KeeperException$SessionExpiredException SessionExpiredException )org/apache/zookeeper/KeeperException$Code 5org/apache/zookeeper/server/DataTree$ProcessTxnResult 5(Lorg/apache/zookeeper/server/ServerStats$Provider;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; getDataDir ()Ljava/io/File; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; getSnapDir toString org/slf4j/Logger info (Ljava/lang/String;)V java/io/PrintWriter print println snapLog java/io/File getAbsolutePath -org/apache/zookeeper/server/ServerCnxnFactory getMaxClientCnxnsPerHost (Ljava/io/File;Ljava/io/File;)V isInitialized getDataTreeLastProcessedZxid loadDataBase getSessions ()Ljava/util/Collection; java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; getSessionWithTimeOuts *()Ljava/util/concurrent/ConcurrentHashMap; &java/util/concurrent/ConcurrentHashMap get &(Ljava/lang/Object;)Ljava/lang/Object; add (Ljava/lang/Object;)Z setDataTreeInit (Z)V longValue getDataTree (()Lorg/apache/zookeeper/server/DataTree; save Q(Lorg/apache/zookeeper/server/DataTree;Ljava/util/concurrent/ConcurrentHashMap;)V error *(Ljava/lang/String;Ljava/lang/Throwable;)V java/lang/System exit currentTimeMillis toHexString (J)Ljava/lang/String; isTraceEnabled $org/apache/zookeeper/server/ZooTrace logTraceMessage ((Lorg/slf4j/Logger;JLjava/lang/String;)V *org/apache/zookeeper/server/SessionTracker removeSession getSessionId getTimeout &org/apache/zookeeper/server/ServerCnxn getSessionTimeout touchSession (JI)Z 0(Lorg/apache/zookeeper/server/ZooKeeperServer;)V &org/apache/zookeeper/jmx/MBeanRegistry getInstance *()Lorg/apache/zookeeper/jmx/MBeanRegistry; register O(Lorg/apache/zookeeper/jmx/ZKMBeanInfo;Lorg/apache/zookeeper/jmx/ZKMBeanInfo;)V )(Lorg/apache/zookeeper/server/DataTree;)V warn notifyAll ^(Lorg/apache/zookeeper/server/ZooKeeperServer;Lorg/apache/zookeeper/server/RequestProcessor;)V start h(Lorg/apache/zookeeper/server/SessionTracker$SessionExpirer;Ljava/util/concurrent/ConcurrentHashMap;IJ)V ,org/apache/zookeeper/server/RequestProcessor clear unregister )(Lorg/apache/zookeeper/jmx/ZKMBeanInfo;)V nextBytes ([B)V java/util/Arrays equals ([B[B)Z (I)J java/nio/ByteBuffer allocate (I)Ljava/nio/ByteBuffer; putInt setSessionId (Z)Ljava/lang/StringBuilder; registerConnection (IIJ[B)V #org/apache/jute/BinaryOutputArchive getArchive =(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive; writeInt (ILjava/lang/String;)V serialize 4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V isOldClient writeBool (ZLjava/lang/String;)V toByteArray ()[B wrap ([B)Ljava/nio/ByteBuffer; remaining rewind ()Ljava/nio/Buffer; sendBuffer (Ljava/nio/ByteBuffer;)V getRemoteSocketAddress ()Ljava/net/InetSocketAddress; closeConn enableRecv wait isValid (I)Z processRequest isDebugEnabled getMessage debug getProperty &(Ljava/lang/String;)Ljava/lang/String; java/lang/Integer parseInt (Ljava/lang/String;)I getLocalPort "org/apache/jute/BinaryInputArchive ;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive; deserialize 3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V getLastZxidSeen readBool (Ljava/lang/String;)Z dataTree &Lorg/apache/zookeeper/server/DataTree; $org/apache/zookeeper/server/DataTree lastProcessedZxid getTimeOut getPasswd setSessionTimeout disableRecv slice ()Ljava/nio/ByteBuffer; getType byteBuffer2Record 0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)V getScheme 1org/apache/zookeeper/server/auth/ProviderRegistry getProvider M(Ljava/lang/String;)Lorg/apache/zookeeper/server/auth/AuthenticationProvider; AUTHFAILED getAuth 7org/apache/zookeeper/server/auth/AuthenticationProvider handleAuthentication W(Lorg/apache/zookeeper/server/ServerCnxn;[B)Lorg/apache/zookeeper/KeeperException$Code; OK listProviders getXid intValue (IJI)V sendResponse U(Lorg/apache/zookeeper/proto/ReplyHeader;Lorg/apache/jute/Record;Ljava/lang/String;)V getAuthInfo ()Ljava/util/List; me (Ljava/lang/Object;)V incrOutstandingRequests -(Lorg/apache/zookeeper/proto/RequestHeader;)V getToken zooKeeperSaslServer /org/apache/zookeeper/server/ZooKeeperSaslServer evaluateResponse ([B)[B isComplete getAuthorizationID '(Ljava/lang/String;Ljava/lang/String;)V addAuthInfo !(Lorg/apache/zookeeper/data/Id;)V java/lang/String "org/apache/zookeeper/txn/TxnHeader getClientId addSession (JI)V getClass ()Ljava/lang/Class; org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; org/apache/zookeeper/Environment logEnv '(Ljava/lang/String;Lorg/slf4j/Logger;)V $org/apache/zookeeper/KeeperException !\c de mn op qr st u v wt xt yt z{ |} ~ ?? ?? ?? D?? ?? u ? ?t ?? ? ? ?? ? ? ?? ?? E ?? ? A *? +? ? ? ? ?? ?? ?? ?? ? ? B*? *?? *? *? *? * ? *? Y? ? *? Y? ? *? Y*? ? ? ? * ? f h j l n z * | 5 ? A ?? B?? ?? ? J ?*? *?? *? *? *? * ? *? Y? ? *? Y? ? *? Y*? ? *+? *? *? *? *? ? ? Y? ? ? ? *? ? ? *? ? ? +? ? ? +? ? ? !? " ? ? B ? f h j l n z * | 5 ? A ? F ? L ? Q ? V ? \ ? ? ?? H ??? ?|} ?wt ?xt ?yt ??? ?~ ?? ? ^ *+-? #Y+? $? %? ? ? ?? * ?? |} wt ?? ? R ?? ? / *? ? ? ?? ?? ?? ? ? ?+&? '+*? (? )+*? '+*? ? +? ? ,? -+.? '+*? ? +? ? ,? -+/? '+*? 0? )+1? '+*? 2? 3? )+4? '+*? ? )+5? '+*? ? )+6? '+*? 7? 8? ? F ? ? ? ? % ? + ? <