--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ganeswidgets/tsrc/fute/HgWidgetTest/src/buffermanager.cpp	Mon May 03 13:32:54 2010 +0300
@@ -0,0 +1,244 @@
+/*
+* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:     
+*
+*/
+#include "buffermanager.h"
+#include <qglobal.h>
+
+BufferManager::BufferManager(
+    AbstractDataProvider* aObserver,
+	int aBufferSize,
+	int aBufferTreshold,
+	int aInitialPosition,
+	int aTotalCount )
+:
+mObserver(aObserver),
+mBufferSize( aBufferSize ),
+mBufferTreshold( aBufferTreshold ),
+mBufferPosition( aInitialPosition ),
+mTotalCount( aTotalCount )
+{
+    mBufferPosition -= (mBufferSize / 2);
+    
+    if( mBufferPosition + mBufferSize > mTotalCount - 1 ){
+        mBufferPosition = (mTotalCount - 1) - mBufferSize;
+    }
+    
+    if(mBufferPosition < 0 ){
+        mBufferPosition = 0;
+    }
+    
+    mDiff = 0;
+	//request Initial Buffer
+	mRequestStart = mBufferPosition;
+	mRequestCount = mBufferSize;
+
+	calculate();
+}
+
+
+BufferManager::~BufferManager()
+{
+}
+
+void BufferManager::resizeCache(int newSize, int newTreshold)
+{
+    if (newTreshold != mBufferTreshold){
+        mBufferTreshold = newTreshold;
+    }
+    
+    if (newSize!=mBufferSize){
+//        int pos = mBufferPosition + (mBufferSize / 2);
+
+        int a = qMax(0, mBufferPosition + mBufferSize/2 - newSize/2);
+        int b = qMin(a + newSize, mTotalCount);
+        if ( b == mTotalCount){
+            a = mTotalCount - newSize;
+        }
+        
+        int c = qMax(0, mBufferPosition);
+        int d = qMin(c + mBufferSize, mTotalCount);
+        if ( d == mTotalCount){
+            c = mTotalCount - mBufferSize;
+        }
+        
+        if ( newSize>mBufferSize){
+            mObserver->request(a, c-1, AbstractDataProvider::ascending);
+            mObserver->request(d, b-1, AbstractDataProvider::ascending);
+        }else if ( newSize<mBufferSize){
+            mObserver->release(c, a-1);
+            mObserver->release(b, d);
+        }
+        mBufferPosition = a;
+        mBufferSize = newSize;
+    }
+}
+
+void BufferManager::calculate()
+{  
+    AbstractDataProvider::requestsOrder direction = AbstractDataProvider::ascending;
+    
+    if(mResetOrdered){
+        mResetOrdered = false;
+    } else {
+        if(mDiff < 0){
+            mReleaseStart = mBufferPosition;
+            mRequestStart = mBufferPosition + mBufferSize;
+            direction = AbstractDataProvider::ascending; 
+        } else if( mDiff > 0) {
+            mReleaseStart = mBufferPosition + mBufferSize - mDiff;
+            mRequestStart = mBufferPosition - mDiff;
+            direction = AbstractDataProvider::descending;
+        }
+    }
+    
+    // Release 
+    int end = mReleaseStart + mReleaseCount < mTotalCount ?
+        mReleaseStart + mReleaseCount: mTotalCount; 
+    end--;
+    if(end >= mReleaseStart ){
+        mObserver->release(mReleaseStart, end);
+    }
+    
+    mReleaseCount = 0;
+    
+    // Request
+    end = mRequestStart + mRequestCount < mTotalCount ? 
+        mRequestStart + mRequestCount : mTotalCount;
+    
+    end--;
+    if(end >= mRequestStart ){
+        mObserver->request(mRequestStart, end, direction);
+	}
+      
+    mRequestCount = 0;
+    
+    // Move Buffer
+    mBufferPosition -= mDiff;
+    // Reset Diff
+    mDiff = 0;
+}
+
+// -----------------------------------------------------------------------------
+// BufferManager::SetPosition()
+// -----------------------------------------------------------------------------
+//
+void BufferManager::setPosition( int aIndex )
+{
+    // If all the items fit in the buffer no need to move the buffer
+    if(mTotalCount <= mBufferSize) return;
+	
+	bool forceUpdate = false;
+    aIndex -= mBufferSize / 2; // normalize index to Buffer start
+    
+    if(aIndex < 0){
+        aIndex = 0;
+        forceUpdate = true;
+    }else if( aIndex > mTotalCount - mBufferSize ){
+        aIndex = mTotalCount - mBufferSize;
+        forceUpdate = true;
+    }
+
+    mDiff = mBufferPosition - aIndex; 
+
+    // Too large change reset whole buffer
+    if( mDiff >= mBufferSize || -mDiff >= mBufferSize || mResetOrdered ) {
+        resetBuffer(aIndex + (mBufferSize/2), mTotalCount);
+    } else if( mDiff >= mBufferTreshold ) { // Move Up
+        mRequestCount = mDiff;
+        mReleaseCount = mDiff;
+        calculate();
+    } else if ( -mDiff >= mBufferTreshold ) {// Move Down
+        mRequestCount = -mDiff;
+        mReleaseCount = -mDiff;
+        calculate();
+    } else if( forceUpdate && mDiff ) { // Top or bottom has been reached
+        int diff = mDiff < 0 ? -mDiff : mDiff;
+        mRequestCount = diff;
+        mReleaseCount = diff;
+        calculate();
+    }
+}
+
+// -----------------------------------------------------------------------------
+// BufferManager::ResetBuffer()
+// -----------------------------------------------------------------------------
+//
+void BufferManager::resetBuffer( int aPosition, int aTotalCount)
+{
+    if( !mResetOrdered ){
+        // release Old buffer
+        mReleaseStart = mBufferPosition;
+        mReleaseCount = mBufferSize;
+    }
+    
+    // set position and count
+    mBufferPosition = aPosition - (mBufferSize / 2);
+    mTotalCount = aTotalCount;
+    mDiff = 0;
+    
+    if( mBufferPosition + mBufferSize > mTotalCount - 1 ){
+        mBufferPosition = mTotalCount - mBufferSize;
+    }
+    
+    if(mBufferPosition < 0 ){
+        mBufferPosition = 0;
+    }
+    
+    //request new Buffer
+    mRequestStart = mBufferPosition;
+    mRequestCount = mBufferSize;
+    mResetOrdered = true;
+    calculate();
+}
+
+void BufferManager::itemCountChanged( int aIndex, 
+                                      bool aRemoved,
+                                      int aNewTotalCount )
+{
+    mTotalCount = aNewTotalCount;
+    AbstractDataProvider::requestsOrder direction = AbstractDataProvider::ascending;    
+    if ( aIndex >= mBufferPosition && aIndex < mBufferPosition + mBufferSize ){
+        // Change inside the buffer
+        if( aRemoved ){
+            // Release removed item ( Item deleted already from the owner )
+			mObserver->release( aIndex, aIndex );
+            if( mTotalCount >= mBufferSize ){
+                // There are more items to keep the buffer filled
+                if( mBufferPosition + mBufferSize <= mTotalCount ){
+                    // Requested from the end
+					mObserver->request( mBufferPosition + mBufferSize, 
+                                        mBufferPosition + mBufferSize,
+                                        direction );
+                }else if( mBufferPosition > 0 ){
+                    // Move buffer and request from the beginning 
+                    mBufferPosition--;
+                    mObserver->request( mBufferPosition, mBufferPosition, direction);
+                }
+            }
+        }else{
+            if( mTotalCount > mBufferSize ){
+                // One item needs to be released
+                if( mBufferPosition + mBufferSize < mTotalCount ){
+                    // Release from the end of the buffer
+					mObserver->release(mBufferPosition + mBufferSize, mBufferPosition + mBufferSize);
+                }
+            }
+            // Request added item
+            mObserver->request(aIndex, aIndex, direction);
+        }
+    }
+}
+