44com/hazelcast/internal/partition/impl/MigrationQueuejava/lang/ObjectMigrationQueue.javamigrateTaskCount+Ljava/util/concurrent/atomic/AtomicInteger;queue$Ljava/util/concurrent/BlockingQueue;_Ljava/util/concurrent/BlockingQueue;()V  )java/util/concurrent/atomic/AtomicInteger   (java/util/concurrent/LinkedBlockingQueue   this6Lcom/hazelcast/internal/partition/impl/MigrationQueue;add<(Lcom/hazelcast/internal/partition/impl/MigrationRunnable;)V4Ledu/umd/cs/findbugs/annotations/SuppressFBWarnings;valueRV_RETURN_VALUE_IGNORED justification8offer will always be successful since queue is unboundedincrementAndGet()I "# $"java/util/concurrent/BlockingQueue&offer(Ljava/lang/Object;)Z () '*task9Lcom/hazelcast/internal/partition/impl/MigrationRunnable;poll[(ILjava/util/concurrent/TimeUnit;)Lcom/hazelcast/internal/partition/impl/MigrationRunnable;java/lang/InterruptedException04(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; .2 '37com/hazelcast/internal/partition/impl/MigrationRunnable5timeoutIunitLjava/util/concurrent/TimeUnit;clearjava/util/ArrayList< = drainTo(Ljava/util/Collection;)I ?@ 'Ajava/util/ListCiterator()Ljava/util/Iterator; EF DGjava/util/IteratorIhasNext()Z KL JMnext()Ljava/lang/Object; OP JQafterTaskCompletion S TsinkKLjava/util/List;Ljava/util/List;decrementAndGet Y# Zjava/lang/IllegalStateException\ ] migrationTaskCountget `# ahasMigrationTaskstoString()Ljava/lang/String;java/lang/StringBuilderf g  MigrationQueue{migrateTaskCount=iappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; kl gm-(Ljava/lang/Object;)Ljava/lang/StringBuilder; ko gp, queue=r(C)Ljava/lang/StringBuilder; kt gu de gw SignatureCodeLineNumberTableLocalVariableTableRuntimeInvisibleAnnotations Exceptions StackMapTableLocalVariableTypeTable SourceFile  y  zM**Y*Y{!#%| zP*%W*++W{*+,|,-}[s s!./zN*,46{0| 789:~1; z6=Y>L*+BW+HM,N,R6N*-UDJ{457-8295:| -,-6.VX .VWSzX*[ ]Y^{B CE|,-_#z2*b{H| cLzE*b@{L| dezR(gYhjn*qsn*q}vx{Q| (