danog/file
1
0
Fork 0
mirror of https://github.com/danog/file.git synced 2024-11-30 04:19:39 +01:00
Code Issues Projects Releases Wiki Activity

Use StatCache in ParallelDriver

Browse Source
This commit is contained in:
Aaron Piotrowski 2017-07-18 01:01:20 -05:00
parent 28a62c8f5f
commit 169a1d1b36
No known key found for this signature in database
GPG Key ID: ADD1EF783EDE9EEB
2 changed files with 74 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/Internal/FileTask.php
View File

@ -131,18 +131,12 @@ class FileTask implements Task {
case "readlink":
case "lstat":
case "exists":
case "isfile":
case "isdir":
case "mkdir":
case "scandir":
case "rmdir":
case "chmod":
case "chown":
case "touch":
case "size":
case "mtime":
case "atime":
case "ctime":
case "get":
case "put":
return ([new BlockingDriver, $this->operation])(...$this->args);

83
lib/ParallelDriver.php
View File

@ -9,6 +9,8 @@ use Amp\Parallel\Worker\Pool;
use Amp\Parallel\Worker\TaskException;
use Amp\Parallel\Worker\WorkerException;
use Amp\Promise;
use Amp\Success;
use function Amp\call;
class ParallelDriver implements Driver {
/**
@ -67,14 +69,28 @@ class ParallelDriver implements Driver {
* {@inheritdoc}
*/
public function unlink(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("unlink", [$path])));
return call(function () use ($path) {
$result = yield from $this->runFileTask(new Internal\FileTask("unlink", [$path]));
StatCache::clear($path);
return $result;
});
}
/**
* {@inheritdoc}
*/
public function stat(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("stat", [$path])));
if ($stat = StatCache::get($path)) {
return new Success($stat);
}
return call(function () use ($path) {
$stat = yield from $this->runFileTask(new Internal\FileTask("stat", [$path]));
if (!empty($stat)) {
StatCache::set($path, $stat);
}
return $stat;
});
}
/**
@ -88,14 +104,32 @@ class ParallelDriver implements Driver {
* {@inheritdoc}
*/
public function isfile(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("isfile", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
return false;
}
if ($stat["mode"] & 0100000) {
return true;
}
return false;
});
}
/**
* {@inheritdoc}
*/
public function isdir(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("isdir", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
return false;
}
if ($stat["mode"] & 0040000) {
return true;
}
return false;
});
}
/**
@ -137,7 +171,11 @@ class ParallelDriver implements Driver {
* {@inheritdoc}
*/
public function rmdir(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("rmdir", [$path])));
return call(function () use ($path) {
$result = yield from $this->runFileTask(new Internal\FileTask("rmdir", [$path]));
StatCache::clear($path);
return $result;
});
}
/**
@ -165,28 +203,55 @@ class ParallelDriver implements Driver {
* {@inheritdoc}
*/
public function size(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("size", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
throw new FilesystemException("Specified path does not exist");
}
if ($stat["mode"] & 0100000) {
return $stat["size"];
}
throw new FilesystemException("Specified path is not a regular file");
});
}
/**
* {@inheritdoc}
*/
public function mtime(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("mtime", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
throw new FilesystemException("Specified path does not exist");
}
return $stat["mtime"];
});
}
/**
* {@inheritdoc}
*/
public function atime(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("atime", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
throw new FilesystemException("Specified path does not exist");
}
return $stat["atime"];
});
}
/**
* {@inheritdoc}
*/
public function ctime(string $path): Promise {
return new Coroutine($this->runFileTask(new Internal\FileTask("ctime", [$path])));
return call(function () use ($path) {
$stat = yield $this->stat($path);
if (empty($stat)) {
throw new FilesystemException("Specified path does not exist");
}
return $stat["ctime"];
});
}
/**