60
60
61
61
#define kSecondsToWaitBeforeMarkingUnreachableAfterSettingUpSubscription 10
62
62
63
+ // Disabling pending crashes
64
+ #define ENABLE_CONNECTIVITY_MONITORING 0
65
+
63
66
// Consider moving utility classes to their own file
64
67
#pragma mark - Utility Classes
65
68
@@ -1381,15 +1384,15 @@ - (void)_handleResubscriptionNeededWithDelay:(NSNumber *)resubscriptionDelayMs
1381
1384
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, resubscriptionDelayNs), self.queue, resubscriptionBlock);
1382
1385
}
1383
1386
1384
- // Set up connectivity monitoring in case network routability changes for the positive, to accellerate resubscription
1387
+ // Set up connectivity monitoring in case network routability changes for the positive, to accelerate resubscription
1385
1388
[self _setupConnectivityMonitoring];
1386
1389
}
1387
1390
1388
1391
- (void)_handleSubscriptionReset:(NSNumber * _Nullable)retryDelay
1389
1392
{
1390
1393
std::lock_guard lock(_lock);
1391
1394
1392
- // If we are here, then either we failed to establish initil CASE, or we
1395
+ // If we are here, then either we failed to establish initial CASE, or we
1393
1396
// failed to send the initial SubscribeRequest message, or our ReadClient
1394
1397
// has given up completely. Those all count as "we have tried and failed to
1395
1398
// subscribe".
@@ -2253,6 +2256,7 @@ - (void)_createDataVersionFilterListFromDictionary:(NSDictionary<MTRClusterPath
2253
2256
2254
2257
- (void)_setupConnectivityMonitoring
2255
2258
{
2259
+ #if ENABLE_CONNECTIVITY_MONITORING
2256
2260
// Dispatch to own queue first to avoid deadlock with syncGetCompressedFabricID
2257
2261
dispatch_async(self.queue, ^{
2258
2262
// Get the required info before setting up the connectivity monitor
@@ -2277,6 +2281,7 @@ - (void)_setupConnectivityMonitoring
2277
2281
errorHandler:nil];
2278
2282
} queue:self.queue];
2279
2283
});
2284
+ #endif
2280
2285
}
2281
2286
2282
2287
- (void)_stopConnectivityMonitoring
0 commit comments