4+com/hazelcast/transaction/impl/xa/XAServicejava/lang/Object com/hazelcast/spi/ManagedServicecom/hazelcast/spi/RemoteService'com/hazelcast/spi/MigrationAwareService XAService.javajava/util/Map$Entry  java/util/MapEntry SERVICE_NAMELjava/lang/String;hz:impl:xaService nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl; xaResource2Lcom/hazelcast/transaction/impl/xa/XAResourceImpl; transactions$Ljava/util/concurrent/ConcurrentMap;Ljava/util/concurrent/ConcurrentMap;>;*(Lcom/hazelcast/spi/impl/NodeEngineImpl;)V()V  &java/util/concurrent/ConcurrentHashMap! "  $  &0com/hazelcast/transaction/impl/xa/XAResourceImpl(N(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/transaction/impl/xa/XAService;)V * )+  -this-Lcom/hazelcast/transaction/impl/xa/XAService;init7(Lcom/hazelcast/spi/NodeEngine;Ljava/util/Properties;)VLcom/hazelcast/spi/NodeEngine; propertiesLjava/util/Properties;resetshutdown(Z)V terminateZcreateDistributedObject:(Ljava/lang/String;)Lcom/hazelcast/core/DistributedObject; objectNamedestroyDistributedObject(Ljava/lang/String;)VnewXATransactionContext^(Ljavax/transaction/xa/Xid;Ljava/lang/String;IZ)Lcom/hazelcast/transaction/TransactionContext;:com/hazelcast/transaction/impl/xa/XATransactionContextImplBX(Lcom/hazelcast/spi/impl/NodeEngineImpl;Ljavax/transaction/xa/Xid;Ljava/lang/String;IZ)V D CExidLjavax/transaction/xa/Xid; ownerUuidtimeoutIoriginatedFromClientputTransaction4(Lcom/hazelcast/transaction/impl/xa/XATransaction;)V/com/hazelcast/transaction/impl/xa/XATransactionOgetXid5()Lcom/hazelcast/transaction/impl/xa/SerializableXID; QR PS"java/util/concurrent/ConcurrentMapUget&(Ljava/lang/Object;)Ljava/lang/Object; WX VYjava/util/List[)java/util/concurrent/CopyOnWriteArrayList] ^put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; `a Vb1com/hazelcast/transaction/impl/xa/SerializableXIDdadd(Ljava/lang/Object;)Z fg \h transaction1Lcom/hazelcast/transaction/impl/xa/XATransaction;3Lcom/hazelcast/transaction/impl/xa/SerializableXID;listCLjava/util/List;Ljava/util/List;removeTransactionsE(Lcom/hazelcast/transaction/impl/xa/SerializableXID;)Ljava/util/List;x(Lcom/hazelcast/transaction/impl/xa/SerializableXID;)Ljava/util/List;remove sX VtgetPreparedXids()Ljava/util/Set;F()Ljava/util/Set;keySet yw VzprepareReplicationOperationL(Lcom/hazelcast/spi/PartitionReplicationEvent;)Lcom/hazelcast/spi/Operation;+com/hazelcast/spi/PartitionReplicationEvent~getReplicaIndex()I java/util/ArrayList %com/hazelcast/spi/impl/NodeEngineImplgetPartitionService=()Lcom/hazelcast/internal/partition/InternalPartitionService; entrySet w V java/util/Setiterator()Ljava/util/Iterator; 9com/hazelcast/internal/partition/InternalPartitionServicejava/util/IteratorhasNext()Z next()Ljava/lang/Object; getKey getPartitionId(Ljava/lang/Object;)I getValue \ 2com/hazelcast/transaction/impl/xa/XATransactionDTO N isEmpty \Ccom/hazelcast/transaction/impl/xa/operations/XaReplicationOperation(Ljava/util/List;II)V   xaTransaction partitionIdxaTransactionListentryLjava/util/Map$Entry;>;Ljava/util/Map$Entry;event-Lcom/hazelcast/spi/PartitionReplicationEvent; migrationDataFLjava/util/List;partitionService;Lcom/hazelcast/internal/partition/InternalPartitionService;beforeMigration.(Lcom/hazelcast/spi/PartitionMigrationEvent;)V+Lcom/hazelcast/spi/PartitionMigrationEvent;commitMigration)com/hazelcast/spi/PartitionMigrationEventgetMigrationEndpoint1()Lcom/hazelcast/spi/partition/MigrationEndpoint; -com/hazelcast/spi/partition/MigrationEndpointSOURCE/Lcom/hazelcast/spi/partition/MigrationEndpoint; getNewReplicaIndex clearPartitionReplica(I)V thresholdReplicaIndexrollbackMigration DESTINATION getCurrentReplicaIndex s xidPartitionIdLjava/util/Iterator;>;>;Ljava/util/Iterator; ConstantValue SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable InnerClasses SourceFile! f"* *"Y#%*+'*)Y+*,.;8<=!>"/0"12?B /03456+F /0785J/09:;<9*.N/0=>?5S/0=@AcCY*'+,FV4/0GHIJKL:MN4+TM*%,Z\N-^Y_N*%,-cW-+iW +e\Z[\]^+`3a*4/04jk/Gl!mo !mnpqB*%+u\d/0Glrvw4 *%{h  /0x|} +YM*'N*%:o :e:-6\::  + P: +,Y iWѧ,Y,++M \@ \ e\.\ Bop stu@vLwVxbyz{}~\ k LQGlVGKb;o@]/0o b;n@]5/0"+в֦+= *+ڷޱ  ! K"/0""+в+= *+ڷޱ  ! K"/0" Q*'M*%N-3- :e:,6 -ʱ 5*  +7AGMPH+"7GlA KQ/0QKI:+":