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

Fix write() truncation with ext-uv

Browse Source
This commit is contained in:
Daniil Gentili 2023-07-22 20:32:53 +02:00
parent 1c9f0ebdb2
commit 0b21b1cb8c
Signed by: danog
GPG Key ID: 8C1BE3B34B230CA7
3 changed files with 57 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Driver/UvFilesystemDriver.php
View File

@ -418,7 +418,7 @@ final class UvFilesystemDriver implements FilesystemDriver
public function write(string $path, string $contents): void
{
$flags = \UV::O_WRONLY | \UV::O_CREAT;
$flags = \UV::O_WRONLY | \UV::O_CREAT | \UV::O_TRUNC;
$mode = \UV::S_IRWXU | \UV::S_IRUSR;
$this->poll->listen();
@ -454,8 +454,10 @@ final class UvFilesystemDriver implements FilesystemDriver
return match ($mode) {
"r" => \UV::O_RDONLY,
"r+" => \UV::O_RDWR,
"c", "w" => \UV::O_WRONLY | \UV::O_CREAT,
"c+", "w+" => \UV::O_RDWR | \UV::O_CREAT,
"c" => \UV::O_WRONLY | \UV::O_CREAT,
"w" => \UV::O_WRONLY | \UV::O_CREAT | \UV::O_TRUNC,
"c+" => \UV::O_RDWR | \UV::O_CREAT,
"w+" => \UV::O_RDWR | \UV::O_CREAT | \UV::O_TRUNC,
"a" => \UV::O_WRONLY | \UV::O_CREAT | \UV::O_APPEND,
"a+" => \UV::O_RDWR | \UV::O_CREAT | \UV::O_APPEND,
"x" => \UV::O_WRONLY | \UV::O_CREAT | \UV::O_EXCL,

31
test/FileTest.php
View File

@ -4,6 +4,8 @@ namespace Amp\File\Test;
use Amp\ByteStream\ClosedException;
use Amp\File;
use Amp\File\Whence;
use function Amp\async;
abstract class FileTest extends FilesystemTest
@ -25,6 +27,35 @@ abstract class FileTest extends FilesystemTest
$this->assertSame("foobar", $contents);
$handle->close();
$handle = $this->driver->openFile($path, "c+");
$handle->seek(0, Whence::End);
$this->assertSame(6, $handle->tell());
$handle->close();
}
public function testWriteTruncate(): void
{
$path = Fixture::path() . "/write";
$handle = $this->driver->openFile($path, "c+");
$this->assertSame(0, $handle->tell());
$handle->write("foo");
$handle->write("bar");
$handle->seek(0);
$contents = $handle->read();
$this->assertSame(6, $handle->tell());
$this->assertTrue($handle->eof());
$this->assertSame("foobar", $contents);
$handle->close();
$handle = $this->driver->openFile($path, "w+");
$handle->seek(0, Whence::End);
$this->assertSame(0, $handle->tell());
$handle->close();
}
public function testEmptyWrite(): void

21
test/FilesystemDriverTest.php
View File

@ -506,6 +506,27 @@ abstract class FilesystemDriverTest extends FilesystemTest
$this->assertTrue($newStat["mtime"] > $oldStat["mtime"]);
}
/**
* @group slow
*/
public function testWrite(): void
{
$fixtureDir = Fixture::path();
$contents1 = "write test longer";
$contents2 = "write test";
$path = "{$fixtureDir}/write.txt";
$this->driver->write($path, $contents1);
$this->assertSame($contents1, $this->driver->read($path));
$this->driver->write($path, $contents2);
$this->assertSame($contents2, $this->driver->read($path));
$this->driver->write($path, $contents1);
$this->assertSame($contents1, $this->driver->read($path));
}
public function testTouchFailsOnNonexistentPath(): void
{
$fixtureDir = Fixture::path();