From dd76b9e72b21d2502a51e3605e5e6ab640e5f0bd Mon Sep 17 00:00:00 2001
From: Sebastian Thiel <byronimo@gmail.com>
Date: Tue, 20 Oct 2009 10:45:40 +0200
Subject: Fixed bare repository handling - bare is now a property to prevent
 writing it

---
 test/git/test_utils.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'test/git/test_utils.py')

diff --git a/test/git/test_utils.py b/test/git/test_utils.py
index 2983a14a..6852d0ad 100644
--- a/test/git/test_utils.py
+++ b/test/git/test_utils.py
@@ -7,6 +7,7 @@
 import os
 from test.testlib import *
 from git import *
+from git.cmd import dashify
 
 class TestUtils(object):
 	def setup(self):
-- 
cgit v1.2.1


From 36f838e7977e62284d2928f65cacf29771f1952f Mon Sep 17 00:00:00 2001
From: Sebastian Thiel <byronimo@gmail.com>
Date: Thu, 22 Oct 2009 19:05:00 +0200
Subject: utils: Added LockFile including test GitConfigFile is now derived
 from LockFile using its capabilities Implemented ConcurrentWriteOperation,
 test is yet to be done

---
 test/git/test_utils.py | 37 ++++++++++++++++++++++++++++++++++++-
 1 file changed, 36 insertions(+), 1 deletion(-)

(limited to 'test/git/test_utils.py')

diff --git a/test/git/test_utils.py b/test/git/test_utils.py
index 6852d0ad..61527758 100644
--- a/test/git/test_utils.py
+++ b/test/git/test_utils.py
@@ -5,11 +5,15 @@
 # the BSD License: http://www.opensource.org/licenses/bsd-license.php
 
 import os
+import tempfile
+
 from test.testlib import *
+from git.utils import *
 from git import *
 from git.cmd import dashify
 
-class TestUtils(object):
+
+class TestUtils(TestCase):
 	def setup(self):
 		self.testdict = {
 			"string":	"42",
@@ -20,3 +24,34 @@ class TestUtils(object):
 	def test_it_should_dashify(self):
 		assert_equal('this-is-my-argument', dashify('this_is_my_argument'))
 		assert_equal('foo', dashify('foo'))
+		
+		
+	def test_lock_file(self):
+		my_file = tempfile.mktemp()
+		lock_file = LockFile(my_file)
+		assert not lock_file._has_lock()
+		# release lock we don't have  - fine
+		lock_file._release_lock()
+		
+		# get lock
+		lock_file._obtain_lock_or_raise()
+		assert lock_file._has_lock()
+		
+		# concurrent access
+		other_lock_file = LockFile(my_file)
+		assert not other_lock_file._has_lock()
+		self.failUnlessRaises(IOError, other_lock_file._obtain_lock_or_raise)
+		
+		lock_file._release_lock()
+		assert not lock_file._has_lock()
+		
+		other_lock_file._obtain_lock_or_raise()
+		self.failUnlessRaises(IOError, lock_file._obtain_lock_or_raise)
+		
+		# auto-release on destruction
+		del(other_lock_file)
+		lock_file._obtain_lock_or_raise()
+		lock_file._release_lock()
+		
+	def test_safe_operation(self):
+		self.fail("todo")
-- 
cgit v1.2.1


From 7184340f9d826a52b9e72fce8a30b21a7c73d5be Mon Sep 17 00:00:00 2001
From: Sebastian Thiel <byronimo@gmail.com>
Date: Thu, 22 Oct 2009 19:23:21 +0200
Subject: Added test for ConcurrentWriteOperation

---
 test/git/test_utils.py | 51 +++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 50 insertions(+), 1 deletion(-)

(limited to 'test/git/test_utils.py')

diff --git a/test/git/test_utils.py b/test/git/test_utils.py
index 61527758..029d2054 100644
--- a/test/git/test_utils.py
+++ b/test/git/test_utils.py
@@ -53,5 +53,54 @@ class TestUtils(TestCase):
 		lock_file._obtain_lock_or_raise()
 		lock_file._release_lock()
 		
+	def _cmp_contents(self, file_path, data):
+		# raise if data from file at file_path 
+		# does not match data string
+		fp = open(file_path, "r")
+		try:
+			assert fp.read() == data
+		finally:
+			fp.close()
+		
 	def test_safe_operation(self):
-		self.fail("todo")
+		my_file = tempfile.mktemp()
+		orig_data = "hello"
+		new_data = "world"
+		my_file_fp = open(my_file, "w")
+		my_file_fp.write(orig_data)
+		my_file_fp.close()
+		
+		try:
+			cwrite = ConcurrentWriteOperation(my_file)
+			
+			# didn't start writing, doesnt matter
+			cwrite._end_writing(False)
+			cwrite._end_writing(True)
+			assert not cwrite._is_writing()
+			
+			# write data and fail
+			stream = cwrite._begin_writing()
+			assert cwrite._is_writing()
+			stream.write(new_data)
+			cwrite._end_writing(successful=False)
+			self._cmp_contents(my_file, orig_data)
+			assert not os.path.exists(stream.name)
+			
+			# write data - concurrently
+			ocwrite = ConcurrentWriteOperation(my_file)
+			stream = cwrite._begin_writing()
+			self.failUnlessRaises(IOError, ocwrite._begin_writing)
+			
+			stream.write("world")
+			cwrite._end_writing(successful=True)
+			self._cmp_contents(my_file, new_data)
+			assert not os.path.exists(stream.name)
+				
+			# could test automatic _end_writing on destruction
+		finally:
+			os.remove(my_file)
+		# END final cleanup
+		
+		
+		
+		
-- 
cgit v1.2.1