From e95d252cdeab518410d140886559a6f73a27e005 Mon Sep 17 00:00:00 2001
From: Gawaboumga <yourihubaut@hotmail.com>
Date: Thu, 15 Jun 2017 18:03:19 +0200
Subject: [PATCH] Add lock file on Linux and the possibility to have two
 processes writing to the same one

---
 src/Nazara/Core/Posix/FileImpl.cpp | 48 +++++++++++++++++++++++++-----
 1 file changed, 41 insertions(+), 7 deletions(-)

diff --git a/src/Nazara/Core/Posix/FileImpl.cpp b/src/Nazara/Core/Posix/FileImpl.cpp
index 5603ed79b..75b2275cc 100644
--- a/src/Nazara/Core/Posix/FileImpl.cpp
+++ b/src/Nazara/Core/Posix/FileImpl.cpp
@@ -5,6 +5,7 @@
 #include <Nazara/Core/Posix/FileImpl.hpp>
 #include <Nazara/Core/Error.hpp>
 #include <cstdio>
+#include <sys/file.h>
 #include <Nazara/Core/Debug.hpp>
 
 namespace Nz
@@ -72,11 +73,47 @@ namespace Nz
 		if (mode & OpenMode_Truncate)
 			flags |= O_TRUNC;
 
-		///TODO: lock
-		//if ((mode & OpenMode_Lock) == 0)
-		//	shareMode |= FILE_SHARE_WRITE;
-
 		m_fileDescriptor = open64(filePath.GetConstBuffer(), flags, permissions);
+
+		static struct flock lock;
+
+		auto initialize_flock = [](struct flock& fileLock)
+		{
+			fileLock.l_type = F_WRLCK;
+			fileLock.l_start = 0;
+			fileLock.l_whence = SEEK_SET;
+			fileLock.l_len = 0;
+			fileLock.l_pid = getpid();
+		};
+
+		initialize_flock(lock);
+
+		if (fcntl(m_fileDescriptor, F_GETLK, &lock) == -1)
+		{
+			Close();
+			NazaraError("Unable to detect presence of lock on the file");
+			return false;
+		}
+
+		if (lock.l_type != F_UNLCK)
+		{
+			Close();
+			NazaraError("A lock is present on the file");
+			return false;
+		}
+
+		if (mode & OpenMode_Lock)
+		{
+			initialize_flock(lock);
+
+			if (fcntl(m_fileDescriptor, F_SETLK, &lock) == -1)  
+			{
+				Close();
+				NazaraError("Unable to place a lock on the file");
+				return false;
+			}
+		}
+
 		return m_fileDescriptor != -1;
 	}
 
@@ -128,10 +165,7 @@ namespace Nz
 
 	std::size_t FileImpl::Write(const void* buffer, std::size_t size)
 	{
-		lockf64(m_fileDescriptor, F_LOCK, size);
 		ssize_t written = write(m_fileDescriptor, buffer, size);
-		lockf64(m_fileDescriptor, F_ULOCK, size);
-
 		m_endOfFileUpdated = false;
 
 		return written;