1 ;N O PQR S T ;U V WX Y ;Z[ ;\ ;] P^ _ `ab ;cd Se f g h ijkl m Pn ;o 5^ 5Qp 5V ;q 7V ;r 5s tu vw vxy .z .{| 1} %~ =S 5S 7S 9S ; <S >S % ; ; ; ; ;? ; % ; 1Y > > > > > > > > > > > > > > > > > >                        1 xm x x xh 1   i x x  1 1 1 S % t S % ;  1 9 ; 9 ; ;  7  5 %  % 9 i@   7 S %  7 tV   % ;  S               ;   ;    ;     ; ;        i P u i  i ; t   ;  xS 1! 1" ;# ;$ %& %' ( } ) ;*+ ,-. ,/ S ,0 12 S 3  14 PV %5 Ps %6 %7 u 8 %9 ;: m ;; 5< ,= %S ,>?@A 'm ;B 7h CD 7EFG CHIJK 7L P<M NO 7P QRS iTUV InnerClassesCountsProcessTxnResultLOGLorg/apache/log4j/Logger;nodes(Ljava/util/concurrent/ConcurrentHashMap; SignaturebLjava/util/concurrent/ConcurrentHashMap; dataWatches*Lorg/apache/zookeeper/server/WatchManager; childWatches rootZookeeperLjava/lang/String; ConstantValue procZookeeperprocChildZookeeperquotaZookeeperquotaChildZookeeperpTrie&Lorg/apache/zookeeper/common/PathTrie; ephemeralsLjava/util/Map;HLjava/util/Map;>; longKeyMapRLjava/util/Map;>; aclKeyMapRLjava/util/Map;Ljava/lang/Long;>;aclIndexJroot&Lorg/apache/zookeeper/server/DataNode; procDataNode quotaDataNodelastProcessedZxidscountI initializedZ getEphemerals(J)Ljava/util/HashSet;CodeLineNumberTableLocalVariableTablethis&Lorg/apache/zookeeper/server/DataTree; sessionIdretvLjava/util/HashSet;clonedLocalVariableTypeTable'Ljava/util/HashSet;*(J)Ljava/util/HashSet;getEphemeralsMap()Ljava/util/Map;J()Ljava/util/Map;>;incrementIndex()J listACLEquals#(Ljava/util/List;Ljava/util/List;)ZaLorg/apache/zookeeper/data/ACL;bilistaLjava/util/List;listb1Ljava/util/List;e(Ljava/util/List;Ljava/util/List;)Z convertAcls"(Ljava/util/List;)Ljava/lang/Long;aclsretLjava/lang/Long;valC(Ljava/util/List;)Ljava/lang/Long; convertLong"(Ljava/lang/Long;)Ljava/util/List;longValC(Ljava/lang/Long;)Ljava/util/List; getSessions()Ljava/util/Collection;*()Ljava/util/Collection; addDataNode;(Ljava/lang/String;Lorg/apache/zookeeper/server/DataNode;)VpathnodegetNode:(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode; getNodeCount()I getWatchCountapproximateDataSizevalueentryEntryLjava/util/Map$Entry;i$Ljava/util/Iterator;resultOLjava/util/Map$Entry;()V isSpecialPath(Ljava/lang/String;)ZcopyStatPersistedU(Lorg/apache/zookeeper/data/StatPersisted;Lorg/apache/zookeeper/data/StatPersisted;)Vfrom)Lorg/apache/zookeeper/data/StatPersisted;tocopyStatC(Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/data/Stat;)V Lorg/apache/zookeeper/data/Stat; updateCount(Ljava/lang/String;I)V lastPrefixdiffstatNode updatedStat!Lorg/apache/zookeeper/StatsTrack; quotaNode thisStats updateBytes(Ljava/lang/String;J)V createNode;(Ljava/lang/String;[BLjava/util/List;JJJ)Ljava/lang/String;listchildrenLjava/util/Set;cverlongvalchilddata[BaclephemeralOwnerzxidtime lastSlash parentName childNamestatparent#Ljava/util/Set; Exceptions\(Ljava/lang/String;[BLjava/util/List;JJJ)Ljava/lang/String; deleteNodeeownerbytes processed/Ljava/util/Set;setData9(Ljava/lang/String;[BIJJ)Lorg/apache/zookeeper/data/Stat;versionsnlastdatagetDataT(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)[BwatcherLorg/apache/zookeeper/Watcher;R(Ljava/lang/String;Lorg/apache/zookeeper/Watcher;)Lorg/apache/zookeeper/data/Stat; getChildrenb(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List;Ljava/util/ArrayList;childs)Ljava/util/ArrayList;v(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;Lorg/apache/zookeeper/Watcher;)Ljava/util/List;setACLE(Ljava/lang/String;Ljava/util/List;I)Lorg/apache/zookeeper/data/Stat;f(Ljava/lang/String;Ljava/util/List;I)Lorg/apache/zookeeper/data/Stat;getACLD(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List;e(Ljava/lang/String;Lorg/apache/zookeeper/data/Stat;)Ljava/util/List; processTxnu(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;errTxn#Lorg/apache/zookeeper/txn/ErrorTxn; createTxn$Lorg/apache/zookeeper/txn/CreateTxn; deleteTxn$Lorg/apache/zookeeper/txn/DeleteTxn; setDataTxn%Lorg/apache/zookeeper/txn/SetDataTxn; setACLTxn$Lorg/apache/zookeeper/txn/SetACLTxn;e&Lorg/apache/zookeeper/KeeperException;header$Lorg/apache/zookeeper/txn/TxnHeader;txnLorg/apache/jute/Record;rc7Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;debug killSession(JJ)VNoNodeException6Lorg/apache/zookeeper/KeeperException$NoNodeException;session getCountsB(Ljava/lang/String;Lorg/apache/zookeeper/server/DataTree$Counts;)Varr$[Ljava/lang/String;len$counts-Lorg/apache/zookeeper/server/DataTree$Counts;lenupdateQuotaForPath(Ljava/lang/String;)VcstrackstatPath traverseNoderealPath endString setupQuota quotaPath serializeNode;(Lorg/apache/jute/OutputArchive;Ljava/lang/StringBuilder;)VoaLorg/apache/jute/OutputArchive;Ljava/lang/StringBuilder; pathStringoffdeserializeList0(Ljava/util/Map;Lorg/apache/jute/InputArchive;)VaclListjLorg/apache/jute/Index;iaLorg/apache/jute/InputArchive;s(Ljava/util/Map;>;Lorg/apache/jute/InputArchive;)V serializeList1(Ljava/util/Map;Lorg/apache/jute/OutputArchive;)VsetXLjava/util/Map$Entry;>;iLjava/util/Set;>;>;t(Ljava/util/Map;>;Lorg/apache/jute/OutputArchive;)V serialize4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)Vtag deserialize3(Lorg/apache/jute/InputArchive;Ljava/lang/String;)V parentPathdumpWatchesSummary(Ljava/io/PrintWriter;)VpwriterLjava/io/PrintWriter; dumpWatches(Ljava/io/PrintWriter;Z)VbyPathdumpEphemeralstmpkkeys!Ljava/util/Set; removeCnxn!(Lorg/apache/zookeeper/Watcher;)Vclear setWatchesR(JLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/zookeeper/Watcher;)V#Lorg/apache/zookeeper/WatchedEvent; relativeZxid existWatches$Ljava/util/List;(JLjava/util/List;Ljava/util/List;Ljava/util/List;Lorg/apache/zookeeper/Watcher;)V SourceFile DataTree.java UV WXY Z[java/util/HashSet  \] \] ^ Z_org/apache/zookeeper/data/ACL `a ZVjava/lang/Long xy XV bc dyf hjava/util/List CDjava/lang/StringBuilder"ERROR: ACL not available for long ij ik lmn opjava/lang/RuntimeExceptionFailed to fetch acls for  qr EF$org/apache/zookeeper/server/DataNode IJ KJ srt uvw xy z]java/util/Map$Entry {] |]java/lang/String } &java/util/concurrent/ConcurrentHashMap(org/apache/zookeeper/server/WatchManager$org/apache/zookeeper/common/PathTrie STjava/util/HashMap'org/apache/zookeeper/data/StatPersisted ~ ^_ `_ a_ b] ef/ PM  /zookeeper RM/zookeeper/quota   y    y  y  y  y    y      Missing count node for stat org/apache/zookeeper/StatsTrack     Missing count node for quota Quota exceeded:  count= i limit= pMissing stat node for bytes y Missing quota node for bytes  bytes= i   4org/apache/zookeeper/KeeperException$NoNodeException r a8org/apache/zookeeper/KeeperException$NodeExistsExceptionNodeExistsException   a zookeeper_limits zookeeper_stats        [  a _  ydataWatches.triggerWatch  childWatches.triggerWatch  org/apache/zookeeper/data/Stat   java/util/ArrayList     5org/apache/zookeeper/server/DataTree$ProcessTxnResult y ]  d y ]  d d"org/apache/zookeeper/txn/CreateTxnCreate transaction for m   y y  M"org/apache/zookeeper/txn/DeleteTxnDelete transaction for #org/apache/zookeeper/txn/SetDataTxnSet data for transaction for  "org/apache/zookeeper/txn/SetACLTxnSet ACL for transaction for  !org/apache/zookeeper/txn/ErrorTxn $org/apache/zookeeper/KeeperException   Failed:  yDeleting ephemeral node  for session 0x  p"Ignoring NoNodeException for path - while removing ephemeral for dead session 0x   d ]  +org/apache/zookeeper/server/DataTree$Counts Missing quota stat node /zookeeper_limits    cd   i  map long   y 23     /0  )* !" C  java/io/IOException(Invalid Datatree, unable to find parent  of path   9:Sessions with Ephemerals (): 0x: B!org/apache/zookeeper/WatchedEvent     $org/apache/zookeeper/server/DataTree   java/lang/Object&org/apache/zookeeper/server/DataTree$1valueOf(J)Ljava/lang/Long; java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object;clone()Ljava/lang/Object;size(I)Ljava/lang/Object;equals(Ljava/lang/Object;)Zput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; longValue  org/apache/zookeeper/ZooDefs$IdsIdsOPEN_ACL_UNSAFEappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;toString()Ljava/lang/String;org/apache/log4j/Loggererror(Ljava/lang/Object;)VkeySet()Ljava/util/Set;entrySet java/util/Setiterator()Ljava/util/Iterator;java/util/IteratorhasNext()ZnextgetValuegetKeylengthd(Lorg/apache/zookeeper/server/DataNode;[BLjava/lang/Long;Lorg/apache/zookeeper/data/StatPersisted;)VaddChild getAversion setAversion(I)VgetCtimesetCtime(J)V getCversion setCversiongetCzxidsetCzxidgetMtimesetMtimegetMzxidsetMzxidgetPzxidsetPzxid getVersion setVersiongetEphemeralOwnersetEphemeralOwner getDataLength setDataLengthgetNumChildrensetNumChildrenorg/apache/zookeeper/Quotas&(Ljava/lang/String;)Ljava/lang/String;([B)VgetCountsetCountgetBytes()[B(I)Ljava/lang/StringBuilder;warnsetBytes(J)Ljava/lang/StringBuilder; lastIndexOf(I)I substring(II)Ljava/lang/String;(I)Ljava/lang/String;containsadd startsWithaddPath findMaxPrefix,org/apache/zookeeper/Watcher$Event$EventTypeEvent EventType NodeCreated.Lorg/apache/zookeeper/Watcher$Event$EventType; triggerWatchQ(Ljava/lang/String;Lorg/apache/zookeeper/Watcher$Event$EventType;)Ljava/util/Set;NodeChildrenChangedremove removeChild deletePathisTraceEnabled$org/apache/zookeeper/server/ZooTracelogTraceMessage/(Lorg/apache/log4j/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;)VNodeDataChangedaddWatch3(Ljava/lang/String;Lorg/apache/zookeeper/Watcher;)VaddAll(Ljava/util/Collection;)Z(Ljava/util/Collection;)V"org/apache/zookeeper/txn/TxnHeader getClientIdclientIdgetCxidcxidgetZxidgetTypetypeerrgetPathgetAcl()Ljava/util/List; getEphemeralgetTimegetErrcode-()Lorg/apache/zookeeper/KeeperException$Code;)org/apache/zookeeper/KeeperException$CodeNONODE+Lorg/apache/zookeeper/KeeperException$Code; NODEEXISTS*(Ljava/lang/Object;Ljava/lang/Throwable;)VisDebugEnabled toHexString(J)Ljava/lang/String;toArray(([Ljava/lang/Object;)[Ljava/lang/Object;count+(Lorg/apache/zookeeper/server/DataTree$1;)VendsWithindexOf(Ljava/lang/String;)Iorg/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/InputArchivereadIntreadLong(Ljava/lang/String;)J startVector+(Ljava/lang/String;)Lorg/apache/jute/Index;org/apache/jute/IndexdoneincrwriteInt(ILjava/lang/String;)V writeLong(JLjava/lang/String;)V%(Ljava/util/List;Ljava/lang/String;)V endVector readString readRecordjava/io/PrintWriterprintprintln removeWatcher.org/apache/zookeeper/Watcher$Event$KeeperState KeeperState SyncConnected0Lorg/apache/zookeeper/Watcher$Event$KeeperState;s(Lorg/apache/zookeeper/Watcher$Event$EventType;Lorg/apache/zookeeper/Watcher$Event$KeeperState;Ljava/lang/String;)Vorg/apache/zookeeper/Watcherprocess&(Lorg/apache/zookeeper/WatchedEvent;)V getLogger,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;org/apache/zookeeper/ZooDefs"org/apache/zookeeper/Watcher$Event!;=CDEFGHIJKJLMNGOMNJPMQMNLRMSTUVGWXVGYZVG[\]^_`_a_Ab]cdef,ghi?*N- Y:-Y:-:ç :%14494j" %.<k*?lm?n].op qpr.os qsGtuvi/*jk lmGwxyi6 *Y a]jk  lmz{iI+,>+-+  :,  : j& )5?AGk>)|}5 ~}4dIlmIIrIIG!iG+  *+M,,*B*!+W*+!W!j&  $3Bk*GlmG.$#]r GG!i]++ *+M,7Y+YY+ ,j& #'@[k ]lm]#:r #:Gi4 *!jk  lmGiM *"+,#Wj  k  lm M _i@ *"+$%jk lm Mi2*"&jk lmi:*'(*)(`jk lmyio @*"*+N-,X--.:/%:Y:012a@3 3a@ç :5_bbgbj& #/5F\jmk4/;_#G^olmm]r #Gi *4*5Y6"*7Y8'*7Y8)*9Y:;*5Y6*Y?@A*%Y*A >Y?@B*%Y*B >Y?@C* D*E*"F*A#W*"G*A#W*AHIW*"J*B#W*BKIW*"L*C#WjVLOQ%i0n;uF{QV r"#%&'k  lmi[G+MJ+M L+Mj135klmM iI+*NO+*PQ+*RS+*TU+*VW+*XY+*Z[+*\]+*^_j* 9:;< =(>0?8@@AHBkII iY+*`a+*bc+*de+*fg+*hi+*jk+*lm+*no+*pq+*rs+*tuj2 EFGH I(J0K8L@MHNPOXPkYYi +vN*"-$%::Yw-Y:»xY1Y3yz:{`|}~3ç :+:*"$%::YY:»xY1Y3yz:ç :  {{6Y+{{:knnsnj^[\]^`3a4c:dOe[fhgvi|jklnoqrstuzkRlmMdM_|Mi +v:*"$%:Y:Y:»xY1Y3yz: a}~3ç :+:*"$%:Y:Y: »xY1Y3yz: ç :   6Y+=nqqvqj^347=R^kykRlmM]M_7Mki+/6 + : + `: >Y?:  Q W U Y [ ] O _*" $%: YY::  YR6S[*-:%Y, @: IW*"+#W P*:Y:*WY:+Wç :ç : L6 M*; L2 M* L2*;+:GM%FM**, ,*'+W*) FMG W+%/2272{=@@E@j1$+29@GMSZhmu{%,:HR\mwk:pdwg_lmM]]]d M M $ h}_VMr :sGia+/6+:+`:*"+$%: Y*"+W*"$%: YY: WR`S [^7  6* :   Y:  +W ç :  ç : JM*;L2*;+: G MIF M?* 6 Y: 3 3t6  ç : *  <Y+Y*'+: *)+ W*)FMGW_-EHHMHj)    ( -5>LQY_gy"#$&). /1$2'3-4B5P6Y8b9~;>@ACk Ep @] '2d lmM]dMM(_L_ M + r Es + i Y:*"+$%:  Y:  Y:  3:  ,3 W Y ]  ç :   *;+: G M+F M!* ,,  d*'+W,`cchcjJG HIJ#L&M,N3O9PCQMRVS]TkVuZ[^_kf lmMd]] _ & uAM iD*"+$%: YY:,- *'+-3ð: ;<<A<j& d efh i&j*k3m<nk4DlmDMDD 7_iHYN*"+$%:, *'+, YY:--ð:5?@@E@j* stuv"x'y/{5|;}@~k4HlmHMH@3_iT v*"+$%: YY:, ,:Y:W Y:- *)+-ð: mnnsnj>  $*16FQ[_hnkRF [1=vlmvMvv i_r F [1=GiQY:*"+$%: YY:O*,ð:)HIINIj*  #)2<CIk>QlmQMQQd H;_r QGi=*"+$%N- Y-Y:-,Y*-ð:455:5j "5k*=lm=M= 1_Gi$ YNF:-+-+-+µ-+ĵ--*D *-õD+Īy[yyyyyyyyyjy[yyy",:Yȶɶ:*̙ + ++ͶW-ɵϧ,:YѶҶ:*+¶ӧ,:Yնֶ:-*++ͶٵڧZ,:Yܶݶ:-*߶ڧ!*++¶,: - Ƨ>:*E*Y- j$ $,1=E'*0Ih k q  kp   0qQ9lm MiA *::,s-1:*!Ӳ)Y+:Y4jmj. *+,4.;/D0j9m5o69<kHo&4aMzlm]]pr s i *+N-:6-Y:-:1:-3-36ç :,Y`,Ya :66-2: *Y+G ,ұLOOTOjNQR S UVWXY!Z7\I]W_a`maxbydedgkp -M }9  4 d1dlmM _ dr -i/YM*+,xYN-,-,|YL+G:*:YY:-}~3ç :tj:p qrst'uFvNxSymzn|t}~k>lmM xFIMNA_i*+MN,Y:,:1Nç :-q-1:+#+L2+:**;-:66,2:*Y+Gӱ 03383jN -;?DHQbhqrkp bMH*MMu8  z3 d}0dlmM_ r ifLL*+M,*+j  k lmM _i ,N*-::Y:*Y`+-+:1:ç :,/W,6::66  ' 2: , W, W*+, ر_bbgbjZ %/:AF\jqw|kz AM 3  . d+d lmM _ w= dr A'!"if,  >, :* *Y:,:) Y:,W+W*WxjJ )2;FPYblsvkRY}v;W#FL$%lmXV&' dr;W#XY'G(")*im ,+ +N-+:,u-.:,0 /:,:,- :,,j. 4JVak\ }j"VA#4c|lmXV+r*VA#4c,XY+-'G./0i/***+ *+YF! *A+Gj # . k /lm//1M'23i **+"*"#+$N-GM%Y%:+&*"-#W-/6 *A-:*"$%*'YY()-*-`IW^7 <*:  Y: * W -W+$N*"G*A#W*+jn #,7BJPYbs{!"#$%&'),- .34k\ &p b4M@],_Jdlm&'1MMr &s '!56iD +*',-j ; <k lm 78!9:iL *'+.j D Ek  lm 78 ;f<6i *!M+Y/,01,+N-,--7+Y2-+31*:Y::,+-1: +Y4 1ç :  fj2 L M-OKPgQnRSTUWXYkRM 2M=pK>]4lm78 ?rM=s ?@ABiM*'+5*)+5j\]^klmCiL*A*"#*6jab cfk lmDEi* -:,-1:*: :  7Y89: B T7Y89: ! X7Y89:   :*'k:,s-1:*: :  5 X7Y89: 7Y89:   :*':,p-1:*: :  7Y89: ! Z7Y89:   :*)j$kl&m)n.oBqOrctpuxy{}~  #BJMRfsk&w_ )tF MY_ VF aMzJV_ MSF B^M,wlmG]IHKr IIHIKIGJKiB";<JHLJ2`KjF ZcLM@Z >;;A ;B .P   `eg Q @ i@N@