Merge pull request #885 from ApptiveGrid/add-size-for-cluster

add size calculation for records.

Author: noha

src/Soil-Core/Object.extension.st

@@ -35,6 +35,11 @@ Object >> soilEmit [
 	self asSoilSignal emit
 ]
 
+{ #category : #'*Soil-Core' }
+Object >> soilSizeInMemory [ 
+	^ self sizeInMemory 
+]
+
 { #category : #'*Soil-Core' }
 Object >> theNonSoilProxy [
 	^ self 

src/Soil-Core/SoilObjectId.class.st

@@ -176,6 +176,14 @@ SoilObjectId >> setIndex: anInteger [
 	index := anInteger 
 ]
 
+{ #category : #comparing }
+SoilObjectId >> soilSizeInMemory [
+	^ self sizeInMemory 
+		+ segment sizeInMemory 
+		+ index sizeInMemory 
+
+]
+
 { #category : #writing }
 SoilObjectId >> writeOn: aStream [ 
 	"for now fix the segment id to be the 16 upper bits and the index 

src/Soil-Core/SoilObjectRepository.class.st

@@ -81,6 +81,23 @@ SoilObjectRepository >> cacheSegmentAt: index upTo: limit [
 				put: ((segments at: index) asCachedSegment weight: limit) ]
 ]
 
+{ #category : #setting }
+SoilObjectRepository >> cacheSegmentAt: index using: aBlock [ 
+	| segment |
+	"exchange object segment with a LRU cached segment. The LRU cache
+	can be setup within aBlock"
+	(index = 0) 
+		ifTrue: [ 
+			metaSegment := metaSegment asCachedSegment.
+			aBlock value: metaSegment ]
+		ifFalse: [ 
+			segment := (segments at: index) asCachedSegment.
+			aBlock value: segment.
+			segments 	
+				at: index 
+				put: segment ]
+]
+
 { #category : #'opening/closing' }
 SoilObjectRepository >> close [
 	metaSegment close.

src/Soil-Core/SoilPersistentClusterVersion.class.st

@@ -119,3 +119,18 @@ SoilPersistentClusterVersion >> readFrom: stream [
 SoilPersistentClusterVersion >> shouldBeCommitted [ 
 	^ changed and: [ committed not ]
 ]
+
+{ #category : #comparing }
+SoilPersistentClusterVersion >> soilSizeInMemory [
+	^ self sizeInMemory 
+		+ objectId soilSizeInMemory 
+		+ (references sum: #soilSizeInMemory) 
+		+ bytes sizeInMemory 
+		+ committed sizeInMemory 
+		+ previousVersionPosition sizeInMemory 
+		+ version sizeInMemory 
+		+ (behaviorDescriptions sum: #soilSizeInMemory) 
+		+ (indexIds sum: #sizeInMemory) 
+		+ position sizeInMemory
+		+ changed sizeInMemory 
+]

src/Soil-Core/SoilSetup.class.st

@@ -19,6 +19,14 @@ SoilSetup >> cacheObjectRecords: anInteger [
 		soil objectRepository cacheSegmentAt: n upTo: anInteger ]
 ]
 
+{ #category : #caching }
+SoilSetup >> cacheObjectRecordsUsing: aBlock [
+	1 to: soil objectRepository segments size do: [:n |
+		soil objectRepository 
+			cacheSegmentAt: n 
+			using: aBlock  ]
+]
+
 { #category : #caching }
 SoilSetup >> cacheRecords [
 	self cacheRecords: self defaultCacheRecordsSize
@@ -31,6 +39,23 @@ SoilSetup >> cacheRecords: anInteger [
 		cacheObjectRecords: anInteger
 ]
 
+{ #category : #caching }
+SoilSetup >> cacheSegmentAt: index maximumBytes: anInteger [
+	self 
+		cacheSegmentAt: index 
+		using: [ :cache | 
+			cache 
+				computeWeight: #soilSizeInMemory;
+				maximumWeight: anInteger ]
+]
+
+{ #category : #caching }
+SoilSetup >> cacheSegmentAt: index using: aBlock [
+	soil objectRepository 
+		cacheSegmentAt: index
+		using: aBlock
+]
+
 { #category : #accessing }
 SoilSetup >> defaultCacheRecordsSize [
 	^ 1000