Continued flock work.

2 files changed, 49 insertions, 4 deletions

diff --git a/lib/public/files/lock.php b/lib/public/files/lock.php
index fb1e4b9f1c5..cc39e674b50 100644
--- a/lib/public/files/lock.php
+++ b/lib/public/files/lock.php
@@ -17,6 +17,7 @@
  */
 
 namespace OCP\Files;
+use OC\Files\Filesystem;
 
 /**
  * Class Lock
@@ -29,13 +30,50 @@ class Lock {
 	/** @var string $path Filename of the file as represented in storage */
 	protected $path;
 
+	/** @var array $stack A stack of lock data */
+	protected $stack = array();
+
+	/** @var int $retries Number of lock retries to attempt */
+	public static $retries = 40;
+
+	/** @var int $retryInterval Milliseconds between retries */
+	public static $retryInterval = 50;
+
+	/**
+	 * Constructor for the lock instance
+	 * @param string $path Absolute pathname for a local file on which to obtain a lock
+	 */
 	public function __construct($path) {
-		$this->path = $path;
+		$this->path = Filesystem::normalizePath($path);
 	}
 
+	/**
+	 * @param integer $lockType A constant representing the type of lock to queue
+	 */
 	public function addLock($lockType) {
-		// This class is a stub/base for classes that implement locks
-		// We don't actually care what kind of lock we're queuing here
+		\OC_Log::write('lock', sprintf('INFO: Lock type %d requested for %s', $lockType, $this->path), \OC_Log::DEBUG);
+		$timeout = self::$retries;
+
+		if(!isset($this->stack[$lockType])) {
+			// does lockfile exist?
+				// yes
+				// Acquire exclusive lock on lockfile?
+					// yes
+					// Delete lockfile, release lock
+					// no
+					// Sleep for configurable milliseconds - start over
+				// no
+				// Acquire shared lock on original file?
+					// yes
+					// Capture handle, return for action
+					// no
+					// Sleep for configurable milliseconds - start over
+			$handle = 1;
+
+			$this->stack[$lockType] = array('handle' => $handle, 'count' => 0);
+		}
+		$this->stack[$lockType]['count']++;
+
 	}
 
 	/**
@@ -45,4 +83,12 @@ class Lock {
 		return true;
 	}
 
+	/**
+	 * Release all queued locks on the file
+	 * @return bool
+	 */
+	public function releaseAll() {
+		return true;
+	}
+
 }
\ No newline at end of file
diff --git a/lib/public/files/storage.php b/lib/public/files/storage.php
index 758cbb27377..323d20db564 100644
--- a/lib/public/files/storage.php
+++ b/lib/public/files/storage.php
@@ -35,7 +35,6 @@ namespace OCP\Files;
  * All paths passed to the storage are relative to the storage and should NOT have a leading slash.
  */
 interface Storage {
-
 	/**
 	 * $parameters is a free form array with the configuration options needed to construct the storage
 	 *