Add logging
This commit is contained in:
@@ -170,6 +170,9 @@ namespace mROA.Implementation
|
|||||||
}
|
}
|
||||||
|
|
||||||
var message = meta.ToMessage(_buffer.Span);
|
var message = meta.ToMessage(_buffer.Span);
|
||||||
|
#if TRACE
|
||||||
|
Console.WriteLine("RECV " + message);
|
||||||
|
#endif
|
||||||
MessageReceived(message);
|
MessageReceived(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -183,11 +186,15 @@ namespace mROA.Implementation
|
|||||||
|
|
||||||
private async Task Send(NetworkMessage message, CancellationToken token = default)
|
private async Task Send(NetworkMessage message, CancellationToken token = default)
|
||||||
{
|
{
|
||||||
|
Thread.SpinWait(10000);
|
||||||
var meta = message.ToMeta();
|
var meta = message.ToMeta();
|
||||||
MemoryMarshal.Write(_buffer.Span, ref meta);
|
MemoryMarshal.Write(_buffer.Span, ref meta);
|
||||||
message.Data.CopyTo(_buffer.Span[19..]);
|
message.Data.CopyTo(_buffer.Span[19..]);
|
||||||
var sendingSpan = _buffer[..(19 + meta.BodyLength)];
|
var sendingSpan = _buffer[..(19 + meta.BodyLength)];
|
||||||
await _ioStream.WriteAsync(sendingSpan, token);
|
await _ioStream.WriteAsync(sendingSpan, token);
|
||||||
|
#if TRACE
|
||||||
|
Console.WriteLine("SEND " + message);
|
||||||
|
#endif
|
||||||
// _logger.LogTrace("SEND {0}", message.ToString());
|
// _logger.LogTrace("SEND {0}", message.ToString());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+1
-1
@@ -22,7 +22,7 @@
|
|||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<PropertyGroup Condition=" '$(Configuration)' == 'Debug' ">
|
<PropertyGroup Condition=" '$(Configuration)' == 'Debug' ">
|
||||||
<DefineConstants></DefineConstants>
|
<DefineConstants>TRACE;</DefineConstants>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
|||||||
Reference in New Issue
Block a user