|
Change Variable Type conn0 : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> to conn0 : ObjectPoolReusable<H2ConnectionWrapper> in method protected onClose() : void in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Variable Type o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type c : H2ConnectionWrapper to perThreadConns : ConcurrentMap<H2ConnectionWrapper,Boolean> in method public stop() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Thread,H2ConnectionWrapper>> to it : Iterator<Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>>> in method private cleanupStatementCache() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type conn : Connection to conn : H2ConnectionWrapper in method private onSqlException() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type entry : Map.Entry<Thread,H2ConnectionWrapper> to entry : Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> in method private cleanupStatementCache() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type pooled : Reusable<E> to pooled : E in method public borrow() : ObjectPoolReusable<E> in class org.apache.ignite.internal.processors.query.h2.ObjectPool |
From |
To |
|
Change Variable Type o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldReturnedToBag() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type c : H2ConnectionWrapper to perThreadConns : ConcurrentHashMap<H2ConnectionWrapper,Boolean> in method public cancelAllQueries() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectIsReusedAfterRecycling() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type w : H2ConnectionWrapper to connPerThread : ConcurrentMap<H2ConnectionWrapper,Boolean> in method private getStatementCacheSize(qryProcessor GridQueryProcessor) : int in class org.apache.ignite.internal.processors.cache.IgniteCacheQueryH2IndexingLeakTest |
From |
To |
|
Change Variable Type o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Variable Type conn0 : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> to conn0 : ObjectPoolReusable<H2ConnectionWrapper> in method public beforeDetach() : void in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Variable Type nodesStartedLatch : CountDownLatch to allNodesReady : IgniteCountDownLatch in method private waitForNodes() : void in class org.apache.ignite.yardstick.IgniteAbstractBenchmark |
From |
To |
|
Change Variable Type conns : ConcurrentMap<Thread,H2ConnectionWrapper> to conns : ConcurrentMap<Thread,ConcurrentMap<H2ConnectionWrapper,Boolean>> in method private getStatementCacheSize(qryProcessor GridQueryProcessor) : int in class org.apache.ignite.internal.processors.cache.IgniteCacheQueryH2IndexingLeakTest |
From |
To |
|
Change Variable Type entry : Map.Entry<Thread,H2ConnectionWrapper> to entry : Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> in method private cleanupConnections() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Thread,H2ConnectionWrapper>> to it : Iterator<Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>>> in method private cleanupConnections() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Inline Method public stopAndUnregisterCurrentLazyWorker() : void inlined to private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Rename Variable o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable c : H2ConnectionWrapper to perThreadConns : ConcurrentMap<H2ConnectionWrapper,Boolean> in method public stop() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Rename Variable o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldReturnedToBag() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable c : H2ConnectionWrapper to perThreadConns : ConcurrentHashMap<H2ConnectionWrapper,Boolean> in method public cancelAllQueries() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Rename Variable o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable qr : MapQueryResults to qryResults : MapQueryResults in method private onNextPageRequest(node ClusterNode, req GridQueryNextPageRequest) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Rename Variable o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectIsReusedAfterRecycling() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable w : H2ConnectionWrapper to connPerThread : ConcurrentMap<H2ConnectionWrapper,Boolean> in method private getStatementCacheSize(qryProcessor GridQueryProcessor) : int in class org.apache.ignite.internal.processors.cache.IgniteCacheQueryH2IndexingLeakTest |
From |
To |
|
Rename Variable o2 : Reusable<Obj> to r2 : ObjectPoolReusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable nodesStartedLatch : CountDownLatch to allNodesReady : IgniteCountDownLatch in method private waitForNodes() : void in class org.apache.ignite.yardstick.IgniteAbstractBenchmark |
From |
To |
|
Rename Variable pRes : List<List<?>> to goldenRes : List<List<?>> in method private restarts(broadcastQry boolean) : void in class org.apache.ignite.internal.processors.cache.distributed.near.IgniteCacheQueryNodeRestartDistributedJoinSelfTest |
From |
To |
|
Rename Variable o1 : Reusable<Obj> to r1 : ObjectPoolReusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Rename Variable qr : MapQueryResults to qryResults : MapQueryResults in method private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Change Attribute Type connectionPool : ThreadLocalObjectPool<H2ConnectionWrapper> to connectionPool : ThreadLocal<ObjectPool<H2ConnectionWrapper>> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Attribute Type pool : ThreadLocalObjectPool<Obj> to pool : ObjectPool<Obj> in class org.apache.ignite.internal.processors.query.h2.ObjectPoolSelfTest |
From |
To |
|
Change Attribute Type pool : ThreadLocalObjectPool<T> to pool : ObjectPool<T> in class org.apache.ignite.internal.processors.query.h2.ObjectPoolReusable |
From |
To |
|
Change Attribute Type res : MapQueryResult to detached : ObjectPoolReusable<H2ConnectionWrapper> in class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryLazyWorker |
From |
To |
|
Change Attribute Type conn : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> to conn : ObjectPoolReusable<H2ConnectionWrapper> in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Attribute Type bag : ThreadLocal<Queue<Reusable<E>>> to bag : ConcurrentLinkedQueue<E> in class org.apache.ignite.internal.processors.query.h2.ObjectPool |
From |
To |
|
Change Attribute Type connCache : ThreadLocal<ThreadLocalObjectPool.Reusable<H2ConnectionWrapper>> to connCache : ThreadLocal<ObjectPoolReusable<H2ConnectionWrapper>> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Attribute Type conns : ConcurrentMap<Thread,H2ConnectionWrapper> to conns : ConcurrentMap<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Extract And Move Method package recycle(object E) : void extracted from public recycle() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPool.Reusable & moved to class org.apache.ignite.internal.processors.query.h2.ObjectPool |
From |
To |
|
Extract And Move Method public queryContext(qctx GridH2QueryContext) : void extracted from private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor & moved to class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryLazyWorker |
From |
To |
|
Extract And Move Method package start(ses Session, detached ObjectPoolReusable<H2ConnectionWrapper>) : void extracted from private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor & moved to class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryLazyWorker |
From |
To |