SCHNotify Class Reference

Inheritance diagram for SCHNotify:

Collaboration diagram for SCHNotify:

Instance Methods
(void)	- registerAt:
(void)	- unregisterFrom:
(id)	- initWithProc:
(bool)	- shouldExecuteProc
(void)	- changed

Protected Attributes
list< pair< CFRunLoopSourceRef, CFSocketRef > >	socketSources
__weak SCHAdditions *	schedulerAdditions
StdSchedulerProc *	proc

Detailed Description

Definition at line 37 of file StdSchedulerMac.mm.

Method Documentation

changed

- (void) changed

Definition at line 71 of file StdSchedulerMac.mm.

{
    [schedulerAdditions changed:self];
}

Referenced by StdScheduler::Changed().

Here is the caller graph for this function:

initWithProc:

- (id) initWithProc:

(StdSchedulerProc*)

_proc

Definition at line 71 of file StdSchedulerMac.mm.

                   :(StdSchedulerProc *) _proc
{
    if (self = [super init])
    {
        proc = _proc;
        return self;
    } else
        return nil;
}

registerAt:

- (void) registerAt:

(SCHAdditions*)

_additions

Reimplemented from SCHAddition.

Definition at line 231 of file StdSchedulerMac.mm.

                   :(SCHAdditions*) _additions
{
    [super registerAt:_additions];
    vector<struct pollfd> vecs;
    proc->GetFDs(vecs);
    CFSocketContext ctx =
    {
        .info = (__bridge void*)self,
        .retain = CFRetain,
        .release = CFRelease
    };
    for (auto p : vecs)
    {
        auto socket = CFSocketCreateWithNative(NULL,
            p.fd, kCFSocketReadCallBack,
            callback, &ctx
        );
        auto runLoopSource = CFSocketCreateRunLoopSource(NULL, socket, 0);
        CFRunLoopAddSource([_additions.runLoop getCFRunLoop], runLoopSource, kCFRunLoopDefaultMode);
        socketSources.push_back(make_pair(runLoopSource, socket));
    }
}

References StdSchedulerProc::Execute(), SCHAddition::proc, s, and SCHAddition::shouldExecuteProc.

Here is the call graph for this function:

shouldExecuteProc

- (bool) shouldExecuteProc

Definition at line 71 of file StdSchedulerMac.mm.

{
    if (!proc)
        return false;
    auto s = schedulerAdditions;
    return s && !s.scheduler->IsInManualLoop();
}

Referenced by registerAt:.

Here is the caller graph for this function:

unregisterFrom:

- (void) unregisterFrom:

(SCHAdditions*)

_additions

Reimplemented from SCHAddition.

Definition at line 231 of file StdSchedulerMac.mm.

                       :(SCHAdditions*) _additions
{
    auto runLoop = [_additions.runLoop getCFRunLoop];
    for (auto r : socketSources)
    {
        CFRunLoopRemoveSource(runLoop, r.first, kCFRunLoopDefaultMode);
        CFSocketDisableCallBacks(r.second, kCFSocketReadCallBack|kCFSocketWriteCallBack);
        CFRunLoopSourceInvalidate(r.first);
        CFRelease(r.second);
        CFRelease(r.first);
    }
    socketSources.clear();
    [super unregisterFrom:_additions];
}

Member Data Documentation

proc

- (StdSchedulerProc*) proc

protectedinherited

Definition at line 28 of file StdSchedulerMac.mm.

Referenced by registerAt:.

schedulerAdditions

- (__weak SCHAdditions*) schedulerAdditions

protectedinherited

Definition at line 27 of file StdSchedulerMac.mm.

socketSources

- (list<pair<CFRunLoopSourceRef, CFSocketRef> >) socketSources

protected

Definition at line 39 of file StdSchedulerMac.mm.

---

The documentation for this class was generated from the following file:

• StdSchedulerMac.mm