45com/hazelcast/cp/internal/session/RaftSessionRegistryjava/lang/Object:com/hazelcast/nio/serialization/IdentifiedDataSerializableRaftSessionRegistry.java5com/hazelcast/cp/session/CPSession$CPSessionOwnerType"com/hazelcast/cp/session/CPSession CPSessionOwnerTypegroupIdLcom/hazelcast/cp/CPGroupId;sessionsLjava/util/Map;RLjava/util/Map; nextSessionIdJgeneratedThreadId()V  &java/util/concurrent/ConcurrentHashMap   this7Lcom/hazelcast/cp/internal/session/RaftSessionRegistry;(Lcom/hazelcast/cp/CPGroupId;)V  !()Lcom/hazelcast/cp/CPGroupId; getSession4(J)Lcom/hazelcast/cp/internal/session/CPSessionInfo;java/lang/Long&valueOf(J)Ljava/lang/Long; () '* java/util/Map,get&(Ljava/lang/Object;)Ljava/lang/Object; ./ -0/com/hazelcast/cp/internal/session/CPSessionInfo2 sessionIdcreateNewSessioni(JLcom/hazelcast/nio/Address;Ljava/lang/String;Lcom/hazelcast/cp/session/CPSession$CPSessionOwnerType;J)J  7toExpirationTime(JJ)J 9: 3;k(JJLcom/hazelcast/nio/Address;Ljava/lang/String;Lcom/hazelcast/cp/session/CPSession$CPSessionOwnerType;JJ)V = 3>put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; @A -B sessionTTLMsendpointLcom/hazelcast/nio/Address; endpointNameLjava/lang/String; endpointType7Lcom/hazelcast/cp/session/CPSession$CPSessionOwnerType; creationTimeidexpirationTimesession1Lcom/hazelcast/cp/internal/session/CPSessionInfo; closeSession(J)Zremove R/ -S expireSession(JJ)Zversion()J WX 3YexpectedVersion heartbeat(JJ)VgetSessionOrFail ^% _ \% 3ashiftExpirationTimes(J)Vvalues()Ljava/util/Collection; ef -gjava/util/Collectioniiterator()Ljava/util/Iterator; kl jmjava/util/IteratorohasNext()Z qr psnext()Ljava/lang/Object; uv pw LX 3yshiftExpirationTime {% 3| durationMsgetSessionsToExpirec()Ljava/util/Collection;>;java/util/ArrayList com/hazelcast/util/ClockcurrentTimeMillis X java/util/List isExpired Q 3%com/hazelcast/cp/internal/util/Tuple2ofM(Ljava/lang/Object;Ljava/lang/Object;)Lcom/hazelcast/cp/internal/util/Tuple2; add(Ljava/lang/Object;)Z expired[Ljava/util/List;>;Ljava/util/List;now9com/hazelcast/cp/internal/session/SessionExpiredException  getSessions?()Ljava/util/Collection<+Lcom/hazelcast/cp/session/CPSession;>;cloneForSnapshot9()Lcom/hazelcast/cp/internal/session/RaftSessionRegistry; putAll(Ljava/util/Map;)V -  clonegenerateThreadId getFactoryId()IFcom/hazelcast/cp/internal/session/RaftSessionServiceDataSerializerHookF_IDI getId writeData'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException"com/hazelcast/nio/ObjectDataOutput writeObject(Ljava/lang/Object;)V  writeLong d size -writeInt(I)V out$Lcom/hazelcast/nio/ObjectDataOutput;readData&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInput readObject v com/hazelcast/cp/CPGroupIdreadLong X readInt iin#Lcom/hazelcast/nio/ObjectDataInput; SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Exceptions InnerClasses SourceFile  B**Y0,1  U**Y*+"3,45  #/*"8 $%E*+13<456 >*Y8 a]87<7 3Y - ?: *+ CWA BC*D;E\ >>D>EF>GH>IJ>K 1L)M *NO PQU*+T@I4UV5*+13:Z!*+TW 3 MNOR#S%V3W*5545[#NO\]l*`:*+!bCW[\]*4DNOcd?*hnN-t)-x3:*z+}CWԱ p.`#a;b>c #NO??~fZYLA*hn:t5x3: +z+Z+W+p8gh i2j;kUmXo*2#NOZR N R^%w*+13N- Y-3stuw 4NOf4 *h{  w/YL+*""+*+*88+*+%-/'X6 *Y a]  . , Z+*"+*8+**hnM,t,x3N+-+* 2p" #ELOY ENOZZU*+ӵ"*+8+=>(+3:*z+CW*+  )& %0DJT40NO *UU7  @