「ログ出力時に毎回ファイルを開いている」の修正

CONTRIBUTORS.md

@@ -75,6 +75,7 @@
 - Tassana Thaveeteeratham (Thai Translation)
 - Kotaro Sakamoto
 - Koichi Yokota (Documentation)
+- Takym (LogWriter)
 
 # Original Covid19Radar Beta Testers
 - Nagahata Kenji

Covid19Radar/Covid19Radar.Android/Services/Logs/LogPeriodicDeleteServiceAndroid.cs

@@ -61,7 +61,7 @@ public LogPeriodicDeleteReceiver()
  {
  var essensialService = new EssentialsService();
  var logPathService = new LogPathService(new LogPathServiceAndroid());
- loggerService = new LoggerService(logPathService, essensialService);
+ loggerService = new LoggerService(new LogWriter(logPathService, essensialService));
  logFileService = new Covid19Radar.Services.Logs.LogFileService(loggerService, logPathService);
  }
 

Covid19Radar/Covid19Radar/App.xaml.cs

@@ -32,7 +32,7 @@ public partial class App : PrismApplication
  private ILoggerService LoggerService;
  private ILogFileService LogFileService;
 
- /* 
+ /*
  * The Xamarin Forms XAML Previewer in Visual Studio uses System.Activator.CreateInstance.
  * This imposes a limitation in which the App class must have a default constructor.
  * App(IPlatformInitializer initializer = null) cannot be handled by the Activator.
@@ -166,6 +166,7 @@ private static void RegisterCommonTypes(IContainer container)
  container.Register<ILogPathService, LogPathService>(Reuse.Singleton);
  container.Register<ILogPeriodicDeleteService, LogPeriodicDeleteService>(Reuse.Singleton);
  container.Register<ILogUploadService, LogUploadService>(Reuse.Singleton);
+ container.Register<ILogWriter, LogWriter>(Reuse.Singleton);
  container.Register<IEssentialsService, EssentialsService>(Reuse.Singleton);
  container.Register<IUserDataService, UserDataService>(Reuse.Singleton);
  container.Register<IExposureNotificationService, ExposureNotificationService>(Reuse.Singleton);

Covid19Radar/Covid19Radar/Services/Logs/LogWriter.cs

@@ -0,0 +1,210 @@
+#nullable enable
+
+using System;
+using System.Diagnostics;
+using System.IO;
+using System.Text;
+using System.Threading;
+using Covid19Radar.Common;
+
+namespace Covid19Radar.Services.Logs
+{
+ /// <summary>
+ /// ログの書き込みを行う機能を提供します。
+ /// </summary>
+ public interface ILogWriter : IDisposable
+ {
+ /// <summary>
+ /// ログを出力します。
+ /// </summary>
+ /// <param name="message">出力するメッセージです。</param>
+ /// <param name="method">実行中の関数の名前です。</param>
+ /// <param name="filePath">実行中の関数を格納しているソースファイルの名前です。</param>
+ /// <param name="lineNumber">実行中の関数のソースファイル内での行番号です。</param>
+ /// <param name="logLevel">ログレベルです。</param>
+ public void Write(string message, string method, string filePath, int lineNumber, LogLevel logLevel);
+ }
+
+ /// <summary>
+ /// <see cref="Covid19Radar.Services.Logs.ILogWriter"/>の実装です。
+ /// </summary>
+ public sealed class LogWriter : ILogWriter
+ {
+ private const string _dt_format = "yyyy/MM/dd HH:mm:ss.fffffff";
+ private readonly ILogPathService _log_path;
+ private readonly IEssentialsService _essentials;
+ private readonly Encoding _enc;
+ private File? _file;
+ private readonly string _header;
+
+ /// <summary>
+ /// 型'<see cref="Covid19Radar.Services.Logs.LogWriter"/>'の新しいインスタンスを生成します。
+ /// </summary>
+ /// <param name="logPath">ログファイルのパスを提供するサービスを指定します。</param>
+ /// <param name="essentials">環境情報を提供するサービスを指定します。</param>
+ public LogWriter(ILogPathService logPath, IEssentialsService essentials)
+ {
+ _log_path = logPath ?? throw new ArgumentNullException(nameof(logPath));
+ _essentials = essentials ?? throw new ArgumentNullException(nameof(essentials));
+ _enc = Encoding.UTF8;
+ _header = CreateLogHeaderRow();
+ }
+
+ /// <inheritdoc/>
+ public void Write(string message, string method, string filePath, int lineNumber, LogLevel logLevel)
+ {
+#if !DEBUG
+ if (logLevel == LogLevel.Verbose || logLevel == LogLevel.Debug) {
+ return;
+ }
+#endif
+ try {
+ var jstNow = Utils.JstNow();
+ string row = CreateLogContentRow(message, method, filePath, lineNumber, logLevel, jstNow, _essentials);
+ Debug.WriteLine(row);
+ this.WriteLine(jstNow, row);
+ } catch (Exception e) {
+ Debug.WriteLine(e.ToString());
+ }
+ }
+
+ private void WriteLine(DateTime jstNow, string line)
+ {
+ var file = _file;
+ string fname = _log_path.LogFilePath(jstNow);
+ if (file is null || file._path != fname) {
+ var newFile = new File(fname, _enc);
+ while (true) {
+ if (Interlocked.CompareExchange(ref _file, newFile, file) == file) {
+ file?.Dispose();
+ break;
+ }
+ Thread.Yield();
+ file = _file;
+ }
+ file = newFile;
+ file._sw.WriteLine(_header);
+ }
+ file._sw.WriteLine(line);
+ }
+
+ /// <inheritdoc/>
+ public void Dispose()
+ {
+ File? file;
+ while (true) {
+ file = _file;
+ if (Interlocked.CompareExchange(ref _file, null, file) == file) {
+ file?.Dispose();
+ break;
+ }
+ Thread.Yield();
+ }
+ }
+
+ private static string CreateLogHeaderRow()
+ {
+ return CreateLogRow(
+ "output_date",
+ "log_level",
+ "message",
+ "method",
+ "file_path",
+ "line_number",
+ "platform",
+ "platform_version",
+ "model",
+ "device_type",
+ "app_version",
+ "build_number"
+ );
+ }
+
+ private static string CreateLogContentRow(
+ string message,
+ string method,
+ string filePath,
+ int lineNumber,
+ LogLevel logLevel,
+ DateTime jstDateTime,
+ IEssentialsService essentials)
+ {
+ return CreateLogRow(
+ jstDateTime.ToString(_dt_format),
+ logLevel.ToString(),
+ message,
+ method,
+ filePath,
+ lineNumber.ToString(),
+ essentials.Platform,
+ essentials.PlatformVersion,
+ essentials.Model,
+ essentials.DeviceType,
+ essentials.AppVersion,
+ essentials.BuildNumber
+ );
+ }
+
+ private static string CreateLogRow(params string[] cols)
+ {
+ var sb = new StringBuilder();
+ for (int i = 0; i < cols.Length; ++i) {
+ if (i != 0) {
+ sb.Append(", ");
+ }
+ string s = cols[i];
+ sb.Append('\"');
+ for (int j = 0; j < s.Length; ++j) {
+ char ch = s[j];
+ switch (ch) {
+ case '\t':
+ sb.Append("\\t");
+ break;
+ case '\v':
+ sb.Append("\\v");
+ break;
+ case '\r':
+ sb.Append("\\r");
+ break;
+ case '\n':
+ sb.Append("\\n");
+ break;
+ case '\\':
+ case '\"':
+ sb.Append(ch)
+ .Append(ch);
+ break;
+ default:
+ sb.Append(ch);
+ break;
+ }
+ }
+ sb.Append('\"');
+ }
+ return sb.ToString();
+ }
+
+ private sealed class File : IDisposable
+ {
+ internal readonly string _path;
+ internal readonly StreamWriter _sw;
+
+ internal File(string path, Encoding enc)
+ {
+ string dir = Path.GetDirectoryName(path);
+ if (!Directory.Exists(dir)) {
+ Directory.CreateDirectory(dir);
+ }
+
+ _path = path;
+ _sw = new StreamWriter(new FileStream(path, FileMode.Append, FileAccess.Write, FileShare.ReadWrite), enc);
+ _sw.AutoFlush = true;
+ }
+
+ public void Dispose()
+ {
+ _sw.Dispose();
+ }
+ }
+ }
+}