From 9310a2b0d8484113649389a0e704567e0432a181 Mon Sep 17 00:00:00 2001
From: Ralf Becker <ralfbecker@outdoor-training.de>
Date: Mon, 14 Jun 2010 20:13:38 +0000
Subject: [PATCH] delete db entry again, if we are not able to open a new(!)
 file in filesystem

---
 phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php b/phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php
index cd8ed4538c..9faf848d29 100644
--- a/phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php
+++ b/phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php
@@ -187,6 +187,7 @@ class sqlfs_stream_wrapper implements iface_stream_wrapper
 				return false;
 			}
 			// new file --> create it in the DB
+			$new_file = true;
 			$stmt = self::$pdo->prepare($query='INSERT INTO '.self::TABLE.' (fs_name,fs_dir,fs_mode,fs_uid,fs_gid,fs_created,fs_modified,fs_creator,fs_mime,fs_size'.
 				') VALUES (:fs_name,:fs_dir,:fs_mode,:fs_uid,:fs_gid,:fs_created,:fs_modified,:fs_creator,:fs_mime,:fs_size)');
 			$values = array(
@@ -263,11 +264,17 @@ class sqlfs_stream_wrapper implements iface_stream_wrapper
 				//echo 'gettype($this->opened_stream)='; var_dump($this->opened_stream);
 			}
 		}
-		// do we operate directly on the filesystem
+		// do we operate directly on the filesystem --> open file from there
 		if ($this->operation == self::STORE2FS)
 		{
 			if (self::LOG_LEVEL > 1) error_log(__METHOD__." fopen (may create a directory? mkdir) ($this->opened_fs_id,$mode,$options)");
-			$this->opened_stream = fopen(self::_fs_path($this->opened_fs_id),$mode);
+			if (!($this->opened_stream = fopen(self::_fs_path($this->opened_fs_id),$mode)) && $new_file)
+			{
+				// delete db entry again, if we are not able to open a new(!) file
+				unset($stmt);
+				$stmt = self::$pdo->prepare('DELETE FROM '.self::TABLE.' WHERE fs_id=:fs_id');
+				$stmt->execute(array('fs_id' => $this->opened_fs_id));
+			}
 		}
 		if ($mode[0] == 'a')	// append modes: a, a+
 		{