Skip to content

Commit 2db9301

Browse files
committed
added some logs
1 parent cbcff30 commit 2db9301

File tree

2 files changed

+9
-5
lines changed

2 files changed

+9
-5
lines changed

Algo/HeartbeatMessageAdapter.cs

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public override Message Clone()
9090
private bool _canSendTime;
9191
private bool _isFirstTimeConnect = true;
9292
private bool _suppressDisconnectError;
93-
93+
9494
/// <summary>
9595
/// Initializes a new instance of the <see cref="HeartbeatMessageAdapter"/>.
9696
/// </summary>
@@ -149,6 +149,8 @@ protected override void OnInnerAdapterNewOutMessage(Message message)
149149
else
150150
_prevState = _currState = ConnectionStates.Failed;
151151
}
152+
153+
this.AddLog(LogLevels.Warning, () => $"RCM: got error, new state={_currState}\n{connectMsg.Error}");
152154
}
153155

154156
if (isRestored)
@@ -307,7 +309,7 @@ protected override bool OnSendInMessage(Message message)
307309
{
308310
lock (_timeSync)
309311
_canSendTime = true;
310-
}
312+
}
311313
}
312314
}
313315

@@ -318,7 +320,7 @@ private void StartTimer()
318320

319321
var period = ReConnectionSettings.Interval;
320322
var needHeartbeat = HeartbeatInterval != TimeSpan.Zero;
321-
323+
322324
var time = TimeHelper.Now;
323325
var lastHeartBeatTime = TimeHelper.Now;
324326

@@ -485,7 +487,7 @@ private static string FormatState(ConnectionStates state)
485487
{
486488
case _reConnecting:
487489
return LocalizedStrings.Reconnecting;
488-
490+
489491
case _none:
490492
return LocalizedStrings.Str1658;
491493

@@ -522,4 +524,4 @@ public override IMessageChannel Clone()
522524
return new HeartbeatMessageAdapter(InnerAdapter.TypedClone()) { SuppressReconnectingErrors = SuppressReconnectingErrors };
523525
}
524526
}
525-
}
527+
}

Messages/AsyncMessageProcessor.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,8 @@ or MessageTypes.OrderCancel
6868
public AsyncMessageProcessor(IAsyncMessageAdapter adapter)
6969
{
7070
Parent = adapter;
71+
// ReSharper disable once VirtualMemberCallInConstructor
72+
Name = $"async({adapter.Name})";
7173
Task.Run(ProcessMessagesAsync);
7274
}
7375

0 commit comments

Comments
 (0)