Merge 4eda66e into 54dcef2

src/StatCache.php

@@ -17,7 +17,7 @@ private static function init(): void
 
         $watcher = Loop::repeat(1000, function () {
             self::$now = $now = \time();
-            foreach (self::$cache as $path => $expiry) {
+            foreach (self::$timeouts as $path => $expiry) {
                 if ($now > $expiry) {
                     unset(
                         self::$cache[$path],
@@ -67,6 +67,11 @@ public static function set(string $path, array $stat): void
         self::$timeouts[$path] = self::$now + self::$ttl;
     }
 
+    public static function getTtl(): int
+    {
+        return self::$ttl;
+    }
+
     public static function ttl(int $seconds): void
     {
         self::$ttl = $seconds;

test/StatCacheTest.php

@@ -0,0 +1,46 @@
+<?php
+
+namespace Amp\File\Test;
+
+use Amp\Delayed;
+use Amp\File;
+use Amp\File\StatCache;
+
+class StatCacheTest extends FilesystemTest
+{
+    private $ttlBackup;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->ttlBackup = StatCache::getTtl();
+
+        StatCache::ttl(1);
+    }
+
+    protected function tearDown(): void
+    {
+        parent::tearDown();
+
+        StatCache::ttl($this->ttlBackup);
+    }
+
+    public function testStatCacheExpiration()
+    {
+        File\filesystem(new File\ParallelDriver);
+
+        $fixtureDir = Fixture::path();
+        $path       = "{$fixtureDir}/small.txt";
+
+        $changeTime = yield File\mtime($path);
+
+        yield new Delayed(1000);
+
+        yield File\put($path, 'smaller');
+
+        yield new Delayed(1000);
+
+        $this->assertNotEquals($changeTime, yield File\mtime($path));
+    }
+}