RCF - Interprocess Communication for C++

//*****************************************************************************
// RCF - Remote Call Framework
// Copyright (c) 2005. All rights reserved.
// Developed by Jarl Lindrud.
// Contact: jlindrud@hotmail.com .
//*****************************************************************************

#include <RCF/StubEntry.hpp>

#include <time.h>

namespace RCF {

    //class StubEntry;

    typedef boost::shared_ptr<StubEntry> StubEntryPtr;

    // time in s since ca 1970, may fail after year 2038
    inline unsigned int getCurrentTimeS() 
    { 
        return static_cast<unsigned int>(time(NULL)); 
    }

    StubEntry::StubEntry() : mConnectionCount(), mTimeStamp() 
    {}

    RcfClientPtr StubEntry::getRcfClientPtr() 
    { 
        return mRcfClientPtr; 
    }
    
    void StubEntry::setRcfClientPtr(RcfClientPtr rcfClientPtr) 
    { 
        mRcfClientPtr = rcfClientPtr; 
    }

    unsigned int StubEntry::getConnectionCount() 
    { 
        return mConnectionCount; 
    }
    
    void StubEntry::setConnectionCount(unsigned int connectionCount) 
    { 
        mConnectionCount = connectionCount; 
    }

    unsigned int StubEntry::incrementConnectionCount() 
    { 
        return ++mConnectionCount; 
    }
    
    unsigned int StubEntry::decrementConnectionCount() 
    { 
        return --mConnectionCount; 
    }

    void StubEntry::touch()
    {
        mTimeStamp = getCurrentTimeS();
    }

    unsigned int StubEntry::getElapsedTimeS()
    {
        if (mTimeStamp == 0)
        {
            return 0;
        }
        else
        {
            unsigned int currentTimeS = getCurrentTimeS();
            return currentTimeS > mTimeStamp ?
                currentTimeS - mTimeStamp :
            mTimeStamp - currentTimeS;
        }
    }

    void StubEntry::clear()
    {
        mRcfClientPtr.reset();
        mTimeStamp = 0;
    }

    Mutex &StubEntry::getMutex() 
    { 
        return mMutex; 
    }


    StubEntryAddRef::StubEntryAddRef() 
    {}

    StubEntryAddRef::~StubEntryAddRef() 
    {
        if (mStubEntryPtr)
        {
            Lock lock(mStubEntryPtr->getMutex());
            mStubEntryPtr->decrementConnectionCount();
        }
    }

    void StubEntryAddRef::operator()(StubEntryPtr stubEntryPtr)
    {
        if (mStubEntryPtr != stubEntryPtr)
        {
            if (mStubEntryPtr) 
            {
                Lock lock(mStubEntryPtr->getMutex());
                mStubEntryPtr->decrementConnectionCount();
                mStubEntryPtr->touch();
            }

            mStubEntryPtr = stubEntryPtr; 

            if (mStubEntryPtr) 
            {
                Lock lock(mStubEntryPtr->getMutex());
                mStubEntryPtr->incrementConnectionCount();
                mStubEntryPtr->touch();
            }
        }
    }

} // namespace RCF