Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\DataTree.class
???? 1} b? ???? ? ? b? ? ?? ????????? b?? b? b??? ? ??? b?? ?? ? ? ????? ??? b? 9? 9?? 9? b? ;? b? b????????? ? 9???? 2? 2?? 5? %? e?? 9?? ;?? =? b?? @?? B? %? b? b? b? b? b?g? b? %?? b?? 5? B? B? B? B? B? B? B? B? B? B? B? B? B? B? B? B? B? B? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ???? 5? |? |? |? |? 5? ????? ????? |? |??? 5 5 5 ?? %? ?? % b 5 = b b b b ; 9 % % =? @ ! " ;#$ ?? %% & =' ;()?? ?* ?+ %, b- ?./ ?? 0 ?1 2 ?3 4 ?5 6 ?7 ?8 ?9: ?; ?< ?= ?> ?? ?@ A bBC ?; bDE ?; ?= ?? bF ?GH ?; ?> ?? bI bJK ?LM ?;N ?O ?? ?P ?6 ?= QR ?? ?? ?? ?? ??ST ?? bUV ?? WX YZ Y[ Y\ ?] ?*^ _ b` a?bcd?e f Yghij?k blm?n ?fop? ?qr stu bv?wJ $x $y bz{ $| |?}~ 5 5? b? b??????? ? ???? ? b???????????? ?? ????????????? ??? b? ? b? 9? =??? %????? b? ;? ?? ;??? ???? ;???? ?? ]??? ??? ?? ???? InnerClasses Counts ProcessTxnResult LOG Lorg/slf4j/Logger; nodes (Ljava/util/concurrent/ConcurrentHashMap; Signature bLjava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lorg/apache/zookeeper/server/DataNode;>; dataWatches *Lorg/apache/zookeeper/server/WatchManager; childWatches rootZookeeper Ljava/lang/String; ConstantValue procZookeeper procChildZookeeper quotaZookeeper quotaChildZookeeper pTrie &Lorg/apache/zookeeper/common/PathTrie; ephemerals Ljava/util/Map; HLjava/util/Map<Ljava/lang/Long;Ljava/util/HashSet<Ljava/lang/String;>;>; longKeyMap RLjava/util/Map<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;>; aclKeyMap RLjava/util/Map<Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;Ljava/lang/Long;>; aclIndex J root &Lorg/apache/zookeeper/server/DataNode; procDataNode quotaDataNode lastProcessedZxid scount I initialized Z $assertionsDisabled getEphemerals (J)Ljava/util/HashSet; Code LineNumberTable LocalVariableTable this &Lorg/apache/zookeeper/server/DataTree; sessionId retv Ljava/util/HashSet; cloned LocalVariableTypeTable 'Ljava/util/HashSet<Ljava/lang/String;>; *(J)Ljava/util/HashSet<Ljava/lang/String;>; getEphemeralsMap ()Ljava/util/Map; J()Ljava/util/Map<Ljava/lang/Long;Ljava/util/HashSet<Ljava/lang/String;>;>; incrementIndex ()J listACLEquals #(Ljava/util/List;Ljava/util/List;)Z a Lorg/apache/zookeeper/data/ACL; b i lista Ljava/util/List; listb 1Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>; e(Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;)Z convertAcls "(Ljava/util/List;)Ljava/lang/Long; acls ret Ljava/lang/Long; val C(Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;)Ljava/lang/Long; convertLong "(Ljava/lang/Long;)Ljava/util/List; longVal C(Ljava/lang/Long;)Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>; getSessions ()Ljava/util/Collection; *()Ljava/util/Collection<Ljava/lang/Long;>; addDataNode ;(Ljava/lang/String;Lorg/apache/zookeeper/server/DataNode;)V path node getNode :(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode; getNodeCount ()I getWatchCount getEphemeralsCount set i$ Ljava/util/Iterator; map result approximateDataSize value entry Entry Ljava/util/Map$Entry; OLjava/util/Map$Entry<Ljava/lang/String;Lorg/apache/zookeeper/server/DataNode;>; <init> ()V isSpecialPath (Ljava/lang/String;)Z copyStatPersisted U(Lorg/apache/zookeeper/data/StatPersisted;Lorg/apache/zookeeper/data/StatPersisted;)V from )Lorg/apache/zookeeper/data/StatPersisted; to copyStat C(Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/data/Stat;)V Lorg/apache/zookeeper/data/Stat; updateCount (Ljava/lang/String;I)V lastPrefix diff statNode updatedStat !Lorg/apache/zookeeper/StatsTrack; quotaNode thisStats updateBytes (Ljava/lang/String;J)V createNode <(Ljava/lang/String;[BLjava/util/List;JIJJ)Ljava/lang/String; list children Ljava/util/Set; longval child data [B acl ephemeralOwner parentCVersion zxid time lastSlash parentName childName stat parent #Ljava/util/Set<Ljava/lang/String;>; Exceptions ](Ljava/lang/String;[BLjava/util/List<Lorg/apache/zookeeper/data/ACL;>;JIJJ)Ljava/lang/String; deleteNode eowner bytes processed /Ljava/util/Set<Lorg/apache/zookeeper/Watcher;>; setData 9(Ljava/lang/String;[BIJJ)Lorg/apache/zookeeper/data/Stat; version s n lastdata getMaxPrefixWithQuota &(Ljava/lang/String;)Ljava/lang/String; getData T(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)[B watcher Lorg/apache/zookeeper/Watcher; R(Ljava/lang/String;Lorg/apache/zookeeper/Watcher;)Lorg/apache/zookeeper/data/Stat; getChildren b(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List; Ljava/util/ArrayList; childs )Ljava/util/ArrayList<Ljava/lang/String;>; v(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List<Ljava/lang/String;>; setACL E(Ljava/lang/String;Ljava/util/List;I)Lorg/apache/zookeeper/data/Stat; f(Ljava/lang/String;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;I)Lorg/apache/zookeeper/data/Stat; getACL D(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List; e(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>; processTxn u(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult; subtxn Lorg/apache/zookeeper/txn/Txn; ec bb Ljava/nio/ByteBuffer; record Lorg/apache/jute/Record; subHdr $Lorg/apache/zookeeper/txn/TxnHeader; subRc 7Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult; multiTxn #Lorg/apache/zookeeper/txn/MultiTxn; txns failed post_failed createTxn $Lorg/apache/zookeeper/txn/CreateTxn; deleteTxn $Lorg/apache/zookeeper/txn/DeleteTxn; setDataTxn %Lorg/apache/zookeeper/txn/SetDataTxn; setACLTxn $Lorg/apache/zookeeper/txn/SetACLTxn; errTxn #Lorg/apache/zookeeper/txn/ErrorTxn; checkTxn *Lorg/apache/zookeeper/txn/CheckVersionTxn; e &Lorg/apache/zookeeper/KeeperException; Ljava/io/IOException; NoNodeException 6Lorg/apache/zookeeper/KeeperException$NoNodeException; cTxn header txn rc 0Ljava/util/List<Lorg/apache/zookeeper/txn/Txn;>; killSession (JJ)V session getCounts B(Ljava/lang/String;Lorg/apache/zookeeper/server/DataTree$Counts;)V arr$ [Ljava/lang/String; len$ counts -Lorg/apache/zookeeper/server/DataTree$Counts; len updateQuotaForPath (Ljava/lang/String;)V c strack statPath traverseNode realPath endString setupQuota quotaPath serializeNode ;(Lorg/apache/jute/OutputArchive;Ljava/lang/StringBuilder;)V oa Lorg/apache/jute/OutputArchive; Ljava/lang/StringBuilder; pathString off deserializeList 0(Ljava/util/Map;Lorg/apache/jute/InputArchive;)V aclList j Lorg/apache/jute/Index; ia Lorg/apache/jute/InputArchive; s(Ljava/util/Map<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;>;Lorg/apache/jute/InputArchive;)V serializeList 1(Ljava/util/Map;Lorg/apache/jute/OutputArchive;)V XLjava/util/Map$Entry<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;>; iLjava/util/Set<Ljava/util/Map$Entry<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;>;>; t(Ljava/util/Map<Ljava/lang/Long;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;>;Lorg/apache/jute/OutputArchive;)V serialize 4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V tag deserialize 3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V parentPath dumpWatchesSummary (Ljava/io/PrintWriter;)V pwriter Ljava/io/PrintWriter; dumpWatches (Ljava/io/PrintWriter;Z)V byPath dumpEphemerals tmp k keys !Ljava/util/Set<Ljava/lang/Long;>; removeCnxn !(Lorg/apache/zookeeper/Watcher;)V clear setWatches R(JLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/zookeeper/Watcher;)V relativeZxid existWatches $Ljava/util/List<Ljava/lang/String;>; ?(JLjava/util/List<Ljava/lang/String;>;Ljava/util/List<Ljava/lang/String;>;Ljava/util/List<Ljava/lang/String;>;Lorg/apache/zookeeper/Watcher;)V setCversionPzxid (Ljava/lang/String;IJ)V newCversion <clinit> SourceFile DataTree.java}~????? java/util/HashSet?????????? org/apache/zookeeper/data/ACL???~ java/lang/Long???~?????? java/util/Listkl java/lang/StringBuilder "ERROR: ACL not available for long ????????P java/lang/RuntimeException Failed to fetch acls for ?P??mn $org/apache/zookeeper/server/DataNodeqrsr??????????????? java/util/Map$Entry???? java/lang/String???? &java/util/concurrent/ConcurrentHashMap (org/apache/zookeeper/server/WatchManager $org/apache/zookeeper/common/PathTrie{| java/util/HashMap 'org/apache/zookeeper/data/StatPersisted???????????? /xu?? /zookeeperzu /zookeeper/quota?????????????????????????????????????????????S Missing count node for stat org/apache/zookeeper/StatsTrack???P????????X Missing count node for quota Quota exceeded: count=?? limit=?P Missing stat node for bytes ???? Missing quota node for bytes bytes=? 4org/apache/zookeeper/KeeperException$NoNodeException?? 8org/apache/zookeeper/KeeperException$NodeExistsException NodeExistsException?????? zookeeper_limits P zookeeper_statsOP ?????????P? dataWatches.triggerWatch childWatches.triggerWatch org/apache/zookeeper/data/Stat? java/util/ArrayList??!"?????# 5org/apache/zookeeper/server/DataTree$ProcessTxnResult$?%?&?'?(???)?*?+?,? "org/apache/zookeeper/txn/CreateTxn-??u?./0?1?2??? "org/apache/zookeeper/txn/DeleteTxn?? #org/apache/zookeeper/txn/SetDataTxn?? "org/apache/zookeeper/txn/SetACLTxnDE !org/apache/zookeeper/txn/ErrorTxn3? (org/apache/zookeeper/txn/CheckVersionTxn !org/apache/zookeeper/txn/MultiTxn4/ org/apache/zookeeper/txn/Txn567 java/io/IOException Invalid type of op: ?? java/lang/AssertionError89:;<=>??=@? "org/apache/zookeeper/txn/TxnHeader?A $org/apache/zookeeper/KeeperExceptionB? Failed: :CDEFG= #Adjusting parent cversion for Txn: path: err: CP?? #Failed to set parent cversion for: ?D !Ignoring processTxn failure hdr: : error: Deleting ephemeral node for session 0xHI "Ignoring NoNodeException for path - while removing ephemeral for dead session 0x??JKL? ?GH +org/apache/zookeeper/server/DataTree$Counts?M Missing quota stat node /zookeeper_limitsN?OPTP??QRSTU?VWXYZYZP long[\]^_`?pqa?bcde]fmngfhi`a??h iU (Invalid Datatree, unable to find parent of path W?jkPwx Sessions with Ephemerals ( ):lP 0x m? !org/apache/zookeeper/WatchedEventnpq?rstu $org/apache/zookeeper/server/DataTreevw?xyz java/lang/Object &org/apache/zookeeper/server/DataTree$1 valueOf (J)Ljava/lang/Long; java/util/Map get &(Ljava/lang/Object;)Ljava/lang/Object; clone ()Ljava/lang/Object; size (I)Ljava/lang/Object; equals (Ljava/lang/Object;)Z put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; longValue{ org/apache/zookeeper/ZooDefs$Ids Ids OPEN_ACL_UNSAFE append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; org/slf4j/Logger error keySet ()Ljava/util/Set; values java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ()Z next entrySet java/util/Set getValue getKey length d(Lorg/apache/zookeeper/server/DataNode;[BLjava/lang/Long;Lorg/apache/zookeeper/data/StatPersisted;)V addChild getAversion setAversion (I)V getCtime setCtime (J)V getCversion setCversion getCzxid setCzxid getMtime setMtime getMzxid setMzxid getPzxid setPzxid getVersion setVersion getEphemeralOwner setEphemeralOwner getDataLength setDataLength getNumChildren setNumChildren org/apache/zookeeper/Quotas ([B)V getCount setCount getBytes ()[B (I)Ljava/lang/StringBuilder; warn setBytes (J)Ljava/lang/StringBuilder; lastIndexOf (I)I substring (II)Ljava/lang/String; (I)Ljava/lang/String; contains add startsWith addPath| ,org/apache/zookeeper/Watcher$Event$EventType Event EventType NodeCreated .Lorg/apache/zookeeper/Watcher$Event$EventType; triggerWatch Q(Ljava/lang/String;Lorg/apache/zookeeper/Watcher$Event$EventType;)Ljava/util/Set; NodeChildrenChanged remove removeChild deletePath isTraceEnabled $org/apache/zookeeper/server/ZooTrace logTraceMessage ((Lorg/slf4j/Logger;JLjava/lang/String;)V NodeDeleted `(Ljava/lang/String;Lorg/apache/zookeeper/Watcher$Event$EventType;Ljava/util/Set;)Ljava/util/Set; #(Lorg/apache/zookeeper/data/Stat;)V NodeDataChanged findMaxPrefix addWatch 3(Ljava/lang/String;Lorg/apache/zookeeper/Watcher;)V addAll (Ljava/util/Collection;)Z (Ljava/util/Collection;)V getClientId clientId getCxid cxid getZxid getType type err multiResult getPath getAcl ()Ljava/util/List; getEphemeral getParentCVersion getTime getErr getTxns java/nio/ByteBuffer wrap ([B)Ljava/nio/ByteBuffer; 1org/apache/zookeeper/server/ByteBufferInputStream byteBuffer2Record 0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)V )org/apache/zookeeper/KeeperException$Code RUNTIMEINCONSISTENCY +Lorg/apache/zookeeper/KeeperException$Code; intValue OK setType (JIJJI)V isDebugEnabled debug *(Ljava/lang/String;Ljava/lang/Throwable;)V code -()Lorg/apache/zookeeper/KeeperException$Code; NODEEXISTS toHexString (J)Ljava/lang/String; toArray (([Ljava/lang/Object;)[Ljava/lang/Object; count +(Lorg/apache/zookeeper/server/DataTree$1;)V endsWith indexOf (Ljava/lang/String;)I org/apache/jute/OutputArchive writeString '(Ljava/lang/String;Ljava/lang/String;)V writeRecord -(Lorg/apache/jute/Record;Ljava/lang/String;)V (C)Ljava/lang/StringBuilder; delete (II)Ljava/lang/StringBuilder; org/apache/jute/InputArchive readInt readLong (Ljava/lang/String;)J startVector +(Ljava/lang/String;)Lorg/apache/jute/Index; org/apache/jute/Index done incr writeInt (ILjava/lang/String;)V writeLong (JLjava/lang/String;)V %(Ljava/util/List;Ljava/lang/String;)V endVector readString readRecord java/io/PrintWriter print println removeWatcher .org/apache/zookeeper/Watcher$Event$KeeperState KeeperState SyncConnected 0Lorg/apache/zookeeper/Watcher$Event$KeeperState; s(Lorg/apache/zookeeper/Watcher$Event$EventType;Lorg/apache/zookeeper/Watcher$Event$KeeperState;Ljava/lang/String;)V org/apache/zookeeper/Watcher process &(Lorg/apache/zookeeper/WatchedEvent;)V java/lang/Class desiredAssertionStatus org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; org/apache/zookeeper/ZooDefs "org/apache/zookeeper/Watcher$Event !be kl mn o p qr sr tu v K wu v N xu yu v P zu {| }~ o ?~ o ? ?~ o ? ?? ?? ?? ?? A?? ?? ?? ?? / ?? ? ? ?*? ? ? ? N-? ? Y? ?:-Y:?-? ? :ç :??? % 1 4 4 9 4 ? "