mirror of
https://github.com/TomHarte/CLK.git
synced 2024-11-23 18:31:53 +00:00
72 lines
1.9 KiB
Objective-C
72 lines
1.9 KiB
Objective-C
//
|
|
// CSBestEffortUpdater.m
|
|
// Clock Signal
|
|
//
|
|
// Created by Thomas Harte on 16/06/2016.
|
|
// Copyright © 2016 Thomas Harte. All rights reserved.
|
|
//
|
|
|
|
#import "CSBestEffortUpdater.h"
|
|
|
|
@implementation CSBestEffortUpdater
|
|
{
|
|
// these are inherently handled only by thread-safe constructions
|
|
uint32_t _updateIsOngoing;
|
|
dispatch_queue_t _serialDispatchQueue;
|
|
|
|
// these are permitted for modification on _serialDispatchQueue only
|
|
NSTimeInterval _previousTimeInterval;
|
|
NSTimeInterval _cyclesError;
|
|
BOOL _hasSkipped;
|
|
}
|
|
|
|
- (instancetype)init
|
|
{
|
|
if(self = [super init])
|
|
{
|
|
_serialDispatchQueue = dispatch_queue_create("Best Effort Updater", DISPATCH_QUEUE_SERIAL);
|
|
}
|
|
return self;
|
|
}
|
|
|
|
- (void)update
|
|
{
|
|
const uint32_t processingMask = 0x01;
|
|
|
|
// Always post an -openGLView:didUpdateToTime: if a previous one isn't still ongoing. This is the hook upon which the substantial processing occurs.
|
|
if(!OSAtomicTestAndSet(processingMask, &_updateIsOngoing))
|
|
{
|
|
dispatch_async(_serialDispatchQueue, ^{
|
|
NSTimeInterval timeInterval = [NSDate timeIntervalSinceReferenceDate];
|
|
if(_previousTimeInterval > DBL_EPSILON && timeInterval > _previousTimeInterval)
|
|
{
|
|
NSTimeInterval timeToRunFor = timeInterval - _previousTimeInterval;
|
|
double cyclesToRunFor = timeToRunFor * self.clockRate + _cyclesError;
|
|
|
|
_cyclesError = fmod(cyclesToRunFor, 1.0);
|
|
NSUInteger integerCyclesToRunFor = (NSUInteger)MIN(cyclesToRunFor, self.clockRate * 0.5);
|
|
|
|
// treat 'unlimited' as running at a factor of 10
|
|
if(self.runAsUnlimited) integerCyclesToRunFor *= 10;
|
|
[self.delegate bestEffortUpdater:self runForCycles:integerCyclesToRunFor didSkipPreviousUpdate:_hasSkipped];
|
|
}
|
|
_previousTimeInterval = timeInterval;
|
|
_hasSkipped = NO;
|
|
OSAtomicTestAndClear(processingMask, &_updateIsOngoing);
|
|
});
|
|
}
|
|
else
|
|
{
|
|
dispatch_async(_serialDispatchQueue, ^{
|
|
_hasSkipped = YES;
|
|
});
|
|
}
|
|
}
|
|
|
|
- (void)flush
|
|
{
|
|
dispatch_sync(_serialDispatchQueue, ^{});
|
|
}
|
|
|
|
@end
|