diff --git a/Wabbajack.Common/DynamicIniData.cs b/Wabbajack.Common/DynamicIniData.cs
index 7998f7d5..7757f40f 100644
--- a/Wabbajack.Common/DynamicIniData.cs
+++ b/Wabbajack.Common/DynamicIniData.cs
@@ -7,11 +7,11 @@ namespace Wabbajack.Common
{
public class DynamicIniData : DynamicObject
{
- private readonly IniData value;
+ private readonly IniData _value;
public DynamicIniData(IniData value) //
{
- this.value = value;
+ this._value = value;
}
public static dynamic FromIni(IniData data)
@@ -27,7 +27,7 @@ namespace Wabbajack.Common
public override bool TryGetMember(GetMemberBinder binder, out object result)
{
- result = new SectionData(value[binder.Name]);
+ result = new SectionData(_value[binder.Name]);
return true;
}
}
diff --git a/Wabbajack.Common/FileExtractor.cs b/Wabbajack.Common/FileExtractor.cs
index be259d11..b87d21da 100644
--- a/Wabbajack.Common/FileExtractor.cs
+++ b/Wabbajack.Common/FileExtractor.cs
@@ -73,13 +73,13 @@ namespace Wabbajack.Common
if (f.Path.StartsWith("\\"))
path = f.Path.Substring(1);
Utils.Status($"Extracting {path}");
- var out_path = Path.Combine(dest, path);
- var parent = Path.GetDirectoryName(out_path);
+ var outPath = Path.Combine(dest, path);
+ var parent = Path.GetDirectoryName(outPath);
if (!Directory.Exists(parent))
Directory.CreateDirectory(parent);
- using (var fs = File.OpenWrite(out_path))
+ using (var fs = File.OpenWrite(outPath))
{
f.CopyDataTo(fs);
}
diff --git a/Wabbajack.Common/SplittingStream.cs b/Wabbajack.Common/SplittingStream.cs
index f95b39bd..723c536e 100644
--- a/Wabbajack.Common/SplittingStream.cs
+++ b/Wabbajack.Common/SplittingStream.cs
@@ -7,15 +7,15 @@ namespace Wabbajack.Common
{
private readonly Stream _a;
private readonly Stream _b;
- private readonly bool _leave_a_open;
- private readonly bool _leave_b_open;
+ private readonly bool _leaveAOpen;
+ private readonly bool _leaveBOpen;
- public SplittingStream(Stream a, bool leave_a_open, Stream b, bool leave_b_open)
+ public SplittingStream(Stream a, bool leaveAOpen, Stream b, bool leaveBOpen)
{
_a = a;
_b = b;
- _leave_a_open = leave_a_open;
- _leave_b_open = leave_b_open;
+ _leaveAOpen = leaveAOpen;
+ _leaveBOpen = leaveBOpen;
}
public override bool CanRead => false;
@@ -63,8 +63,8 @@ namespace Wabbajack.Common
{
if (disposing)
{
- if (!_leave_a_open) _a.Dispose();
- if (!_leave_b_open) _b.Dispose();
+ if (!_leaveAOpen) _a.Dispose();
+ if (!_leaveBOpen) _b.Dispose();
}
}
}
diff --git a/Wabbajack.Common/Utils.cs b/Wabbajack.Common/Utils.cs
index bfe3d8a5..c997b93e 100644
--- a/Wabbajack.Common/Utils.cs
+++ b/Wabbajack.Common/Utils.cs
@@ -36,18 +36,18 @@ namespace Wabbajack.Common
public static string LogFile { get; private set; }
static Utils()
{
- var program_name = Assembly.GetEntryAssembly()?.Location ?? "Wabbajack";
- LogFile = program_name + ".log";
+ var programName = Assembly.GetEntryAssembly()?.Location ?? "Wabbajack";
+ LogFile = programName + ".log";
_startTime = DateTime.Now;
if (LogFile.FileExists())
File.Delete(LogFile);
}
- private static readonly Subject<string> _loggerSubj = new Subject<string>();
- public static IObservable<string> LogMessages => _loggerSubj;
- private static readonly Subject<(string Message, int Progress)> _statusSubj = new Subject<(string Message, int Progress)>();
- public static IObservable<(string Message, int Progress)> StatusUpdates => _statusSubj;
+ private static readonly Subject<string> LoggerSubj = new Subject<string>();
+ public static IObservable<string> LogMessages => LoggerSubj;
+ private static readonly Subject<(string Message, int Progress)> StatusSubj = new Subject<(string Message, int Progress)>();
+ public static IObservable<(string Message, int Progress)> StatusUpdates => StatusSubj;
private static readonly string[] Suffix = {"B", "KB", "MB", "GB", "TB", "PB", "EB"}; // Longs run out around EB
@@ -63,7 +63,7 @@ namespace Wabbajack.Common
File.AppendAllText(LogFile, msg + "\r\n");
}
- _loggerSubj.OnNext(msg);
+ LoggerSubj.OnNext(msg);
}
public static void LogToFile(string msg)
@@ -81,7 +81,7 @@ namespace Wabbajack.Common
if (WorkQueue.CurrentQueue != null)
WorkQueue.CurrentQueue.Report(msg, progress);
else
- _statusSubj.OnNext((msg, progress));
+ StatusSubj.OnNext((msg, progress));
}
/// <summary>
@@ -167,14 +167,14 @@ namespace Wabbajack.Common
{
var buffer = new byte[1024 * 64];
if (maxSize == 0) maxSize = 1;
- long total_read = 0;
+ long totalRead = 0;
while (true)
{
var read = istream.Read(buffer, 0, buffer.Length);
if (read == 0) break;
- total_read += read;
+ totalRead += read;
ostream.Write(buffer, 0, read);
- Status(status, (int) (total_read * 100 / maxSize));
+ Status(status, (int) (totalRead * 100 / maxSize));
}
}
@@ -446,7 +446,7 @@ namespace Wabbajack.Common
{
var colllst = coll.ToList();
- var remaining_tasks = colllst.Count;
+ var remainingTasks = colllst.Count;
var tasks = coll.Select(i =>
{
@@ -461,14 +461,14 @@ namespace Wabbajack.Common
{
tc.SetException(ex);
}
- Interlocked.Decrement(ref remaining_tasks);
+ Interlocked.Decrement(ref remainingTasks);
});
return tc.Task;
}).ToList();
// To avoid thread starvation, we'll start to help out in the work queue
if (WorkQueue.WorkerThread)
- while (remaining_tasks > 0)
+ while (remainingTasks > 0)
if (queue.Queue.TryTake(out var a, 500))
a();
@@ -581,31 +581,31 @@ namespace Wabbajack.Common
public static void CreatePatch(byte[] a, byte[] b, Stream output)
{
- var data_a = a.SHA256().FromBase64().ToHex();
- var data_b = b.SHA256().FromBase64().ToHex();
- var cache_file = Path.Combine("patch_cache", $"{data_a}_{data_b}.patch");
+ var dataA = a.SHA256().FromBase64().ToHex();
+ var dataB = b.SHA256().FromBase64().ToHex();
+ var cacheFile = Path.Combine("patch_cache", $"{dataA}_{dataB}.patch");
if (!Directory.Exists("patch_cache"))
Directory.CreateDirectory("patch_cache");
while (true)
{
- if (File.Exists(cache_file))
+ if (File.Exists(cacheFile))
{
- using (var f = File.OpenRead(cache_file))
+ using (var f = File.OpenRead(cacheFile))
{
f.CopyTo(output);
}
}
else
{
- var tmp_name = Path.Combine("patch_cache", Guid.NewGuid() + ".tmp");
+ var tmpName = Path.Combine("patch_cache", Guid.NewGuid() + ".tmp");
- using (var f = File.OpenWrite(tmp_name))
+ using (var f = File.OpenWrite(tmpName))
{
BSDiff.Create(a, b, f);
}
- File.Move(tmp_name, cache_file);
+ File.Move(tmpName, cacheFile);
continue;
}
@@ -615,9 +615,9 @@ namespace Wabbajack.Common
public static void TryGetPatch(string foundHash, string fileHash, out byte[] ePatch)
{
- var patch_name = Path.Combine("patch_cache",
+ var patchName = Path.Combine("patch_cache",
$"{foundHash.FromBase64().ToHex()}_{fileHash.FromBase64().ToHex()}.patch");
- ePatch = File.Exists(patch_name) ? File.ReadAllBytes(patch_name) : null;
+ ePatch = File.Exists(patchName) ? File.ReadAllBytes(patchName) : null;
}
public static void Warning(string s)
@@ -699,7 +699,7 @@ namespace Wabbajack.Common
private static long TestDiskSpeedInner(WorkQueue queue, string path)
{
- var start_time = DateTime.Now;
+ var startTime = DateTime.Now;
var seconds = 2;
return Enumerable.Range(0, queue.ThreadCount)
.PMap(queue, idx =>
@@ -712,7 +712,7 @@ namespace Wabbajack.Common
random.NextBytes(buffer);
using (var fs = File.OpenWrite(file))
{
- while (DateTime.Now < start_time + new TimeSpan(0, 0, seconds))
+ while (DateTime.Now < startTime + new TimeSpan(0, 0, seconds))
{
fs.Write(buffer, 0, buffer.Length);
// Flush to make sure large buffers don't cause the rate to be higher than it should
@@ -728,11 +728,11 @@ namespace Wabbajack.Common
private static Dictionary<string, long> _cachedDiskSpeeds = new Dictionary<string, long>();
public static long TestDiskSpeed(WorkQueue queue, string path)
{
- var drive_name = Volume.GetUniqueVolumeNameForPath(path);
- if (_cachedDiskSpeeds.TryGetValue(drive_name, out long speed))
+ var driveName = Volume.GetUniqueVolumeNameForPath(path);
+ if (_cachedDiskSpeeds.TryGetValue(driveName, out long speed))
return speed;
speed = TestDiskSpeedInner(queue, path);
- _cachedDiskSpeeds[drive_name] = speed;
+ _cachedDiskSpeeds[driveName] = speed;
return speed;
}