Edit C:\Users\Admin\.m2\repository\org\dspace\dspace-api\6.2\org\dspace\harvest\HarvestScheduler.class
???? 3? ' ? ' ? ' ? ? ? ? ? ? ? t ? ? ? ' ? ? ? ? ? ' ? ? ? ? ? ? ' ? ' ' u0 ' 6? ' ' ' ' ? @ ' 3 ? 3 t 3 !"#$%&%'( ) '*+ ,- @. @/0 @ 12 334 J5 678 !9 M5:; V< == V>? V@ VA ZBC Z ? DE DF 'G tHIJ `K !LM !N O =PQ RS =T +U kV WXY k !Z[ \] \^ _` _a log Lorg/apache/log4j/Logger; harvestAdmin Lorg/dspace/eperson/EPerson; mainContext Lorg/dspace/core/Context; lock Ljava/lang/Object; harvestThreads Ljava/util/Stack; Signature 5Ljava/util/Stack<Lorg/dspace/harvest/HarvestThread;>; maxActiveThreads Ljava/lang/Integer; activeThreads HARVESTER_STATUS_RUNNING I ConstantValue HARVESTER_STATUS_SLEEPING HARVESTER_STATUS_PAUSED HARVESTER_STATUS_STOPPED HARVESTER_INTERRUPT_NONE HARVESTER_INTERRUPT_PAUSE HARVESTER_INTERRUPT_STOP HARVESTER_INTERRUPT_RESUME !HARVESTER_INTERRUPT_INSERT_THREAD HARVESTER_INTERRUPT_KILL_THREAD status interrupt interruptValue Ljava/util/UUID; minHeartbeat J maxHeartbeat collectionService .Lorg/dspace/content/service/CollectionService; harvestedCollectionService 7Lorg/dspace/harvest/service/HarvestedCollectionService; hasStatus (I)Z Code LineNumberTable LocalVariableTable statusToCheck StackMapTable setInterrupt (I)V newInterrupt (ILjava/util/UUID;)V newInterruptValue getInterrupt ()I getStatus ()Ljava/lang/String; <init> ()V this %Lorg/dspace/harvest/HarvestScheduler; harvestAdminParam Ljava/lang/String;b Exceptionsc run scheduleLoop harvestedCollection (Lorg/dspace/harvest/HarvestedCollection; activeThread Ljava/lang/Thread; e Ljava/sql/SQLException; cids Ljava/util/List; Ljava/lang/Exception; calendar Ljava/util/Calendar; nextTime Ljava/util/Date; tempContext hc harvestInterval nextHarvest upperBound delay ie Ljava/lang/InterruptedException; i LocalVariableTypeTable :Ljava/util/List<Lorg/dspace/harvest/HarvestedCollection;>;[def+47 ?(I addThread D(Lorg/dspace/core/Context;Lorg/dspace/harvest/HarvestedCollection;)V context ht "Lorg/dspace/harvest/HarvestThread;g <clinit> SourceFile HarvestScheduler.java ? ? ? ? ? ? ;The scheduler is finishing active harvests before pausing. The scheduler is shutting down. 2The scheduler is actively harvesting collections. 5The scheduler is waiting for collections to harvest. The scheduler is paused. $Automatic harvesting is not active. ? ? org/dspace/core/Context } ~ oai harvester.epersonhij { |bk ?lmnopqrs java/util/Stack ? ? harvester.maxThreadstuvwx ? ?y ? harvester.minHeartbeat ? ? harvester.maxHeartbeat ? ? ? ? #org/dspace/harvest/HarvestScheduler ? ? ? ?z{| org/dspace/content/Collection}{~ ? ???? y z java/lang/StringBuilder )Collections ready for immediate harvest: ??? ????e??f???? &org/dspace/harvest/HarvestedCollection?? ? ? java/lang/Thread?? java/lang/Runnable ??? ? Thread started: ? ? Done with iteration ?? java/sql/SQLException? ?? ? java/lang/Exception Exception on iteration: ???? harvester.harvestFrequencym????? java/util/Calendar?????? java/util/Date????? ??? java/lang/InterruptedException Interrupt: ? ??? 5****** Entered the addThread method. Active threads: ????? ?? ?? ? org/dspace/harvest/HarvestThread???? ???? +****** Queued up a thread. Active threads: Thread queued up: ?? java/lang/Object?m????m??? java/lang/String 'org/dspace/authorize/AuthorizeException java/lang/Throwable java/util/List java/util/Iterator java/io/IOException $org/dspace/core/ConfigurationManager getProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; length 0org/dspace/eperson/factory/EPersonServiceFactory getInstance 4()Lorg/dspace/eperson/factory/EPersonServiceFactory; getEPersonService -()Lorg/dspace/eperson/service/EPersonService; )org/dspace/eperson/service/EPersonService findByEmail I(Lorg/dspace/core/Context;Ljava/lang/String;)Lorg/dspace/eperson/EPerson; getIntProperty '(Ljava/lang/String;Ljava/lang/String;)I java/lang/Integer valueOf (I)Ljava/lang/Integer; intValue ,org/dspace/content/service/CollectionService find L(Lorg/dspace/core/Context;Ljava/util/UUID;)Lorg/dspace/content/DSpaceObject; 5org/dspace/harvest/service/HarvestedCollectionService b(Lorg/dspace/core/Context;Lorg/dspace/content/Collection;)Lorg/dspace/harvest/HarvestedCollection; sleep (J)V findReady +(Lorg/dspace/core/Context;)Ljava/util/List; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString org/apache/log4j/Logger info (Ljava/lang/Object;)V iterator ()Ljava/util/Iterator; hasNext ()Z next ()Ljava/lang/Object; isEmpty pop (Ljava/lang/Runnable;)V start complete (J)Ljava/lang/StringBuilder; printStackTrace abort error findOldestHarvest C(Lorg/dspace/core/Context;)Lorg/dspace/harvest/HarvestedCollection; ()Ljava/util/Calendar; getHarvestDate ()Ljava/util/Date; setTime (Ljava/util/Date;)V add (II)V getTime ()J java/lang/Math min (JJ)J max wait getMessage warn debug setCurrentUser (Lorg/dspace/eperson/EPerson;)V setHarvestStatus update dispatchEvents getCollection !()Lorg/dspace/content/Collection; getID ()Ljava/util/UUID; (Ljava/util/UUID;)V push &(Ljava/lang/Object;)Ljava/lang/Object; getLogger ,(Ljava/lang/Class;)Lorg/apache/log4j/Logger; 0org/dspace/content/factory/ContentServiceFactory 4()Lorg/dspace/content/factory/ContentServiceFactory; getCollectionService 0()Lorg/dspace/content/service/CollectionService; 0org/dspace/harvest/factory/HarvestServiceFactory 4()Lorg/dspace/harvest/factory/HarvestServiceFactory; getHarvestedCollectionService 9()Lorg/dspace/harvest/service/HarvestedCollectionService; ! ' t B y z { | } ~ ? ? ? ? ? ? ? L ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? B ? ? ? ? ? P ? ? ? ? @ ) ? ? ? 3 ? ? ? T U ? ? ? ) ? ? ? E ? +? ? ? X Y Z ? ? ? ? ? ? ? ? ? ? ? ] ? ? ? ? J? ? D >