File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -539,13 +539,12 @@ public void HeartbeatReadLoop()
539
539
FinishClose ( ) ;
540
540
}
541
541
542
- public void HandleHeartbeatFrame ( )
542
+ public void NotifyHeartbeatThread ( )
543
543
{
544
544
if ( m_heartbeat == 0 ) {
545
545
// Heartbeating not enabled for this connection.
546
546
return ;
547
547
}
548
-
549
548
m_heartbeatRead . Set ( ) ;
550
549
}
551
550
@@ -601,11 +600,11 @@ public void MainLoopIteration()
601
600
{
602
601
Frame frame = m_frameHandler . ReadFrame ( ) ;
603
602
603
+ NotifyHeartbeatThread ( ) ;
604
604
// We have received an actual frame.
605
605
if ( frame . Type == CommonFraming . Constants . FrameHeartbeat ) {
606
606
// Ignore it: we've already just reset the heartbeat
607
607
// counter.
608
- HandleHeartbeatFrame ( ) ;
609
608
return ;
610
609
}
611
610
You can’t perform that action at this time.
0 commit comments