1                      #     ?        . . :  . ? ?       D         .  ?   ?     W!" #$ [% [&' W() *+ ,-. c0 1 2 3 e4 5 6 7 89: ; <= n>?@ ABC u nE F G HI { .K L M nN OP OQ RSTU VW X YZ[\  ^_ a nb Oc d ef  g eh .i .j k lm > n o op r t u > ov b w xy > E o z{ | } ~ ~  8       8 > o  n          D e    D        3   ~ e ~    ~ ~ V   h         , [  ,      LOGLorg/slf4j/Logger;skipACLZ failCreatesubmittedRequests*Ljava/util/concurrent/LinkedBlockingQueue; SignatureQLjava/util/concurrent/LinkedBlockingQueue; nextProcessor.Lorg/apache/zookeeper/server/RequestProcessor;zks-Lorg/apache/zookeeper/server/ZooKeeperServer;^(Lorg/apache/zookeeper/server/ZooKeeperServer;Lorg/apache/zookeeper/server/RequestProcessor;)VCodeLineNumberTableLocalVariableTablethis2Lorg/apache/zookeeper/server/PrepRequestProcessor; setFailCreate(Z)Vbrun()Vrequest%Lorg/apache/zookeeper/server/Request; traceMaskJe Ljava/lang/InterruptedException;RequestProcessorException InnerClassesHLorg/apache/zookeeper/server/RequestProcessor$RequestProcessorException;Ljava/lang/Exception;getRecordForPath ChangeRecordN(Ljava/lang/String;)Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;aclLjava/lang/Long;childrenLjava/util/Set;n&Lorg/apache/zookeeper/server/DataNode;pathLjava/lang/String; lastChange:Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;LocalVariableTypeTable#Ljava/util/Set; ExceptionsaddChangeRecord=(Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;)VcgetPendingChangesB(Lorg/apache/zookeeper/MultiTransactionRecord;)Ljava/util/HashMap;cr lastSlashI parentPathparentCrNoNodeException6Lorg/apache/zookeeper/KeeperException$NoNodeException;opLorg/apache/zookeeper/Op;i$Ljava/util/Iterator; multiRequest-Lorg/apache/zookeeper/MultiTransactionRecord;pendingChangeRecordsLjava/util/HashMap;aLjava/util/HashMap;(Lorg/apache/zookeeper/MultiTransactionRecord;)Ljava/util/HashMap;rollbackPendingChanges(JLjava/util/HashMap;)ViterLjava/util/ListIterator;empty firstZxid priorIterzxidTLjava/util/ListIterator;PLjava/util/Iterator;e(JLjava/util/HashMap;)VcheckACLQ(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/util/List;ILjava/util/List;)VauthIdLorg/apache/zookeeper/data/Id;ap9Lorg/apache/zookeeper/server/auth/AuthenticationProvider;idaLorg/apache/zookeeper/data/ACL;Ljava/util/List;permids1Ljava/util/List;0Ljava/util/List;(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/util/List;ILjava/util/List;)V pRequest2TxnC(IJLorg/apache/zookeeper/server/Request;Lorg/apache/jute/Record;Z)Vie$Ljava/lang/IllegalArgumentException; path2Delete nodeRecordversioncurrentVersioncheckVersionRequest0Lorg/apache/zookeeper/proto/CheckVersionRequest; createRequest*Lorg/apache/zookeeper/proto/CreateRequest;listACL parentRecordparentCVersion createMode!Lorg/apache/zookeeper/CreateMode;ephemeralParent newCversions)Lorg/apache/zookeeper/data/StatPersisted; deleteRequest*Lorg/apache/zookeeper/proto/DeleteRequest;setDataRequest+Lorg/apache/zookeeper/proto/SetDataRequest; setAclRequest*Lorg/apache/zookeeper/proto/SetACLRequest;toesLjava/util/HashSet;typerecordLorg/apache/jute/Record; deserialize'Ljava/util/HashSet;pRequest((Lorg/apache/zookeeper/server/Request;)VLjava/io/IOException;&Lorg/apache/zookeeper/KeeperException; subrequestbaosLjava/io/ByteArrayOutputStream;boa%Lorg/apache/jute/BinaryOutputArchive;bbLjava/nio/ByteBuffer; checkRequesttxnskependingChangesindexsbLjava/lang/StringBuilder;0Ljava/util/List;removeDuplicates"(Ljava/util/List;)Ljava/util/List;retvalLjava/util/ArrayList;it6Ljava/util/ArrayList;5Ljava/util/Iterator;d(Ljava/util/List;)Ljava/util/List;fixupACL#(Ljava/util/List;Ljava/util/List;)Zcid authIdValidauthInfotoAddLjava/util/LinkedList;7Ljava/util/LinkedList;d(Ljava/util/List;Ljava/util/List;)ZprocessRequestshutdown SourceFilePrepRequestProcessor.javajava/lang/StringBuilder '2ProcessThread(sid:    cport:  ):  '(java/util/concurrent/LinkedBlockingQueue  #$ %&  #org/apache/zookeeper/server/Request T    4 java/lang/InterruptedExceptionUnexpected interruption Forg/apache/zookeeper/server/RequestProcessor$RequestProcessorException >org/apache/zookeeper/server/quorum/Leader$XidRolloverExceptionXidRolloverException  Unexpected exceptionjava/lang/Exception!PrepRequestProcessor exited loop! w ` 8org/apache/zookeeper/server/ZooKeeperServer$ChangeRecord   @A     '4org/apache/zookeeper/KeeperException$NoNodeException '  FG java/util/HashMap   org/apache/zookeeper/Op   =?          j6 2     org/apache/zookeeper/data/Id super org/apache/zookeeper/data/ACL  world anyone  !" #$4org/apache/zookeeper/KeeperException$NoAuthExceptionNoAuthException"org/apache/zookeeper/txn/TxnHeader %6 &T ' '( )* +, -. /0(org/apache/zookeeper/proto/CreateRequest 31 23   Invalid path  with session 0x4 56:org/apache/zookeeper/KeeperException$BadArgumentsExceptionBadArgumentsException 78  w 8org/apache/zookeeper/KeeperException$InvalidACLExceptionInvalidACLException @w no 9 :; <= >? @A%010djava/lang/ObjectB CD EFG H"java/lang/IllegalArgumentException8org/apache/zookeeper/KeeperException$NodeExistsExceptionNodeExistsException IEorg/apache/zookeeper/KeeperException$NoChildrenForEphemeralsException NoChildrenForEphemeralsException"org/apache/zookeeper/txn/CreateTxn JK L 'M N'org/apache/zookeeper/data/StatPersisted OP Q RS TT UV MN(org/apache/zookeeper/proto/DeleteRequest WX Y8org/apache/zookeeper/KeeperException$BadVersionExceptionBadVersionException6org/apache/zookeeper/KeeperException$NotEmptyExceptionNotEmptyException"org/apache/zookeeper/txn/DeleteTxn)org/apache/zookeeper/proto/SetDataRequest#org/apache/zookeeper/txn/SetDataTxn 'Z [V(org/apache/zookeeper/proto/SetACLRequest \"org/apache/zookeeper/txn/SetACLTxn '] ^V_ `a b)org/apache/zookeeper/txn/CreateSessionTxn 'V cd e0 fgh java/lang/String iP/Processed session termination for sessionid: 0x.org/apache/zookeeper/proto/CheckVersionRequest(org/apache/zookeeper/txn/CheckVersionTxn 'j k }~+org/apache/zookeeper/MultiTransactionRecordjava/io/IOExceptionjava/util/ArrayList PQ lm nV!org/apache/zookeeper/txn/ErrorTxno pq r s$org/apache/zookeeper/KeeperException tu/Got user-level KeeperException when processing  aborting remaining multi ops. Error Path: Error:  vw cdjava/io/ByteArrayOutputStreamx yz{ |} ~K org/apache/zookeeper/txn/Txn K '!org/apache/zookeeper/txn/MultiTxn 'Failed to process    5request buffer is nullDumping request buffer: 0x  q  authjava/util/LinkedList#Missing AuthenticationProvider for  ' X Shutting down 2 20org/apache/zookeeper/server/PrepRequestProcessor zookeeper.skipACLno yes4zookeeper.skipACL=="yes", ACL checks will be skippedjava/lang/Thread,org/apache/zookeeper/server/RequestProcessorappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;+org/apache/zookeeper/server/ZooKeeperServer getServerId()J(J)Ljava/lang/StringBuilder; getClientPort()I(I)Ljava/lang/StringBuilder;toString()Ljava/lang/String;(Ljava/lang/String;)Vtake()Ljava/lang/Object;org/slf4j/LoggerisTraceEnabled()Z$org/apache/zookeeper/server/ZooTrace logRequestN(Lorg/slf4j/Logger;JCLorg/apache/zookeeper/server/Request;Ljava/lang/String;)VrequestOfDeatherror*(Ljava/lang/String;Ljava/lang/Throwable;)VgetCause()Ljava/lang/Throwable;)org/apache/zookeeper/server/quorum/Leaderjava/lang/Throwable getMessageinfooutstandingChangesoutstandingChangesForPathget&(Ljava/lang/Object;)Ljava/lang/Object; getZKDatabase*()Lorg/apache/zookeeper/server/ZKDatabase;&org/apache/zookeeper/server/ZKDatabasegetNode:(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode;$org/apache/zookeeper/server/DataNode getChildren()Ljava/util/Set;stat java/util/Setsize convertLong"(Ljava/lang/Long;)Ljava/util/List;P(JLjava/lang/String;Lorg/apache/zookeeper/data/StatPersisted;ILjava/util/List;)Vjava/util/Listadd(Ljava/lang/Object;)Zput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;iterator()Ljava/util/Iterator;java/util/IteratorhasNextnextgetPath lastIndexOf(I)IindexOf substring(II)Ljava/lang/String; listIterator(I)Ljava/util/ListIterator;java/util/ListIterator hasPreviouspreviousremoveisEmpty(I)Ljava/lang/Object;values()Ljava/util/Collection;java/util/Collection getSchemeequalsgetId ()Lorg/apache/zookeeper/data/Id;getPerms1org/apache/zookeeper/server/auth/ProviderRegistry getProviderM(Ljava/lang/String;)Lorg/apache/zookeeper/server/auth/AuthenticationProvider;7org/apache/zookeeper/server/auth/AuthenticationProvidermatches'(Ljava/lang/String;Ljava/lang/String;)Z sessionIdcxidgetTime(JIJJI)Vhdr$Lorg/apache/zookeeper/txn/TxnHeader;sessionTracker,Lorg/apache/zookeeper/server/SessionTracker;getOwner*org/apache/zookeeper/server/SessionTracker checkSession(JLjava/lang/Object;)V1org/apache/zookeeper/server/ByteBufferInputStreambyteBuffer2Record0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)Vjava/lang/Long toHexString(J)Ljava/lang/String;getAcl()Ljava/util/List; getCversiongetFlagsorg/apache/zookeeper/CreateModefromFlag$(I)Lorg/apache/zookeeper/CreateMode; isSequentialjava/util/LocaleENGLISHLjava/util/Locale;java/lang/IntegervalueOf(I)Ljava/lang/Integer;formatK(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;%org/apache/zookeeper/common/PathUtils validatePathgetEphemeralOwnergetData()[B isEphemeral)(Ljava/lang/String;[BLjava/util/List;ZI)VtxnsetEphemeralOwner(J)VgetZxid duplicate=(J)Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord; childCount setCversion(I)V isSpecialPath(Ljava/lang/String;)Z getVersion(Ljava/lang/String;[BI)V setVersion getAversion&(Ljava/lang/String;Ljava/util/List;I)V setAversionjava/nio/ByteBufferrewind()Ljava/nio/Buffer;getInt addSession(JI)VsetOwner getEphemerals(J)Ljava/util/HashSet;java/util/HashSetsetSessionClosing(Ljava/lang/String;I)V getNextZxidtoRequestRecord()Lorg/apache/jute/Record;setType)org/apache/zookeeper/KeeperException$CodeRUNTIMEINCONSISTENCY+Lorg/apache/zookeeper/KeeperException$Code;intValuegetTypecode-()Lorg/apache/zookeeper/KeeperException$Code; setException)(Lorg/apache/zookeeper/KeeperException;)V#org/apache/jute/BinaryOutputArchive getArchive=(Ljava/io/OutputStream;)Lorg/apache/jute/BinaryOutputArchive;org/apache/jute/Record serialize4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V toByteArraywrap([B)Ljava/nio/ByteBuffer;array(I[B)V(Ljava/util/List;)V-(Ljava/lang/Object;)Ljava/lang/StringBuilder; hasRemaining()B(I)Ljava/lang/String;MARSHALLINGERRORcontainsisAuthenticated"(ILorg/apache/zookeeper/data/Id;)VisValidclearorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;java/lang/System getProperty8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;!  !"#$%&'()A*Y++   * Y*,*+*g+_6i;j@k+ A,-A%&A#$ ./)3* rs+ 012)b*LA+ A P++ *+FL!+"7L+$%+$&'(+"L(+"*'EH EW#E)*^x yz{}'~3:=BEHITWXbq|+> 734356I 78X$7; 7<,-=?)h M*+YN*,+-.M,d*/+0:RY:1:2:ç :.Y3+5 6*/78M-ç : - , ,9 :Y+;,7HKKPK *> ,17>ES+>>B@AE;BC,TDE,-FGHIJ E;BKL:MN)3*+YM*++<W*,+=+>W,çN,- *--0-* (2+3,-3OIPQ)t ?Y@M+AN-Bo-CD:E:*F: ,>W/G6 HI:*F:  , >W:,(W}:Zz}:*F!(05>GWZdlqz}+p 0JRIG3STdUGlVI 7X(WFG!^YZ u[\,-]^|_`J |_a!bcd) *+Y:*+*+JK:L3M.:NO*,=PW*+Q6 7*+R.N7-ST:  B7 C.:  N*, = >Wç :   *V %/;EL\_mpu  +\ ;!OI%OI %efmfgpch6>i\ ,-j6_`J %ek>il _a!mno) U+ +J-V:B CW:XYZ+V:BC[:\:]~sX^Z_`ZXa:I-V:B7CW:  XXZ __bŧicYd*V3@A D!b"i#s$&(*+,.034+z 3pq'[\%pq >[\KrsiztqbuvL[\%&@wxTywJ@zy{Lc!|}~) eYfg *hij s"tOd*kflmn: opq:/G6  H 9Yrsft 'uYv*wx: *y z {Y| I: * F: * }y~ 96 :+YY S :;:Yrsft 'uYv*F Y: 9 6 Y 9`6Y Y: f j:  Y` 9* *.Yj 8f*kflm: op:/G6  H*/ uYv I: * F: *F:* }y~69 Y YY j:  Yd* *.Yj8U*kflm: op:*F:*}y~696 Y`6Yj:9**kflm: op:*x: *y z {Y|*F:*}y~696 Y`6Y j:9*oWo6YoW*kf*fl*/f:*+Y:*+V:BDC.:9=W9f=W:B*C:*.Yj8*kfç :Y¶ft '*kflm: op:*F:*}y~696 Y`6Yǵ:TWW\W*2DGIJKLMNOPRT'U5V?XIYQ[c]m^w`adiefhklpnqrs"u.vJySz[{e}t~#+>EXbjt (28M\flo /9?BKUcl%=@Q_+B 67X2OIK[\%G1[\HFG+IETTn^?ST 'w IUG QI mT w.TSF5UTk,-Tj634J'z kL#) +j++    !eӻnYM*+*+,ʧCYN*+*+-ʧ&Y:*+*+ʧY:*+*+ʧY:*+*+ʧɻY:+op+:+eY+f+g**hijY:*7 : *: 6 A:BCD:: +j+Yضٷڵ* +ʧt: : +j+YݶٷڵY޶+߶ '+*  Y::+:Y+j<W +eY+f+g *h+ij+Y,*+*+ʧ*k+f+lmM+j+j+Y,ݶٷڵY޶+߶,, '+,MY+ ,"YN+o:%W-~W-WY-  +j+j+Yٷڵ+**+8AD  X)*FQ !" #%&,'/)8+A0D,F-i/l1u3~479:;ABCIYJKLNO PFULXT_]`daqb{defhikpq|PUXYu}+F&7o7]<d5{YZ [\U88]^uw~wj6 t l` iT \7}rlY7<,-34Jula L#)8YM+N-B!-C[:, ,W,*"#,36+4#uv8,-8@w0)\J 8@z0)!) ^U, ,J,N:-B-C[:\:X^Z_`ZXZ- Y:6+V:BeCW:  Xa:  &Y X $ 6[Y]   W%Xa:_ , :BC[:,<W,J*%!*5<Ygmr{~  !&CLO+Irs Sq l[\~{rs5uv<tqC uv-"[\^,-^w^@w@\!=J*^{^@z@!=!)B *+ W*  + ,- 342)a''** W** &+ ',-2)Y1ZUU'*O ST!U,]:b #9 .>:W % c/ uD {J ] ` q s )@