4CPcom/hazelcast/collection/impl/txncollection/AbstractTransactionalCollectionProxyqLcom/hazelcast/spi/TransactionalDistributedObject;0com/hazelcast/spi/TransactionalDistributedObject)AbstractTransactionalCollectionProxy.java0com/hazelcast/transaction/impl/Transaction$State*com/hazelcast/transaction/impl/Transaction State itemIdSetLjava/util/Set;!Ljava/util/Set;nameLjava/lang/String; partitionIdIoperationService$Lcom/hazelcast/spi/OperationService;(Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/spi/RemoteService;)Vb(Ljava/lang/String;Lcom/hazelcast/transaction/impl/Transaction;Lcom/hazelcast/spi/NodeEngine;TS;)Vn(Lcom/hazelcast/spi/NodeEngine;Lcom/hazelcast/spi/RemoteService;Lcom/hazelcast/transaction/impl/Transaction;)V  java/util/HashSet()V     "com/hazelcast/spi/NodeEngine$getPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; &' %(getNameAsPartitionAwareData(()Lcom/hazelcast/nio/serialization/Data; *+ ,-com/hazelcast/spi/partition/IPartitionService.getPartitionId)(Lcom/hazelcast/nio/serialization/Data;)I 01 /2  4getOperationService&()Lcom/hazelcast/spi/OperationService; 67 %8  :thisZLcom/hazelcast/collection/impl/txncollection/AbstractTransactionalCollectionProxy;RLcom/hazelcast/collection/impl/txncollection/AbstractTransactionalCollectionProxy;tx,Lcom/hazelcast/transaction/impl/Transaction; nodeEngineLcom/hazelcast/spi/NodeEngine;serviceTS;!Lcom/hazelcast/spi/RemoteService; getCollection()Ljava/util/Collection;S()Ljava/util/Collection;getName()Ljava/lang/String;add(Ljava/lang/Object;)Z(TE;)Zjava/lang/ThrowableNcheckTransactionActive P QcheckObjectNotNull(Ljava/lang/Object;)V ST U getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; WX YtoData:(Ljava/lang/Object;)Lcom/hazelcast/nio/serialization/Data; [\ %]Tcom/hazelcast/collection/impl/txncollection/operations/CollectionReserveAddOperation_ ?@ agetTxnId cJ dM(Ljava/lang/String;Ljava/lang/String;Lcom/hazelcast/nio/serialization/Data;)V f `ggetServiceName iJ j"com/hazelcast/spi/OperationServicelinvokeOnPartition_(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InternalCompletableFuture; no mpjava/util/concurrent/Futurerget()Ljava/lang/Object; tu svjava/lang/Longx java/util/Setz KL {|.com/hazelcast/transaction/TransactionException~java/lang/StringBuilder Duplicate itemId: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString J (Ljava/lang/String;)V  java/lang/Object$com/hazelcast/nio/serialization/Data FG 7com/hazelcast/collection/impl/collection/CollectionItem longValue()J y*(JLcom/hazelcast/nio/serialization/Data;)V  java/util/Collection |Pcom/hazelcast/collection/impl/txncollection/operations/CollectionTxnAddOperation<(Ljava/lang/String;JLcom/hazelcast/nio/serialization/Data;)V   putToRecordG(Lcom/hazelcast/collection/impl/txncollection/CollectionTxnOperation;)V  com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; opRLcom/hazelcast/collection/impl/txncollection/operations/CollectionTxnAddOperation;future/Ljava/util/concurrent/Future;Ljava/util/concurrent/Future;itemIdLjava/lang/Long;tLjava/lang/Throwable;eTE;Ljava/lang/Object;value&Lcom/hazelcast/nio/serialization/Data; operationVLcom/hazelcast/collection/impl/txncollection/operations/CollectionReserveAddOperation;I(Ljava/lang/Object;)Lcom/hazelcast/transaction/impl/TransactionLogRecord; t Jcom/hazelcast/collection/impl/txncollection/CollectionTransactionLogRecord:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;I)V  8(Lcom/hazelcast/transaction/impl/TransactionLogRecord;)V K  addOperation DLcom/hazelcast/collection/impl/txncollection/CollectionTxnOperation; logRecordLLcom/hazelcast/collection/impl/txncollection/CollectionTransactionLogRecord;removeFromRecord(J)VremoveOperation(J)I remove T Jsizeiterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next u getValue + equals L  getItemId Wcom/hazelcast/collection/impl/txncollection/operations/CollectionReserveRemoveOperationN(Ljava/lang/String;JLcom/hazelcast/nio/serialization/Data;Ljava/lang/String;)V   valueOf(J)Ljava/lang/Long;  y L {(J)Ljava/lang/StringBuilder;  Scom/hazelcast/collection/impl/txncollection/operations/CollectionTxnRemoveOperation (Ljava/lang/String;J)V    item9Lcom/hazelcast/collection/impl/collection/CollectionItem;ULcom/hazelcast/collection/impl/txncollection/operations/CollectionTxnRemoveOperation;XLjava/util/concurrent/Future;OLjava/util/Iterator;Ljava/util/Iterator;reservedItemIdYLcom/hazelcast/collection/impl/txncollection/operations/CollectionReserveRemoveOperation;()IKcom/hazelcast/collection/impl/collection/operations/CollectionSizeOperation java/lang/IntegerintValue    MLcom/hazelcast/collection/impl/collection/operations/CollectionSizeOperation;2Ljava/util/concurrent/Future;Ljava/lang/Integer;getState4()Lcom/hazelcast/transaction/impl/Transaction$State; $% &ACTIVE2Lcom/hazelcast/transaction/impl/Transaction$State; () * 7com/hazelcast/transaction/TransactionNotActiveException-Transaction is not active!/ .Object is null2 com/hazelcast/util/Preconditions4 checkNotNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; 67 58o SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable InnerClasses SourceFile! ; <6*-,*Y!*+#*-)*-35*-9;=5/67+859>46<>66?@6AB6CE?6<=6CD;FG;HIJ<A*#=?> <>? <=KL<*R*+V*Z+^M`Y*#*behN*;*k-*5q:wy:_*!}YY*Y,WY*#,:* :*O@#y`sy1BO=FCD FG*I>JJKOL]MyOPQRVTUW>R>mJa<>*? >m<=;M<B*b*#M,*Y*k*be*#*5M*b,,+б@<=[\]2^<`Aa> B<>B1? B<=<+*b*#N-6*b*#@ *=defg*i>*+<>+? +<=L<| *R*+V*Z+^M*N7-'-:, 7ֻY*#,*be:*;*k*5q:w:x -**!W*!}"YY Y*# : *  :iOO@##)fs2BO=zlm opq#r,s7tCuJvMxPy_zi|~}~ >p 7 ~z <>#i?*~<=;M<B*RY*#L*;*k+*5qM,wN-* `L+;<O@|O=#-<=>4,!#-#=B<>?#"B<=P<k*b'+,.Y01@=> <>? <=ST<S +39W= > <> :?  <=A  @;B