Edit C:\dspace\webapps\solr\WEB-INF\lib\org\apache\zookeeper\server\PrepRequestProcessor.class
???? 1?? ?? ? ?? ?? ?? ?? ? ?? ? ? ? ? ? ?? ? ???? ?? ? ?????? #?? ??????? ?? ?? ??? ?? ?? ?? ?????????? ??? ? . .? : . ? ?? ? D ? ? ? . ? ? W!" ?#$ [% [&' W() *+,-. c?0 1 2 ?3 e4 5 ?6 789: ; <= 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 ? ?? ??? ??,? [? ,? ? ??? ???? ?????? LOG Lorg/slf4j/Logger; skipACL Z failCreate submittedRequests *Ljava/util/concurrent/LinkedBlockingQueue; Signature QLjava/util/concurrent/LinkedBlockingQueue<Lorg/apache/zookeeper/server/Request;>; nextProcessor .Lorg/apache/zookeeper/server/RequestProcessor; zks -Lorg/apache/zookeeper/server/ZooKeeperServer; <init> ^(Lorg/apache/zookeeper/server/ZooKeeperServer;Lorg/apache/zookeeper/server/RequestProcessor;)V Code LineNumberTable LocalVariableTable this 2Lorg/apache/zookeeper/server/PrepRequestProcessor; setFailCreate (Z)V b run ()V request %Lorg/apache/zookeeper/server/Request; traceMask J e Ljava/lang/InterruptedException; RequestProcessorException InnerClasses HLorg/apache/zookeeper/server/RequestProcessor$RequestProcessorException; Ljava/lang/Exception; getRecordForPath ChangeRecord N(Ljava/lang/String;)Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord; acl Ljava/lang/Long; children Ljava/util/Set; n &Lorg/apache/zookeeper/server/DataNode; path Ljava/lang/String; lastChange :Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord; LocalVariableTypeTable #Ljava/util/Set<Ljava/lang/String;>; Exceptions addChangeRecord =(Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;)V c getPendingChanges B(Lorg/apache/zookeeper/MultiTransactionRecord;)Ljava/util/HashMap; cr lastSlash I parentPath parentCr NoNodeException 6Lorg/apache/zookeeper/KeeperException$NoNodeException; op Lorg/apache/zookeeper/Op; i$ Ljava/util/Iterator; multiRequest -Lorg/apache/zookeeper/MultiTransactionRecord; pendingChangeRecords Ljava/util/HashMap; aLjava/util/HashMap<Ljava/lang/String;Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; ?(Lorg/apache/zookeeper/MultiTransactionRecord;)Ljava/util/HashMap<Ljava/lang/String;Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; rollbackPendingChanges (JLjava/util/HashMap;)V iter Ljava/util/ListIterator; empty firstZxid priorIter zxid TLjava/util/ListIterator<Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; PLjava/util/Iterator<Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>; e(JLjava/util/HashMap<Ljava/lang/String;Lorg/apache/zookeeper/server/ZooKeeperServer$ChangeRecord;>;)V checkACL Q(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/util/List;ILjava/util/List;)V authId Lorg/apache/zookeeper/data/Id; ap 9Lorg/apache/zookeeper/server/auth/AuthenticationProvider; id a Lorg/apache/zookeeper/data/ACL; Ljava/util/List; perm ids 1Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>; 0Ljava/util/List<Lorg/apache/zookeeper/data/Id;>; ?(Lorg/apache/zookeeper/server/ZooKeeperServer;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;ILjava/util/List<Lorg/apache/zookeeper/data/Id;>;)V pRequest2Txn C(IJLorg/apache/zookeeper/server/Request;Lorg/apache/jute/Record;Z)V ie $Ljava/lang/IllegalArgumentException; path2Delete nodeRecord version currentVersion checkVersionRequest 0Lorg/apache/zookeeper/proto/CheckVersionRequest; createRequest *Lorg/apache/zookeeper/proto/CreateRequest; listACL parentRecord parentCVersion createMode !Lorg/apache/zookeeper/CreateMode; ephemeralParent newCversion s )Lorg/apache/zookeeper/data/StatPersisted; deleteRequest *Lorg/apache/zookeeper/proto/DeleteRequest; setDataRequest +Lorg/apache/zookeeper/proto/SetDataRequest; setAclRequest *Lorg/apache/zookeeper/proto/SetACLRequest; to es Ljava/util/HashSet; type record Lorg/apache/jute/Record; deserialize 'Ljava/util/HashSet<Ljava/lang/String;>; pRequest ((Lorg/apache/zookeeper/server/Request;)V Ljava/io/IOException; &Lorg/apache/zookeeper/KeeperException; subrequest baos Ljava/io/ByteArrayOutputStream; boa %Lorg/apache/jute/BinaryOutputArchive; bb Ljava/nio/ByteBuffer; checkRequest txns ke pendingChanges index sb Ljava/lang/StringBuilder; 0Ljava/util/List<Lorg/apache/zookeeper/txn/Txn;>; removeDuplicates "(Ljava/util/List;)Ljava/util/List; retval Ljava/util/ArrayList; it 6Ljava/util/ArrayList<Lorg/apache/zookeeper/data/ACL;>; 5Ljava/util/Iterator<Lorg/apache/zookeeper/data/ACL;>; d(Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;)Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>; fixupACL #(Ljava/util/List;Ljava/util/List;)Z cid authIdValid authInfo toAdd Ljava/util/LinkedList; 7Ljava/util/LinkedList<Lorg/apache/zookeeper/data/ACL;>; d(Ljava/util/List<Lorg/apache/zookeeper/data/Id;>;Ljava/util/List<Lorg/apache/zookeeper/data/ACL;>;)Z processRequest shutdown <clinit> SourceFile PrepRequestProcessor.java java/lang/StringBuilder'2 ProcessThread(sid:??????? cport:???? ):??'? (java/util/concurrent/LinkedBlockingQueue #$%&?? #org/apache/zookeeper/server/Request?T??? ????4?? java/lang/InterruptedException Unexpected interruption?? Forg/apache/zookeeper/server/RequestProcessor$RequestProcessorException??? >org/apache/zookeeper/server/quorum/Leader$XidRolloverException XidRolloverException????? Unexpected exception java/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 ?=? ??j62??? org/apache/zookeeper/data/Id? super org/apache/zookeeper/data/ACL? world? anyone !"#$ 4org/apache/zookeeper/KeeperException$NoAuthException NoAuthException "org/apache/zookeeper/txn/TxnHeader%6&T'?'()*+,-?./0 (org/apache/zookeeper/proto/CreateRequest3?123 ? Invalid path with session 0x456 :org/apache/zookeeper/KeeperException$BadArgumentsException BadArgumentsException78???w?? 8org/apache/zookeeper/KeeperException$InvalidACLException InvalidACLException@wno9?:?;<=>??@A %010d java/lang/ObjectBCDEFGH? "java/lang/IllegalArgumentException 8org/apache/zookeeper/KeeperException$NodeExistsException NodeExistsExceptionI? Eorg/apache/zookeeper/KeeperException$NoChildrenForEphemeralsException NoChildrenForEphemeralsException "org/apache/zookeeper/txn/CreateTxnJKL?'MN? 'org/apache/zookeeper/data/StatPersistedOPQ?RSTTUVMN (org/apache/zookeeper/proto/DeleteRequestWXY? 8org/apache/zookeeper/KeeperException$BadVersionException BadVersionException 6org/apache/zookeeper/KeeperException$NotEmptyException NotEmptyException "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_`ab? )org/apache/zookeeper/txn/CreateSessionTxn'Vcde0fgh java/lang/StringiP /Processed session termination for sessionid: 0x .org/apache/zookeeper/proto/CheckVersionRequest (org/apache/zookeeper/txn/CheckVersionTxn'jk?}~ +org/apache/zookeeper/MultiTransactionRecord java/io/IOException java/util/ArrayListPQlmnV !org/apache/zookeeper/txn/ErrorTxnopqr?s? $org/apache/zookeeper/KeeperExceptiontu /Got user-level KeeperException when processing ?? aborting remaining multi ops. Error Path: Error:??vwcd java/io/ByteArrayOutputStreamxyz{|}~K? org/apache/zookeeper/txn/Txn?K'? !org/apache/zookeeper/txn/MultiTxn'? Failed to process ??????5? request buffer is null Dumping request buffer: 0x???q??? auth java/util/LinkedList #Missing AuthenticationProvider for ??'??X Shutting down?2?2 0org/apache/zookeeper/server/PrepRequestProcessor??? zookeeper.skipACL no??? yes 4zookeeper.skipACL=="yes", ACL checks will be skipped java/lang/Thread ,org/apache/zookeeper/server/RequestProcessor append -(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;)V take ()Ljava/lang/Object; org/slf4j/Logger isTraceEnabled ()Z $org/apache/zookeeper/server/ZooTrace logRequest N(Lorg/slf4j/Logger;JCLorg/apache/zookeeper/server/Request;Ljava/lang/String;)V requestOfDeath error *(Ljava/lang/String;Ljava/lang/Throwable;)V getCause ()Ljava/lang/Throwable; )org/apache/zookeeper/server/quorum/Leader java/lang/Throwable getMessage info outstandingChanges outstandingChangesForPath get &(Ljava/lang/Object;)Ljava/lang/Object; getZKDatabase *()Lorg/apache/zookeeper/server/ZKDatabase; &org/apache/zookeeper/server/ZKDatabase getNode :(Ljava/lang/String;)Lorg/apache/zookeeper/server/DataNode; $org/apache/zookeeper/server/DataNode getChildren ()Ljava/util/Set; stat java/util/Set size convertLong "(Ljava/lang/Long;)Ljava/util/List; P(JLjava/lang/String;Lorg/apache/zookeeper/data/StatPersisted;ILjava/util/List;)V java/util/List add (Ljava/lang/Object;)Z put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; iterator ()Ljava/util/Iterator; java/util/Iterator hasNext next getPath lastIndexOf (I)I indexOf substring (II)Ljava/lang/String; listIterator (I)Ljava/util/ListIterator; java/util/ListIterator hasPrevious previous remove isEmpty (I)Ljava/lang/Object; values ()Ljava/util/Collection; java/util/Collection getScheme equals getId ()Lorg/apache/zookeeper/data/Id; getPerms 1org/apache/zookeeper/server/auth/ProviderRegistry getProvider M(Ljava/lang/String;)Lorg/apache/zookeeper/server/auth/AuthenticationProvider; 7org/apache/zookeeper/server/auth/AuthenticationProvider matches '(Ljava/lang/String;Ljava/lang/String;)Z sessionId cxid getTime (JIJJI)V hdr $Lorg/apache/zookeeper/txn/TxnHeader; sessionTracker ,Lorg/apache/zookeeper/server/SessionTracker; getOwner *org/apache/zookeeper/server/SessionTracker checkSession (JLjava/lang/Object;)V 1org/apache/zookeeper/server/ByteBufferInputStream byteBuffer2Record 0(Ljava/nio/ByteBuffer;Lorg/apache/jute/Record;)V java/lang/Long toHexString (J)Ljava/lang/String; getAcl ()Ljava/util/List; getCversion getFlags org/apache/zookeeper/CreateMode fromFlag $(I)Lorg/apache/zookeeper/CreateMode; isSequential java/util/Locale ENGLISH Ljava/util/Locale; java/lang/Integer valueOf (I)Ljava/lang/Integer; format K(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; %org/apache/zookeeper/common/PathUtils validatePath getEphemeralOwner getData ()[B isEphemeral )(Ljava/lang/String;[BLjava/util/List;ZI)V txn setEphemeralOwner (J)V getZxid 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 setAversion java/nio/ByteBuffer rewind ()Ljava/nio/Buffer; getInt addSession (JI)V setOwner getEphemerals (J)Ljava/util/HashSet; java/util/HashSet setSessionClosing (Ljava/lang/String;I)V getNextZxid toRequestRecord ()Lorg/apache/jute/Record; setType )org/apache/zookeeper/KeeperException$Code RUNTIMEINCONSISTENCY +Lorg/apache/zookeeper/KeeperException$Code; intValue getType code -()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 serialize 4(Lorg/apache/jute/OutputArchive;Ljava/lang/String;)V toByteArray wrap ([B)Ljava/nio/ByteBuffer; array (I[B)V (Ljava/util/List;)V -(Ljava/lang/Object;)Ljava/lang/StringBuilder; hasRemaining ()B (I)Ljava/lang/String; MARSHALLINGERROR contains isAuthenticated "(ILorg/apache/zookeeper/data/Id;)V isValid clear org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; java/lang/System getProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; ! ! "