1                        # %  ! "# $ #% %&'( %) * %+, 3-  . / 0 123 %4 ;5 ;6 ;7 ;89 : ;<= E> D? @A B CD EFG L% H I [J KL MNO PQ RS TU TVW PXY Z[ _ \] _^ \_ _` \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   LOGLorg/slf4j/Logger;sessionsWithTimeouts(Ljava/util/concurrent/ConcurrentHashMap; SignatureMLjava/util/concurrent/ConcurrentHashMap;dataDirLjava/io/File; snapShotDir oldDataTree0Lorg/apache/zookeeper/server/upgrade/DataTreeV1;(Ljava/io/File;Ljava/io/File;)VCodeLineNumberTableLocalVariableTablethis7Lorg/apache/zookeeper/server/upgrade/UpgradeSnapShotV1;deserializeSnapshot`(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;Lorg/apache/jute/InputArchive;Ljava/util/Map;)VidJtoIoldTreeiaLorg/apache/jute/InputArchive;sessionsLjava/util/Map;countLocalVariableTypeTable4Ljava/util/Map; Exceptions(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;Lorg/apache/jute/InputArchive;Ljava/util/Map;)VplayLog!(Lorg/apache/jute/InputArchive;)Jbytes[Bhdr$Lorg/apache/zookeeper/txn/TxnHeader;txnLorg/apache/jute/Record;r%Lorg/apache/zookeeper/server/Request;eLjava/io/EOFException; logStream highestZxidprocessLogFilesB(Lorg/apache/zookeeper/server/upgrade/DataTreeV1;[Ljava/io/File;)JlogIsLjava/io/InputStream;farr$[Ljava/io/File;len$i$logFileszxidloadThisSnapShot()Vsnapshot inputstream snapshotZxidfilesfindMostRecentSnapshot()Ljava/io/File;Ljava/io/IOException;Ljava/util/Iterator;Ljava/util/List; Ljava/util/List; convertStatV(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; oldDataNode0Lorg/apache/zookeeper/server/upgrade/DataNodeV1;dataNoderecurseThroughDataTree;(Lorg/apache/zookeeper/server/DataTree;Ljava/lang/String;)V lastSlash parentPathLjava/lang/String;childdataTreepathchildrenLjava/util/HashSet; thisDatNode'Ljava/util/HashSet;convertThisSnapShot(()Lorg/apache/zookeeper/server/DataTree;getNewDataTreegetSessionWithTimeOuts*()Ljava/util/concurrent/ConcurrentHashMap;O()Ljava/util/concurrent/ConcurrentHashMap; SourceFileUpgradeSnapShotV1.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/BufferedInputStreamjava/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/Object3org/apache/zookeeper/server/upgrade/UpgradeSnapShotorg/apache/jute/InputArchivereadInt(Ljava/lang/String;)IreadLong(Ljava/lang/String;)Jjava/lang/LongvalueOf(J)Ljava/lang/Long;java/lang/Integer(I)Ljava/lang/Integer; java/util/Mapput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;org/slf4j/LoggerisTraceEnabled()Zappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;(J)Ljava/lang/StringBuilder;(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;$org/apache/zookeeper/server/ZooTracelogTraceMessage((Lorg/slf4j/Logger;JLjava/lang/String;)V deserialize3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V readBuffer(Ljava/lang/String;)[B/org/apache/zookeeper/server/util/SerializeUtilsdeserializeTxn@([BLorg/apache/zookeeper/txn/TxnHeader;)Lorg/apache/jute/Record;readByte(Ljava/lang/String;)Bwarn(Ljava/lang/String;)VgetZxid()JgetType()Ierror 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;getCxidS(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/InputStreamcloselastProcessedZxid listFiles()[Ljava/io/File;2org/apache/zookeeper/server/persistence/FileTxnLog getLogFiles!([Ljava/io/File;J)[Ljava/io/File;,org/apache/zookeeper/server/persistence/Util sortDataDir4([Ljava/io/File;Ljava/lang/String;Z)Ljava/util/List;java/util/Listiterator()Ljava/util/Iterator;java/util/IteratorhasNextnext()Ljava/lang/Object;isValidSnapshot(Ljava/io/File;)Z*(Ljava/lang/String;Ljava/lang/Throwable;)V)org/apache/zookeeper/data/StatPersistedV1 getAversion setAversion(I)VgetCtimesetCtime(J)V getCversion setCversiongetCzxidsetCzxidgetEphemeralOwnersetEphemeralOwnergetMtimesetMtimegetMzxidsetMzxid getVersion setVersion.org/apache/zookeeper/server/upgrade/DataNodeV1dataacl 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;)VgetNodeD(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;)Vjava/util/HashSetsizeorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;?org/apache/zookeeper/server/upgrade/DataTreeV1$ProcessTxnResult! w%**Y*+*,*Y H=IJK$L %%%t, 6`, 7, 6-W*Y+, . W XYZ#[4\?]faiblcsdHP#Ftttt j tL  A+!": #Y$%Y&:':+()B*+#Y*,- < 6Y .-/01 -A0*2345W6Y62734* 8W\*29W&Y:27* 8W* 8W;Y <0=:>?-@^: #~mp qtv#w,x9yCzM|]} ,7ZfiuR #,xL ` B,:66M2:YABCDYEYFG: * HIB J!"7ISX^\ I =Y T Q```^L7 *KL+!LYYM*BNDYEY+FGM,HN** -*O* P7*QR:** S7* P.YTU* P12  '7<IR`lyH7n<iRS`El9LX*QVWL+XM,Y;,Z[N-\-":Y]-B^(04L& (/146SV46(+AXJ JLJ_Y`M,+ab,+cd,+ef,+gh,+ij,+kl,+mn,+op,*  (08@H JJB.*-qr:sY,-t+-uvw:-xy "+>.... $"  ,* ,zN-x::{,| :,/}6,~:+:*+-:+, :Y/Z:*+Y,ͱJ !&$.%7&?(I*P+],^/{013p .7{e6IS 4YL* {zM, 1*+{+* P+789; >'?2@ 4,"LG **L+DE F L/*J " ;