1 [   X   X X  X  X X X X              ! "# $ % &( %) 7* +,- ) ./ +0 12 +3 42 )56 X78 9:; )< 7= % %> ? @ A B C D E F G H I J K L M N O$ X "P XQ XR XS TU TV "W "X "Y "5Z [\ X]^ InnerClassesLOGLorg/slf4j/Logger;dataTree&Lorg/apache/zookeeper/server/DataTree;sessionsWithTimeouts(Ljava/util/concurrent/ConcurrentHashMap; SignatureMLjava/util/concurrent/ConcurrentHashMap;snapLog8Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;minCommittedLogJmaxCommittedLogcommitLogCountI ConstantValuecommitLogBuffer committedLogLjava/util/LinkedList;ProposalLLjava/util/LinkedList;logLock3Ljava/util/concurrent/locks/ReentrantReadWriteLock; initializedZ;(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)VCodeLineNumberTableLocalVariableTablethis(Lorg/apache/zookeeper/server/ZKDatabase; isInitialized()Zclear()Vlock_ WriteLock=Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock; getDataTree(()Lorg/apache/zookeeper/server/DataTree;getmaxCommittedLog()JgetminCommittedLog getLogLock5()Ljava/util/concurrent/locks/ReentrantReadWriteLock;getCommittedLog()Ljava/util/LinkedList;rl`ReadLock;getDataTreeLastProcessedZxidsetDataTreeInit(Z)Vb getSessions()Ljava/util/Collection;*()Ljava/util/Collection;getSessionWithTimeOuts*()Ljava/util/concurrent/ConcurrentHashMap;O()Ljava/util/concurrent/ConcurrentHashMap; loadDataBaselisteneraPlayBackListenerILorg/apache/zookeeper/server/persistence/FileTxnSnapLog$PlayBackListener;zxid ExceptionsaddCommittedProposal((Lorg/apache/zookeeper/server/Request;)VeLjava/io/IOException;baosLjava/io/ByteArrayOutputStream;boa%Lorg/apache/jute/BinaryOutputArchive;pp1Lorg/apache/zookeeper/server/quorum/QuorumPacket;p4Lorg/apache/zookeeper/server/quorum/Leader$Proposal;request%Lorg/apache/zookeeper/server/Request;wl removeCnxn+(Lorg/apache/zookeeper/server/ServerCnxn;)Vcnxn(Lorg/apache/zookeeper/server/ServerCnxn; killSession(JJ)V sessionIddumpEphemerals(Ljava/io/PrintWriter;)VpwriterLjava/io/PrintWriter; getNodeCount()I getEphemerals(J)Ljava/util/HashSet;*(J)Ljava/util/HashSet;setlastProcessedZxid(J)V processTxnbProcessTxnResultu(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;hdr$Lorg/apache/zookeeper/txn/TxnHeader;txnLorg/apache/jute/Record;statNode\(Ljava/lang/String;Lorg/apache/zookeeper/server/ServerCnxn;)Lorg/apache/zookeeper/data/Stat;pathLjava/lang/String; serverCnxndgetNode:(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode; convertLong"(Ljava/lang/Long;)Ljava/util/List;aclLLjava/lang/Long;C(Ljava/lang/Long;)Ljava/util/List;getDataT(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)[Bstat Lorg/apache/zookeeper/data/Stat;watcherLorg/apache/zookeeper/Watcher; setWatchesR(JLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/zookeeper/Watcher;)V relativeZxid dataWatchesLjava/util/List; existWatches childWatchesLocalVariableTypeTable$Ljava/util/List;(JLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/zookeeper/Watcher;)VgetACLD(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List;e(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List; getChildrenb(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List;v(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List; isSpecialPath(Ljava/lang/String;)Z getAclSize truncateLog(J)Z truncateddeserializeSnapshot!(Lorg/apache/jute/InputArchive;)ViaLorg/apache/jute/InputArchive;serializeSnapshot"(Lorg/apache/jute/OutputArchive;)VoaLorg/apache/jute/OutputArchive;fappend((Lorg/apache/zookeeper/server/Request;)ZsirollLogcommitclose SourceFileZKDatabase.java xjava/util/LinkedList pq1java/util/concurrent/locks/ReentrantReadWriteLock tu vw$org/apache/zookeeper/server/DataTree `a&java/util/concurrent/ConcurrentHashMap bc fg hi ji gh i jk l xm ni (org/apache/zookeeper/server/ZKDatabase$1 xop qr s tu vuw2org/apache/zookeeper/server/quorum/Leader$Proposal x yz ijava/io/ByteArrayOutputStream{ |} ~   java/io/IOException ^_ This really should be impossible /org/apache/zookeeper/server/quorum/QuorumPacket  x          &org/apache/zookeeper/server/ZKDatabase  oljava/lang/Object;java/util/concurrent/locks/ReentrantReadWriteLock$WriteLock:java/util/concurrent/locks/ReentrantReadWriteLock$ReadLockGorg/apache/zookeeper/server/persistence/FileTxnSnapLog$PlayBackListener5org/apache/zookeeper/server/DataTree$ProcessTxnResult4org/apache/zookeeper/KeeperException$NoNodeExceptionNoNodeExceptionjava/lang/InterruptedException writeLock?()Ljava/util/concurrent/locks/ReentrantReadWriteLock$WriteLock;unlockreadLock>()Ljava/util/concurrent/locks/ReentrantReadWriteLock$ReadLock;getReadHoldCount(Ljava/util/Collection;)VlastProcessedZxid+(Lorg/apache/zookeeper/server/ZKDatabase;)V6org/apache/zookeeper/server/persistence/FileTxnSnapLogrestore(Lorg/apache/zookeeper/server/DataTree;Ljava/util/Map;Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog$PlayBackListener;)Jsize removeFirst()Ljava/lang/Object;getFirst)org/apache/zookeeper/server/quorum/LeaderpacketgetZxid#org/apache/zookeeper/server/Request#org/apache/jute/BinaryOutputArchive getArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;"org/apache/zookeeper/txn/TxnHeader serialize4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)Vorg/apache/jute/Recordorg/slf4j/Loggererror*(Ljava/lang/String;Ljava/lang/Throwable;)V toByteArray()[B(IJ[BLjava/util/List;)Vadd(Ljava/lang/Object;)Z!(Lorg/apache/zookeeper/Watcher;)VR(Ljava/lang/String;Lorg/apache/zookeeper/Watcher;)Lorg/apache/zookeeper/data/Stat; longKeyMapLjava/util/Map; java/util/Map/org/apache/zookeeper/server/util/SerializeUtilsV(Lorg/apache/zookeeper/server/DataTree;Lorg/apache/jute/InputArchive;Ljava/util/Map;)VW(Lorg/apache/zookeeper/server/DataTree;Lorg/apache/jute/OutputArchive;Ljava/util/Map;)Vorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;$org/apache/zookeeper/KeeperException!X[ ^_`abcdefghijiklmn olpqdstuBvw&xyz;**Y*Y** Y * Y *+{"SIJKT*U5V:W|;}~;fgz/*{_| }~zH* * * Y **L+* M,N+*$25595{2 ij nop$r(s/t2v5uBwGx|H}~$$z/* {| }~z/*{| }~z/*{| }~z/*{| }~!z:*L*&+Y*M ,N-:+*%''+'{'5|:}~2dz2* {| }~zA * { | }~ wz2* {| }~dz/*{| }~dzk!Y* L** *+!A* { | !}~ i3z *M,*"*#W**$%&'*"*+(*+()Y*N-+:+,-.+/+/01-2:4567Y+(-89:%Y::&+;*{  |  }~ i izA * +?{ %&| }~ z2* @{-| }~z= * A{6| }~ idzA * { >?| }~ izH * +,B{I|  }~  zH * +,C{T|  }~  z= * +D{]| }~ z= * +E{f| }~ dzS * +,-F{s|* }~   z* -G{ |>}~i dzH * +,H{|  }~  dzS * +,-I{|* }~   dz= * +J{| }~ z7 * KL{|  }~zl*M*N>*OX{ | }~i w3zV*M*P+*QR*{|}~3zE *P+*QS{  | }~ 3z= *+T{| }~ 3z6*U{ | }~3z6*V{ | }~3z6*W{ | }~3z,XY4Z{ = H ]:%'r   " ce