Skip to content

Commit 17bc6c3

Browse files
authored
Remove debug wait (#682)
1 parent 0005d86 commit 17bc6c3

File tree

2 files changed

+0
-18
lines changed

2 files changed

+0
-18
lines changed

source/Halibut/Queue/Redis/NodeHeartBeat/NodeHeartBeatSender.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,6 @@ public NodeHeartBeatSender(
4141

4242
async Task SendPulsesWhileProcessingRequest(Func<HeartBeatMessage> heartBeatMessageProvider, TimeSpan defaultDelayBetweenPulses, CancellationToken cancellationToken)
4343
{
44-
await NodeHeartBeatWatcher.WaitBeforePulses(cancellationToken);
45-
4644
log.Write(EventType.Diagnostic, "Starting heartbeat pulse loop for {0} node, request {1}", nodeSendingPulsesType, requestActivityId);
4745

4846
TimeSpan delayBetweenPulse;

source/Halibut/Queue/Redis/NodeHeartBeat/NodeHeartBeatWatcher.cs

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ public static async Task<NodeWatcherResult> WatchThatNodeProcessingTheRequestIsS
2222
IGetNotifiedOfHeartBeats notifiedOfHeartBeats,
2323
CancellationToken watchCancellationToken)
2424
{
25-
await WaitBeforePulses(watchCancellationToken);
2625
log = log.ForContext<NodeHeartBeatWatcher>();
2726
// Once the pending's CT has been cancelled we no longer care to keep observing
2827
await using var cts = new CancelOnDisposeCancellationToken(watchCancellationToken, redisPending.PendingRequestCancellationToken);
@@ -58,7 +57,6 @@ public static async Task<NodeWatcherResult> WatchThatNodeWhichSentTheRequestIsSt
5857
TimeSpan maxTimeBetweenSenderHeartBeetsBeforeSenderIsAssumedToBeOffline,
5958
CancellationToken watchCancellationToken)
6059
{
61-
await WaitBeforePulses(watchCancellationToken);
6260
try
6361
{
6462
return await WatchForPulsesFromNode(endpoint, requestActivityId, halibutRedisTransport, log, maxTimeBetweenSenderHeartBeetsBeforeSenderIsAssumedToBeOffline, HalibutQueueNodeSendingPulses.RequestSenderNode, watchCancellationToken);
@@ -72,20 +70,6 @@ public static async Task<NodeWatcherResult> WatchThatNodeWhichSentTheRequestIsSt
7270
return NodeWatcherResult.NodeMayHaveDisconnected;
7371
}
7472
}
75-
76-
public static TimeSpan delayBeforeCheckingForOrSendingPulses = TimeSpan.Zero;
77-
78-
public static async Task WaitBeforePulses(CancellationToken cancellationToken)
79-
{
80-
try
81-
{
82-
await Task.Delay(NodeHeartBeatWatcher.delayBeforeCheckingForOrSendingPulses, cancellationToken);
83-
}
84-
catch
85-
{
86-
87-
}
88-
}
8973

9074
static async Task<NodeWatcherResult> WatchForPulsesFromNode(Uri endpoint,
9175
Guid requestActivityId,

0 commit comments

Comments
 (0)