Merge pull request #592 from ApptiveGrid/add-fsync

Added FFI calls for fsync() and fdatasync() and connected it to writi…
ApptiveGrid · Feb 13, 2024 · 1804657 · 1804657
2 parents 8a81468 + d551e8b
commit 1804657
Show file tree

Hide file tree

Showing 6 changed files with 58 additions and 0 deletions.
diff --git a/src/Soil-Core/SoilJournalFragmentFile.class.st b/src/Soil-Core/SoilJournalFragmentFile.class.st
@@ -30,6 +30,7 @@ SoilJournalFragmentFile >> appendEntry: aSoilJournalEntry [
 	position := stream position.
 	aSoilJournalEntry writeOn: stream.
 	stream flush.
+	stream fileStream dataSync.
 	^ position
 
 ]

diff --git a/src/Soil-File/AbstractBinaryFileStream.extension.st b/src/Soil-File/AbstractBinaryFileStream.extension.st
@@ -0,0 +1,6 @@
+Extension { #name : #AbstractBinaryFileStream }
+
+{ #category : #'*Soil-File' }
+AbstractBinaryFileStream >> fileStream [
+	^ self 
+]
diff --git a/src/Soil-File/BinaryFileStream.extension.st b/src/Soil-File/BinaryFileStream.extension.st
@@ -1,11 +1,31 @@
 Extension { #name : #BinaryFileStream }
 
+{ #category : #'*Soil-File' }
+BinaryFileStream >> dataSync [ 
+	^ self dataSync: (self fileno: self fileHandle)
+]
+
+{ #category : #'*Soil-File' }
+BinaryFileStream >> dataSync: fd [
+	^ self 
+		ffiCall: #(int fdatasync(int fd))
+		module: LibC
+]
+
 { #category : #'*Soil-File' }
 BinaryFileStream >> fileHandle [
 
 	^ handle pointerAt: 9
 ]
 
+{ #category : #'*Soil-File' }
+BinaryFileStream >> fileno: stream [
+
+	^ self 
+		ffiCall: #(int fileno("FILE *"void *stream))
+		module: LibC
+]
+
 { #category : #'*Soil-File' }
 BinaryFileStream >> flockClass [
 	^ OSPlatform current flockClass
@@ -50,6 +70,19 @@ BinaryFileStream >> lockForAppendStartingAt: offset [
 		length: 0
 ]
 
+{ #category : #'*Soil-File' }
+BinaryFileStream >> sync [ 
+	^ self sync: (self fileno: self fileHandle).
+
+]
+
+{ #category : #'*Soil-File' }
+BinaryFileStream >> sync: fd [
+	^ self 
+		ffiCall: #(int fsync(int fd))
+		module: LibC
+]
+
 { #category : #'*Soil-File' }
 BinaryFileStream >> unlockAt: position length: length [
 

diff --git a/src/Soil-File/ZnBufferedReadWriteStream.extension.st b/src/Soil-File/ZnBufferedReadWriteStream.extension.st
@@ -0,0 +1,6 @@
+Extension { #name : #ZnBufferedReadWriteStream }
+
+{ #category : #'*Soil-File' }
+ZnBufferedReadWriteStream >> fileStream [
+	^ writeStream fileStream
+]
diff --git a/src/Soil-File/ZnBufferedWriteStream.extension.st b/src/Soil-File/ZnBufferedWriteStream.extension.st
@@ -0,0 +1,6 @@
+Extension { #name : #ZnBufferedWriteStream }
+
+{ #category : #'*Soil-File' }
+ZnBufferedWriteStream >> fileStream [
+	^ stream fileStream
+]
diff --git a/src/Soil-File/ZnEncodedStream.extension.st b/src/Soil-File/ZnEncodedStream.extension.st
@@ -0,0 +1,6 @@
+Extension { #name : #ZnEncodedStream }
+
+{ #category : #'*Soil-File' }
+ZnEncodedStream >> fileStream [
+	^ stream fileStream
+]