RTSDK-8563 Fixed EMA C# Non-Interactive provider failed to resize encoded buffer to publish user source directory message.

Author: soranat

CSharp/Ema/Src/Core/Access/MarketItemHandler.cs

@@ -480,8 +480,12 @@ void SendRejectMessage(ClientSession clientSession, IMsg msg, int statusCode, st
                 }
             }
 
-            m_EncodeIterator.Clear();
+            // Clears underlying ByteBuffer to reset buffer's length
+            Eta.Common.ByteBuffer byteBuf = m_MsgBuffer.Data();
+            byteBuf.Clear();
+            m_MsgBuffer.Data(byteBuf, 0, byteBuf.Capacity);
 
+            m_EncodeIterator.Clear();
             CodecReturnCode retCode = m_EncodeIterator.SetBufferAndRWFVersion(m_MsgBuffer, clientSession.Channel().MajorVersion,
                             clientSession.Channel().MinorVersion);
 

CSharp/Ema/Src/Core/Access/OmmNiProviderImpl.cs

@@ -1172,8 +1172,17 @@ private CodecReturnCode SubmitDirectoryRefresh(DirectoryRefresh directoryRefresh
             while ((retCode = directoryRefresh.Encode(encodeIt)) == CodecReturnCode.BUFFER_TOO_SMALL)
             {
                 capacity *= 2;
-                if ((retCode = Utilities.RealignBuffer(encodeIt, capacity)) != CodecReturnCode.SUCCESS)
-                    break;
+
+                encodedBuffer.Clear();
+                encodedBuffer.Data(new ByteBuffer(capacity));
+
+                if ((retCode = encodeIt.SetBufferAndRWFVersion(encodedBuffer, Codec.MajorVersion(), Codec.MinorVersion())) != CodecReturnCode.SUCCESS)
+                {
+                    errorText.Append($"Internal error. Failed to set encode iterator buffer and version in " +
+                        $"OmmNiProviderImpl.SubmitDirectoryRefresh(). Reason = {retCode.GetAsString()}.");
+                    HandleInvalidUsage(errorText.ToString(), (int)retCode);
+                    return CodecReturnCode.FAILURE;
+                }
             }
 
             if (retCode != CodecReturnCode.SUCCESS)
@@ -1186,7 +1195,7 @@ private CodecReturnCode SubmitDirectoryRefresh(DirectoryRefresh directoryRefresh
 
             DecodeIterator decodeIt = new();
 
-            if((retCode = decodeIt.SetBufferAndRWFVersion(encodeIt.Buffer(), Codec.MajorVersion(), Codec.MinorVersion())) 
+            if((retCode = decodeIt.SetBufferAndRWFVersion(encodedBuffer, Codec.MajorVersion(), Codec.MinorVersion())) 
                 != CodecReturnCode.SUCCESS)
             {
                 errorText.Append($"Internal error. Failed to set decode iterator buffer and version in" +