@@ -113,11 +113,12 @@ protected async override Task ExecuteAsync(CancellationToken stoppingToken)
113
113
continue ;
114
114
}
115
115
116
- if ( _recvSocket . Available > 0 )
116
+ try
117
117
{
118
- try
118
+ if ( _recvSocket . Available > 0 )
119
119
{
120
- var bytesReceived = await _recvSocket . ReceiveAsync ( _recvBuffer , SocketFlags . None , _linkedToken . Token ) ;
120
+ var bytesReceived =
121
+ await _recvSocket . ReceiveAsync ( _recvBuffer , SocketFlags . None , _linkedToken . Token ) ;
121
122
var offset = 0 ;
122
123
var newMsg = OscMessage . TryParseOsc ( _recvBuffer , bytesReceived , ref offset ) ;
123
124
if ( newMsg == null )
@@ -127,21 +128,21 @@ protected async override Task ExecuteAsync(CancellationToken stoppingToken)
127
128
128
129
OnMessageReceived ( newMsg ) ;
129
130
}
130
- catch ( Exception e )
131
+ else
131
132
{
132
- // We don't care about operation cancellations as they're intentional and carefully controlled
133
- if ( e . GetType ( ) == typeof ( OperationCanceledException ) )
134
- {
135
- continue ;
136
- }
137
-
138
- _logger . LogError ( "Error encountered in OSC Receive thread: {e}" , e ) ;
139
- SentrySdk . CaptureException ( e , scope => scope . SetExtra ( "recvBuffer" , _recvBuffer ) ) ;
133
+ await Task . Delay ( 100 , _linkedToken . Token ) ;
140
134
}
141
135
}
142
- else
136
+ catch ( Exception e )
143
137
{
144
- await Task . Delay ( 100 , _linkedToken . Token ) ;
138
+ // We don't care about operation cancellations as they're intentional and carefully controlled
139
+ if ( e . GetType ( ) == typeof ( OperationCanceledException ) || e . GetType ( ) == typeof ( TaskCanceledException ) )
140
+ {
141
+ continue ;
142
+ }
143
+
144
+ _logger . LogError ( "Error encountered in OSC Receive thread: {e}" , e ) ;
145
+ SentrySdk . CaptureException ( e , scope => scope . SetExtra ( "recvBuffer" , _recvBuffer ) ) ;
145
146
}
146
147
}
147
148
}
0 commit comments