1 \o #p cq \r \s \t \u \vw q \xy q \z{ | \} \~ q   \ \ 9  9   # \  \  #   \ \  \  9 ;q \ # # \ # Bq #    #  B # B H \ # 9    \ H \ #    \       k o \   t \  \ \ \ \ \ \ c     \      # \  \A\   \          \ \ \   q    B   ! " # $ %&' () *+, -.  \/0 1 \2 c34567 8 9 \: ; < = \>? @A q = BC kD EFG DH I JKLM \N #OPQR ST #U VW X YZ[ q \]^ _ Y`abcd  #f ghijk \lm n o p q rs / \tu \v \wx qy \ z {|} q ~   P   P   P *  \     8q 8     A    P {  # Un  c c   w8 \ ChangeRecord InnerClassesMissingSessionExceptionBasicDataTreeBuilderDataTreeBuilderLOGLorg/slf4j/Logger; jmxServerBean1Lorg/apache/zookeeper/server/ZooKeeperServerBean;jmxDataTreeBean*Lorg/apache/zookeeper/server/DataTreeBean;DEFAULT_TICK_TIMEI ConstantValue tickTimeminSessionTimeoutmaxSessionTimeoutsessionTracker,Lorg/apache/zookeeper/server/SessionTracker; txnLogFactory8Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;zkDb(Lorg/apache/zookeeper/server/ZKDatabase;hzxidJokLjava/lang/Exception;firstProcessor.Lorg/apache/zookeeper/server/RequestProcessor;runningZ superSecretrequestsInProcessoutstandingChangesLjava/util/List; SignatureLLjava/util/List;outstandingChangesForPathLjava/util/HashMap;aLjava/util/HashMap;serverCnxnFactory/Lorg/apache/zookeeper/server/ServerCnxnFactory; serverStats)Lorg/apache/zookeeper/server/ServerStats; removeCnxn+(Lorg/apache/zookeeper/server/ServerCnxn;)VCodeLineNumberTableLocalVariableTablethis-Lorg/apache/zookeeper/server/ZooKeeperServer;cnxn(Lorg/apache/zookeeper/server/ServerCnxn;()V(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;IIILorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;Lorg/apache/zookeeper/server/ZKDatabase;)V treeBuilder=Lorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;y(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;ILorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;)V Exceptions+()Lorg/apache/zookeeper/server/ServerStats;dumpConf(Ljava/io/PrintWriter;)VpwriterLjava/io/PrintWriter; (Ljava/io/File;Ljava/io/File;I)VsnapDirLjava/io/File;logDirx(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;Lorg/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder;)V getZKDatabase*()Lorg/apache/zookeeper/server/ZKDatabase; setZKDatabase+(Lorg/apache/zookeeper/server/ZKDatabase;)VloadDatasessionLjava/lang/Long;i$Ljava/util/Iterator; deadSessionsLjava/util/LinkedList;LocalVariableTypeTable(Ljava/util/LinkedList; takeSnapshoteLjava/io/IOException;getZxid()J getNextZxidsetZxid(J)VzxidgetTimeclose sessionId closeSession killSession(JJ)VexpireSession7(Lorg/apache/zookeeper/server/SessionTracker$Session;)V4Lorg/apache/zookeeper/server/SessionTracker$Session;touchidto registerJMX startdatastartupsetupRequestProcessorsfinalProcessor syncProcessorcreateSessionTrackerstartSessionTracker isRunning()Zshutdown unregisterJMX incInProcess decInProcess getInProcess()IgeneratePasswd(J)[BrLjava/util/Random;p[B checkPasswd(J[B)Zpasswd createSession.(Lorg/apache/zookeeper/server/ServerCnxn;[BI)JtimeoutLjava/nio/ByteBuffer;setOwner(JLjava/lang/Object;)VownerLjava/lang/Object;revalidateSession-(Lorg/apache/zookeeper/server/ServerCnxn;JI)VsessionTimeoutrc reopenSession/(Lorg/apache/zookeeper/server/ServerCnxn;J[BI)VfinishSessionInit,(Lorg/apache/zookeeper/server/ServerCnxn;Z)Vrsp,Lorg/apache/zookeeper/proto/ConnectResponse;baosLjava/io/ByteArrayOutputStream;bos%Lorg/apache/jute/BinaryOutputArchive;bbvalidU(Lorg/apache/zookeeper/server/ServerCnxn;Lorg/apache/zookeeper/proto/RequestHeader;)V requestHeader*Lorg/apache/zookeeper/proto/RequestHeader; getServerId submitRequestS(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)VtypexidauthInfosi%Lorg/apache/zookeeper/server/Request;0Ljava/util/List;s(Lorg/apache/zookeeper/server/ServerCnxn;JIILjava/nio/ByteBuffer;Ljava/util/List;)V((Lorg/apache/zookeeper/server/Request;)V Ljava/lang/InterruptedException; validpacketELorg/apache/zookeeper/server/ZooKeeperServer$MissingSessionException;RequestProcessorExceptionHLorg/apache/zookeeper/server/RequestProcessor$RequestProcessorException; getSnapCount snapCountscLjava/lang/String;getGlobalOutstandingLimitlimitsetServerCnxnFactory2(Lorg/apache/zookeeper/server/ServerCnxnFactory;)VfactorygetServerCnxnFactory1()Lorg/apache/zookeeper/server/ServerCnxnFactory;getLastProcessedZxidgetOutstandingRequests truncateLog getTickTime setTickTime(I)VgetMinSessionTimeoutsetMinSessionTimeoutmingetMaxSessionTimeoutsetMaxSessionTimeoutmax getClientPortsetTxnLogFactory;(Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;)VtxnLoggetTxnLogFactory:()Lorg/apache/zookeeper/server/persistence/FileTxnSnapLog;getState()Ljava/lang/String;dumpEphemeralsgetNumAliveConnectionsprocessConnectRequest@(Lorg/apache/zookeeper/server/ServerCnxn;Ljava/nio/ByteBuffer;)VmsgclientSessionIdincomingBufferbia$Lorg/apache/jute/BinaryInputArchive;connReq+Lorg/apache/zookeeper/proto/ConnectRequest;readOnlyshouldThrottle(J)ZoutStandingCount processPacketLjava/lang/RuntimeException;rh(Lorg/apache/zookeeper/proto/ReplyHeader; authPacket'Lorg/apache/zookeeper/proto/AuthPacket;schemeap9Lorg/apache/zookeeper/server/auth/AuthenticationProvider; authReturn+Lorg/apache/zookeeper/KeeperException$Code;Lorg/apache/jute/Record;baisLjava/io/InputStream;h processSaslW(Ljava/nio/ByteBuffer;Lorg/apache/zookeeper/server/ServerCnxn;)Lorg/apache/jute/Record;authorizationID#Ljavax/security/sasl/SaslException; saslServer1Lorg/apache/zookeeper/server/ZooKeeperSaslServer; Ljava/lang/NullPointerException;clientTokenRecord+Lorg/apache/zookeeper/proto/GetSASLRequest; clientToken responseToken processTxnProcessTxnResultu(Lorg/apache/zookeeper/txn/TxnHeader;Lorg/apache/jute/Record;)Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;cst+Lorg/apache/zookeeper/txn/CreateSessionTxn;hdr$Lorg/apache/zookeeper/txn/TxnHeader;txn7Lorg/apache/zookeeper/server/DataTree$ProcessTxnResult;opCode SourceFileZooKeeperServer.java ~   wt xt yt |} java/util/ArrayList java/util/HashMap 'org/apache/zookeeper/server/ServerStats   mnjava/lang/StringBuilderCreated server with tickTime   minSessionTimeout ) maxSessionTimeout , datadir   snapdir  6 &org/apache/zookeeper/server/ZKDatabase 1  clientPort=  / (dataDir= } 6  dataLogDir= tickTime= &maxClientCnxns=  minSessionTimeout=maxSessionTimeout= serverId=  6org/apache/zookeeper/server/persistence/FileTxnSnapLog @org/apache/zookeeper/server/ZooKeeperServer$BasicDataTreeBuilder     java/util/LinkedList    java/lang/Long        java/io/IOException#Severe unrecoverable error, exiting  (    Closing session 0x    #ZooKeeperServer --- killSession: 0x   z{  Expiring session 0x , timeout of  ms exceeded  Corg/apache/zookeeper/server/ZooKeeperServer$MissingSessionExceptionNo session with sessionid 0x% exists, probably expired and removed /org/apache/zookeeper/server/ZooKeeperServerBean  op  (org/apache/zookeeper/server/DataTreeBean  qrjava/lang/ExceptionFailed to register with JMX        1org/apache/zookeeper/server/FinalRequestProcessor0org/apache/zookeeper/server/SyncRequestProcessor  0org/apache/zookeeper/server/PrepRequestProcessor .org/apache/zookeeper/server/SessionTrackerImpl   shutting down ! "  #$Failed to unregister with JMX tjava/util/Random  %& ' () *+ ,- .- /  Session 0x is valid: 0    1*org/apache/zookeeper/proto/ConnectResponse 2java/io/ByteArrayOutputStream3 45len 67connect 89 ::org/apache/zookeeper/server/quorum/ReadOnlyZooKeeperServer ;<  => ?@ A BC DEInvalid session 0x for client FG, probably expired HEstablished session 0x with negotiated timeout I-Exception while establishing session, closing #org/apache/zookeeper/server/Request    Jjava/lang/InterruptedExceptionUnexpected interruptionjava/lang/RuntimeException Not started     t KL M *Received packet at server of unknown type 9org/apache/zookeeper/server/UnimplementedRequestProcessor NDropping request: O6 PForg/apache/zookeeper/server/RequestProcessor$RequestProcessorExceptionUnable to process request:zookeeper.snapCount QRS TU;SnapCount should be 2 or more. Now, snapCount is reset to 2 zookeeper.globalOutstandingLimit  %DtickTime set to minSessionTimeout set to maxSessionTimeout set to V standalone 7 81org/apache/zookeeper/server/ByteBufferInputStream EW 4X)org/apache/zookeeper/proto/ConnectRequest YZ*Session establishment request from client  client's lastZxid is 0x [ \]#Connection request from old client *; will be dropped if server is in r-o mode2Refusing session request for not-read-only client  d( e%Client attempting to renew session 0x at .Client attempting to establish new session at  (org/apache/zookeeper/proto/RequestHeaderheader fg hgot auth packet %org/apache/zookeeper/proto/AuthPacket ij k6l mn oQ p>q rs6Caught runtime exception from AuthenticationProvider:  due to tQ'No authentication provider for scheme:  has u6"Authentication failed for scheme: &org/apache/zookeeper/proto/ReplyHeader v w x yz%Authentication succeeded for scheme:  auth success VWresponse {| } ~  Responding to client SASL token.)org/apache/zookeeper/proto/GetSASLRequest >Size of client SASL token: [   6/adding SASL authorization for authorizationID: org/apache/zookeeper/data/Idsasl  !javax/security/sasl/SaslException$Client failed to SASL authenticate:  zookeeper.allowSaslFailedClientstrue (BMaintaining client connection despite SASL authentication failure.=Closing client connection due to SASL authentication failure.java/lang/NullPointerExceptionPcnxn.saslServer is null: cnxn object did not initialize its saslServer properly. Size of server SASL response: *org/apache/zookeeper/proto/SetSASLResponse &  ad)org/apache/zookeeper/txn/CreateSessionTxn *****>>>>> Got  +org/apache/zookeeper/server/ZooKeeperServer Server environment: No prob java/lang/Object9org/apache/zookeeper/server/SessionTracker$SessionExpirerSessionExpirer0org/apache/zookeeper/server/ServerStats$ProviderProvider8org/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;org/apache/zookeeper/server/ZooKeeperServer$DataTreeBuilder2org/apache/zookeeper/server/SessionTracker$Session*+ ~3*>**?@**A@BYCL*DEM,F$,GHN*I-J +-KW*L+MM,F,GHNB*!*?Oޱ6   #+KY_bj>K8* o%+j +jRz***P*IQLS+T UR$*%&$))+*!/*2  6 *Y a]6  !>* :;.V> D *W B C  `$YXY!"*ZFJ#K$$E*![\"]Y_Y!`*a *abN OP3T:UDW EEE>+cAYd Ye+fg!"* ZZ[8]=^ >>7C++hA+i6*a j&kYYl Ym!nijl mnoBs*CC 93tk`*oY*pqr*qs*tY*Puvr*v*qsLx+y*vLx+y*q7:wKNw6 x y|)}7:~;FKNOZ_ ;O`_%**#Y*$*>*z $ %R/*a*{*|*}*~*YL**+çM+,&)),)*   $. /2Y*LY*+M,*Y*,* '1 2 )G*Y**I* a  9 *a    /* B"**a *a* ** ***  &/6=A BK*v r*vL+y*q r*qL+y*q*vw 14w6  '145@EJ  5 K!9 *Y`    !9 *Yd    /* pYN:- *  V -* D*a7Y:,:W+*+W" ! '!."4#A$HDDDDt 8)'N *a- . /    J*a j6\,]Y Y!`*+345B9I:4JJJJt<Rz*  *+ *+ > ?AC4tR% 7 *2+Nx-yY +i +h *+hNY::-+*:dW+?Y+hY+!"+@Y+hY+i+!"+§N-y+ı w#&wjHI MKLPOTXU_VgWoXvY\]^_abgin#t&q'r2s6u\  OX_'777K *+hű xy    , |    Y+ :*ȱR t t    *D*YM* *ɶ˧N-y* YϷп,ç :,*+Ѷ+Ӹ=*++3*֧,Y׶+Ӷ!Y+ۧPM!Yݶ,޶!#MY,!,T  >AAEAHkHj  +2<HPX\fmt> XE) "K*<<Lw"   tyL+=N= w * t>*+2  !"/*2 #2*? $0*酭 %B *W    R&/* '(]!Y!"* !!wt)@* *h* *(]!Y!"* !!+t,A* *h* -(]!Y!"* !!.t/=*2 *2  01>*+ 2}34/* 56- 7A *+   82*2" 9:MY,NY:-1Y+Y!6-6+(:Y+!6*/Y+!:"Y*ZY+Y*?Y!:"Y6 :*66*6   6+ +  7  T 7 Y  Y+!"*2 + *+ ,Y+!"*+XYfiR(& '()(*V/Y1a2f9i3k6:;=>@AI&J0L7M>NDOKPORUS\T`VfYjZq[x\]`abcdfhk#;;G< = >?@AYB7t>DxtUyt q RCDU** k lnEF:u Y,N-:Y:,MdpY+!"Y:,:: : D+!": 2: Y#$ ! :  %|/Y&'(! Y)!*Y+  ,-: + .++ g Y/!Y0+!"*Y+ %,-: + .f.*,+1:*Y+ %,-:+2..Y++h+,+3:45*+6w+s tuv"z'{1|P}Y~_fmrw#+269Da-G #HI HI YEJKf8Lm1MNr,OQ  R HI= ST>?URVW78Y9N+--::Y;!:,<:=:>7?:Y@!",AYBCDW:YF!G GHIJK,ħ:MN!YO!PYQEE?Lf <?ENW^{f ^-XRYEZ[ \= ]^_?`Rad+R6+S7*+,TNR,U,U:*aVWDYX,YZ,[!*ab-2  $*:=ls~H*efghiRjjzkt tl@ \]^_wY`abO Qomnhb f\gk\i ;\j k\l   P@bgc e d e