cyberpresidentvanellope/tgstation-server
1
0
Fork 0
mirror of https://github.com/tgstation/tgstation-server.git synced 2026-08-24 05:27:30 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1223 from tgstation/BetterFileCopy [TGSDeploy]

Browse Source 
Better file copy
This commit is contained in:
Jordan Brown
2021-02-02 12:18:04 -05:00
committed by GitHub
parent 5630a99c9f 7795c6631f
commit c18135d9a2
1 changed files with 28 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Tgstation.Server.Host/IO/DefaultIOManager.cs
+28 -11
View File
@@ -64,13 +64,6 @@ namespace Tgstation.Server.Host.IO
dir.Delete(true);
}
/// <summary>
/// Opens a <see cref="FileStream"/> for async writing at a given <paramref name="path"/>
/// </summary>
/// <param name="path">The path to open the <see cref="FileStream"/> at</param>
/// <returns>A new <see cref="FileStream"/> ready for async writing</returns>
static FileStream OpenWriteStream(string path) => new FileStream(path, FileMode.Create, FileAccess.Write, FileShare.ReadWrite, DefaultBufferSize, true);
/// <summary>
/// Copies a directory from <paramref name="src"/> to <paramref name="dest"/>
/// </summary>
@@ -143,8 +136,20 @@ namespace Tgstation.Server.Host.IO
throw new ArgumentNullException(nameof(src));
if (dest == null)
throw new ArgumentNullException(nameof(dest));
using var srcStream = new FileStream(ResolvePath(src), FileMode.Open, FileAccess.Read, FileShare.Read | FileShare.Delete, DefaultBufferSize, true);
using var destStream = new FileStream(ResolvePath(dest), FileMode.Create, FileAccess.Write, FileShare.ReadWrite | FileShare.Delete, DefaultBufferSize, true);
using var srcStream = new FileStream(
ResolvePath(src),
FileMode.Open,
FileAccess.Read,
FileShare.Read | FileShare.Delete,
DefaultBufferSize,
FileOptions.Asynchronous | FileOptions.SequentialScan);
using var destStream = new FileStream(
ResolvePath(dest),
FileMode.Create,
FileAccess.Write,
FileShare.ReadWrite | FileShare.Delete,
DefaultBufferSize,
FileOptions.Asynchronous | FileOptions.SequentialScan);
// value taken from documentation
await srcStream.CopyToAsync(destStream, 81920, cancellationToken).ConfigureAwait(false);
@@ -229,7 +234,13 @@ namespace Tgstation.Server.Host.IO
public async Task<byte[]> ReadAllBytes(string path, CancellationToken cancellationToken)
{
path = ResolvePath(path);
using var file = new FileStream(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite | FileShare.Delete, DefaultBufferSize, true);
using var file = new FileStream(
path,
FileMode.Open,
FileAccess.Read,
FileShare.ReadWrite | FileShare.Delete,
DefaultBufferSize,
FileOptions.Asynchronous | FileOptions.SequentialScan);
byte[] buf;
buf = new byte[file.Length];
await file.ReadAsync(buf, cancellationToken).ConfigureAwait(false);
@@ -246,7 +257,13 @@ namespace Tgstation.Server.Host.IO
public async Task WriteAllBytes(string path, byte[] contents, CancellationToken cancellationToken)
{
path = ResolvePath(path);
using var file = OpenWriteStream(path);
using var file = new FileStream(
path,
FileMode.Create,
FileAccess.Write,
FileShare.ReadWrite,
DefaultBufferSize,
FileOptions.Asynchronous | FileOptions.SequentialScan);
await file.WriteAsync(contents, cancellationToken).ConfigureAwait(false);
}