mirror of
https://github.com/TomHarte/CLK.git
synced 2024-08-16 16:28:59 +00:00
71 lines
1.5 KiB
Plaintext
71 lines
1.5 KiB
Plaintext
//
|
|
// CSBestEffortUpdater.m
|
|
// Clock Signal
|
|
//
|
|
// Created by Thomas Harte on 16/06/2016.
|
|
// Copyright 2016 Thomas Harte. All rights reserved.
|
|
//
|
|
|
|
#import "CSBestEffortUpdater.h"
|
|
|
|
#include "BestEffortUpdater.hpp"
|
|
|
|
struct UpdaterDelegate: public Concurrency::BestEffortUpdater::Delegate {
|
|
__weak id<CSBestEffortUpdaterDelegate> delegate;
|
|
NSLock *delegateLock;
|
|
|
|
void update(Concurrency::BestEffortUpdater *updater, Time::Seconds cycles, bool did_skip_previous_update) {
|
|
[delegateLock lock];
|
|
__weak id<CSBestEffortUpdaterDelegate> delegateCopy = delegate;
|
|
[delegateLock unlock];
|
|
|
|
[delegateCopy bestEffortUpdater:nil runForInterval:(NSTimeInterval)cycles didSkipPreviousUpdate:did_skip_previous_update];
|
|
}
|
|
};
|
|
|
|
@implementation CSBestEffortUpdater {
|
|
Concurrency::BestEffortUpdater _updater;
|
|
UpdaterDelegate _updaterDelegate;
|
|
NSLock *_delegateLock;
|
|
}
|
|
|
|
- (instancetype)init {
|
|
self = [super init];
|
|
if(self) {
|
|
_delegateLock = [[NSLock alloc] init];
|
|
_updaterDelegate.delegateLock = _delegateLock;
|
|
_updater.set_delegate(&_updaterDelegate);
|
|
}
|
|
return self;
|
|
}
|
|
|
|
//- (void)dealloc {
|
|
// _updater.flush();
|
|
//}
|
|
|
|
- (void)update {
|
|
_updater.update();
|
|
}
|
|
|
|
- (void)flush {
|
|
_updater.flush();
|
|
}
|
|
|
|
- (void)setDelegate:(id<CSBestEffortUpdaterDelegate>)delegate {
|
|
[_delegateLock lock];
|
|
_updaterDelegate.delegate = delegate;
|
|
[_delegateLock unlock];
|
|
}
|
|
|
|
- (id<CSBestEffortUpdaterDelegate>)delegate {
|
|
id<CSBestEffortUpdaterDelegate> delegate;
|
|
|
|
[_delegateLock lock];
|
|
delegate = _updaterDelegate.delegate;
|
|
[_delegateLock unlock];
|
|
|
|
return delegate;
|
|
}
|
|
|
|
@end
|