masterport.cpp

Go to the documentation of this file.

/* SPDX-License-Identifier: MIT */
#include "masterport.h"
#include <iostream>
 
 
using namespace std;
 
 
static bool             gTerminating    (false);
static MasterPortPtr    gMasterPort;    //  Singleton
 
 
static ostream &    operator << (ostream & inOutStr, const MasterPort & inObj)
{
    return inOutStr << "MasterPort instance " << hex << &inObj << dec << " portRef " << hex << inObj.GetPortRef () << dec << " " << (inObj.IsOkay () ? "OK" : "Not OK");
 
}   //  MasterPort ostream operator <<
 
 
IONotificationPortRef MasterPort::Get (void)
{
    MasterPortPtr           masterPortInstance  (GetInstance ());
    IONotificationPortRef   masterPortRef       (NULL);
 
    assert (masterPortInstance && "Must have valid MasterPort instance");
    if (masterPortInstance)
    {
        masterPortRef = *masterPortInstance;
        assert (masterPortRef && "Must have valid masterPortRef");
    }
 
    return masterPortRef;
 
}   //  Get
 
 
MasterPortPtr MasterPort::GetInstance (void)
{
    if (!gMasterPort)
        Create (gMasterPort);
 
    return gMasterPort;
 
}   //  GetInstance
 
 
bool MasterPort::Create (MasterPortPtr & outObj)
{
    outObj = NULL;
    try
    {
        outObj = gTerminating ? NULL : new MasterPort;
        if (!outObj->IsOkay ())
            outObj = NULL;
    }
    catch (std::bad_alloc)
    {
    }
    return outObj;
 
}   //  Create
 
 
MasterPort::MasterPort ()
{
    //
    //  To set up asynchronous notifications, create a notification port, then add its run loop event source to our run loop.
    //  It is not necessary to call CFRunLoopRemoveSource during teardown because that's implicitly done when the notification
    //  port is destroyed.
    //
    mpMasterPort = IONotificationPortCreate (kIOMasterPortDefault);
    if (!mpMasterPort)
    {
        cerr << "IONotificationPortCreate returned NULL" << endl;
        return;
    }
    CFRunLoopSourceRef  pRunLoopSource  (IONotificationPortGetRunLoopSource (mpMasterPort));
    if (!pRunLoopSource)
    {
        cerr << "IONotificationPortGetRunLoopSource returned NULL" << endl;
        return;
    }
    CFRunLoopAddSource (CFRunLoopGetCurrent (), pRunLoopSource, kCFRunLoopDefaultMode);
 
}   //  constructor
 
 
MasterPort::~MasterPort ()
{
    cerr << *this << " destructor" << endl;
    if (mpMasterPort)
        IONotificationPortDestroy (mpMasterPort);
    mpMasterPort = NULL;
 
}   //  destructor
 
 
class MasterPortDestroyer
{
    public:
        explicit inline MasterPortDestroyer ()      {cerr << "MasterPortDestroyer is armed" << endl;}
        virtual inline ~MasterPortDestroyer ()
        {
            cerr << "MasterPortDestroyer triggered" << endl;
            gMasterPort = NULL;
        }   //  destructor
 
    private:
        //  Do not copy!
        inline                          MasterPortDestroyer (const MasterPortDestroyer & inObj)     {if (&inObj != this) assert (false);}
        inline MasterPortDestroyer &    operator = (const MasterPortDestroyer & inRHS)              {if (&inRHS != this) assert (false); return *this;}
 
};  //  MasterPortDestroyer
 
static MasterPortDestroyer  gMasterPortDestroyer;