From 325b352bb4f41749df1325d343cb473051768b4c Mon Sep 17 00:00:00 2001
From: Alan Featherston Lago <alan.featherston@trademe.co.nz>
Date: Wed, 27 Mar 2019 08:32:00 +1300
Subject: [PATCH] ads comments to packer and cleans up Write()

---
 src/NLog.Fluentd/FluentdPacker.cs | 12 +++++++++++-
 src/NLog.Fluentd/FluentdTarget.cs | 20 +++++++++-----------
 2 files changed, 20 insertions(+), 12 deletions(-)

diff --git a/src/NLog.Fluentd/FluentdPacker.cs b/src/NLog.Fluentd/FluentdPacker.cs
index 688fa35..230ada8 100644
--- a/src/NLog.Fluentd/FluentdPacker.cs
+++ b/src/NLog.Fluentd/FluentdPacker.cs
@@ -17,6 +17,12 @@ internal class FluentdPacker
         private static DateTime unixEpoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
         private readonly Packer packer;
 
+        /// <summary>
+        /// Packs an event in the stream.
+        /// </summary>
+        /// <remarks>
+        /// The event is packed using the Message Mode.
+        /// </remarks>
         public void Pack(DateTime timestamp, string tag, IDictionary<string, string> data)
 
         {
@@ -27,9 +33,13 @@ public void Pack(DateTime timestamp, string tag, IDictionary<string, string> dat
             this.packer.Pack(data, SerializationContext);
         }
 
+        /// <summary>
+        /// Initializes a new instance of MsgPack.Packer
+        /// </summary>
+        /// <param name="stream">Stream object to be wrapped by the Packer</param>
         public FluentdPacker(Stream stream)
         {
-            this.packer = Packer.Create(stream);           
+            this.packer = Packer.Create(stream);
         }
 
         private static SerializationContext InstantiateSerializationContext()
diff --git a/src/NLog.Fluentd/FluentdTarget.cs b/src/NLog.Fluentd/FluentdTarget.cs
index 18d31cd..e08b45a 100644
--- a/src/NLog.Fluentd/FluentdTarget.cs
+++ b/src/NLog.Fluentd/FluentdTarget.cs
@@ -17,7 +17,6 @@ namespace NLog.Fluentd
     public partial class FluentdTarget : TargetWithLayout, IFluentdTarget
     {
         private string _fluentdHost;
-        private string _fluentdTag;
         private bool _fluentdEnabled;
         private TcpClient _client;
         private Stream _stream;
@@ -178,25 +177,24 @@ protected override void Write(LogEventInfo logEvent)
             _fluentdEnabled = bool.Parse(Enabled?.Render(logEvent));
             if (!_fluentdEnabled)
             {
-                InternalLogger.Trace("Fluentd is disabled.");
+                InternalLogger.Trace("Fluentd target is disabled.");
                 return;
             }
 
-            string renderedFluentdHost = Host?.Render(logEvent);
-            _fluentdTag  = Tag?.Render(logEvent);
+            CheckConnectionIsValid(Host.Render(logEvent));
+
+            string fluentdTag  = Tag?.Render(logEvent);
+            Dictionary<string, string> record = new Dictionary<string, string>();
+            record.Add("message", Layout.Render(logEvent));
 
-            CheckConnectionIsValid(renderedFluentdHost);
-            InternalLogger.Trace("Fluentd (Name={0}): Sending to address: '{1}:{2}'", Name, _fluentdHost, Port);
-            var record = new Dictionary<string, string>();
-            var logMessage = Layout.Render(logEvent);;
-            record.Add("message", logMessage);
             try
             {
-                this._packer.Pack(logEvent.TimeStamp, _fluentdTag, record);
+                InternalLogger.Trace("Fluentd (Name={0}): Sending to address: '{1}:{2}'", Name, _fluentdHost, Port);
+                this._packer.Pack(logEvent.TimeStamp, fluentdTag, record);
             }
             catch (Exception ex)
             {
-                InternalLogger.Warn("Fluentd Emit - " + ex.ToString());
+                InternalLogger.Warn("Fluentd: Error Packing event - " + ex.ToString());
                 ResetConnection();
                 throw;  // Notify NLog of failure
             }