Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\upgrade\UpgradeSnapShotV1.class
???? 1 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? # ? % ? !"#$ #% %&'( %)* %+, 3- . / 0 123 %4 ;5 ;6 ;7 ;89 :;<= E> D? @A ?B CD ?EFG L% ?H I [J KL ?MNO ? PQRSTUTVW PXYZ[ _ ? \] _^ \_ _` \a _b \c _d \e _f \g _h \i _j \k _l mn ?op mq mr ?s st mu sv wx ?y ?z ?{ ?| ?} ?~ ? S?? ??? ? ?? ?I ?? ??? ???? LOG Lorg/slf4j/Logger; sessionsWithTimeouts (Ljava/util/concurrent/ConcurrentHashMap; Signature MLjava/util/concurrent/ConcurrentHashMap<Ljava/lang/Long;Ljava/lang/Integer;>; dataDir Ljava/io/File; snapShotDir oldDataTree 0Lorg/apache/zookeeper/server/upgrade/DataTreeV1; <init> (Ljava/io/File;Ljava/io/File;)V Code LineNumberTable LocalVariableTable this 7Lorg/apache/zookeeper/server/upgrade/UpgradeSnapShotV1; deserializeSnapshot `(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;Lorg/apache/jute/InputArchive;Ljava/util/Map;)V id J to I oldTree ia Lorg/apache/jute/InputArchive; sessions Ljava/util/Map; count LocalVariableTypeTable 4Ljava/util/Map<Ljava/lang/Long;Ljava/lang/Integer;>; Exceptions ?(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;Lorg/apache/jute/InputArchive;Ljava/util/Map<Ljava/lang/Long;Ljava/lang/Integer;>;)V playLog !(Lorg/apache/jute/InputArchive;)J bytes [B hdr $Lorg/apache/zookeeper/txn/TxnHeader; txn Lorg/apache/jute/Record; r %Lorg/apache/zookeeper/server/Request; e Ljava/io/EOFException; logStream highestZxid processLogFiles B(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;[Ljava/io/File;)J logIs Ljava/io/InputStream; f arr$ [Ljava/io/File; len$ i$ logFiles zxid loadThisSnapShot ()V snapshot inputstream snapshotZxid files findMostRecentSnapshot ()Ljava/io/File; Ljava/io/IOException; Ljava/util/Iterator; Ljava/util/List; Ljava/util/List<Ljava/io/File;>; convertStat V(Lorg/apache/zookeeper/data/StatPersistedV1;)Lorg/apache/zookeeper/data/StatPersisted; oldStat +Lorg/apache/zookeeper/data/StatPersistedV1; stat )Lorg/apache/zookeeper/data/StatPersisted; convertDataNode ?(Lorg/apache/zookeeper/server/DataTree;Lorg/apache/zookeeper/server/DataNode;Lorg/apache/zookeeper/server/upgrade/DataNodeV1;)Lorg/apache/zookeeper/server/DataNode; dt &Lorg/apache/zookeeper/server/DataTree; parent &Lorg/apache/zookeeper/server/DataNode; oldDataNode 0Lorg/apache/zookeeper/server/upgrade/DataNodeV1; dataNode recurseThroughDataTree ;(Lorg/apache/zookeeper/server/DataTree;Ljava/lang/String;)V lastSlash parentPath Ljava/lang/String; child dataTree path children Ljava/util/HashSet; thisDatNode 'Ljava/util/HashSet<Ljava/lang/String;>; convertThisSnapShot (()Lorg/apache/zookeeper/server/DataTree; getNewDataTree getSessionWithTimeOuts *()Ljava/util/concurrent/ConcurrentHashMap; O()Ljava/util/concurrent/ConcurrentHashMap<Ljava/lang/Long;Ljava/lang/Integer;>; <clinit> SourceFile UpgradeSnapShotV1.java ? ? &java/util/concurrent/ConcurrentHashMap ? ? ? ? ? ? .org/apache/zookeeper/server/upgrade/DataTreeV1 ? ?????? timeout????????? ? ???? java/lang/StringBuilder !loadData --- session in archive: ???? with timeout: ??????? tree?? txnEntry?? java/io/EOFException "org/apache/zookeeper/txn/TxnHeader??? EOR?? Last transaction was partial.?? ???? (higestZxid) >= (next log) for type ?????? )org/apache/zookeeper/txn/CreateSessionTxn?? %playLog --- create session in log: 0x?????? $playLog --- close session in log: 0x #org/apache/zookeeper/server/Request?? ?? ? ? ? ? ? ? Processing log file: ???? java/io/BufferedInputStream java/io/FileInputStream ?? ????? ? ??? ? ? ? java/io/IOException &Invalid snapshots or not snapshots in ? ?? ?????? ? ? Zxids not equal log zxid datatree processed ??????????? java/io/File?? Invalid snapshot ?? 'org/apache/zookeeper/data/StatPersisted?????????????????????????????????? ? ? ? ? $org/apache/zookeeper/server/DataNode? ?? ??? ?? ? ????? ???? ? ? ?? java/lang/String / ? ? $org/apache/zookeeper/server/DataTree !Upgrading from an empty snapshot. ? ? ? ? 5org/apache/zookeeper/server/upgrade/UpgradeSnapShotV1 java/lang/Object 3org/apache/zookeeper/server/upgrade/UpgradeSnapShot org/apache/jute/InputArchive readInt (Ljava/lang/String;)I readLong (Ljava/lang/String;)J java/lang/Long valueOf (J)Ljava/lang/Long; java/lang/Integer (I)Ljava/lang/Integer; java/util/Map put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; org/slf4j/Logger isTraceEnabled ()Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (J)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; $org/apache/zookeeper/server/ZooTrace logTraceMessage ((Lorg/slf4j/Logger;JLjava/lang/String;)V deserialize 3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V readBuffer (Ljava/lang/String;)[B /org/apache/zookeeper/server/util/SerializeUtils deserializeTxn @([BLorg/apache/zookeeper/txn/TxnHeader;)Lorg/apache/jute/Record; readByte (Ljava/lang/String;)B warn (Ljava/lang/String;)V getZxid ()J getType ()I error getClientId getTimeOut toHexString (J)Ljava/lang/String; processTxn ProcessTxnResult InnerClasses (Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/upgrade/DataTreeV1$ProcessTxnResult; remove &(Ljava/lang/Object;)Ljava/lang/Object; getCxid S(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)V -(Ljava/lang/Object;)Ljava/lang/StringBuilder; info (Ljava/io/File;)V (Ljava/io/InputStream;)V "org/apache/jute/BinaryInputArchive getArchive ;(Ljava/io/InputStream;)Lorg/apache/jute/BinaryInputArchive; java/io/InputStream close lastProcessedZxid listFiles ()[Ljava/io/File; 2org/apache/zookeeper/server/persistence/FileTxnLog getLogFiles !([Ljava/io/File;J)[Ljava/io/File; ,org/apache/zookeeper/server/persistence/Util sortDataDir 4([Ljava/io/File;Ljava/lang/String;Z)Ljava/util/List; java/util/List iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next ()Ljava/lang/Object; isValidSnapshot (Ljava/io/File;)Z *(Ljava/lang/String;Ljava/lang/Throwable;)V )org/apache/zookeeper/data/StatPersistedV1 getAversion setAversion (I)V getCtime setCtime (J)V getCversion setCversion getCzxid setCzxid getEphemeralOwner setEphemeralOwner getMtime setMtime getMzxid setMzxid getVersion setVersion .org/apache/zookeeper/server/upgrade/DataNodeV1 data acl convertAcls "(Ljava/util/List;)Ljava/lang/Long; d(Lorg/apache/zookeeper/server/DataNode;[BLjava/lang/Long;Lorg/apache/zookeeper/data/StatPersisted;)V setChildren (Ljava/util/HashSet;)V getNode D(Ljava/lang/String;)Lorg/apache/zookeeper/server/upgrade/DataNodeV1; equals (Ljava/lang/Object;)Z lastIndexOf (I)I substring (II)Ljava/lang/String; :(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode; addDataNode ;(Ljava/lang/String;Lorg/apache/zookeeper/server/DataNode;)V java/util/HashSet size org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ?org/apache/zookeeper/server/upgrade/DataTreeV1$ProcessTxnResult ! ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? w %*? *? Y? ? *+? *,? *? Y? ? ? ? H = I J K $ L ? % ? ? % ? ? % ? ? ? ? ? t, ? 6? `,? 7,? 6-? ? ? W? ? ? *? ? Y? ? ? ? ? ? ? ?????+,? ? ? . W X Y Z # [ 4 \ ? ] f a i b l c s d ? H P ? ? # F ? ? t ? ? t ? ? t ? ? t ? ? j ? ? ? t ? ? ? L ? ? ? ? ? ? ? A+!? " :?? ? #Y? $?? %Y? &:? ':+(? ) B? ? *? + ? #Y*? ,?? - ?? < ?? 6? ? Y? ? .? ? -? /? ? 0? ? ? 1 ? ? -A? 0? ? ???? ????? *? ? 2? ? 3? 4? ? 5W? ? ? 6? ? Y? 6? ? 2? 7? ? ? 3? 4? ? ? *? ? 8W? \*? ? 2? ? 9W? ? ? &? ? Y? :? ? 2? 7? ? ? *? ? 8W? *? ? 8W? ;Y ? <? 0? =:? >? ?? -? @??^: ? ?? # ? ~ m p q t v # w , x 9 y C z M | ] } ? ? ? ? ? ? ? ? ? ? ? ? ?, ?7 ?Z ?f ?i ?u ?? ?? ?? ?? ?? ?? ? ? R ? ? ? #? ? ? ,x ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? L ? ? ? ? ` B,:?66? M2:? ? Y? A? ? B? ? C ? DY? EY? F? G: * ? H? IB ? J????!? ? "