RCF - Interprocess Communication for C++

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

#ifndef INCLUDE_RCF_SESSION_HPP
#define INCLUDE_RCF_SESSION_HPP

#include <vector>

#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>

#include <RCF/MethodInvocation.hpp>
#include <RCF/SerializationProtocol.hpp>
#include <RCF/ServerTransport.hpp>
#include <RCF/StubEntry.hpp>

namespace RCF {

    // TODO: use this more extensively?
    template<typename T>
    class DefaultInitialized
    {
    public:
        DefaultInitialized() : mValue()
        {}

        T operator=(T value)
        {
            mValue = value;
            return mValue;
        }

        operator T()
        {
            return mValue;
        }
    private:
        T mValue;
    };

    typedef DefaultInitialized<bool> Bool;
    typedef DefaultInitialized<int> Int;

    class Filter;

    typedef boost::shared_ptr<Filter> FilterPtr;

    class Session;

    typedef boost::shared_ptr<Session> SessionPtr;

    class Session : public I_Session
    {
    public:
        Session();
        StubEntryAddRef &getStubEntryAddRef();
        MethodInvocationRequest &getRequest();
        typedef boost::function1<void, Session&> OnWriteCompletedCallback;
        void setOnWriteCompletedCallback(OnWriteCompletedCallback onWriteCompletedCallback);
        void onWriteCompleted();
        const RCF::I_RemoteAddress &getRemoteAddress();
        bool hasServerStub();
        StubEntryPtr getStubEntryPtr();
        void setStubEntryPtr(StubEntryPtr stubEntryPtr);

        // protocol-opaque serialization
        SerializationProtocolIn in;
        SerializationProtocolOut out;

        // payload filters
        std::vector<FilterPtr> filters;
        Bool filtered;

        /// Enables pointer tracking for outbound SF serialization on this session.
        /// \parameter Whether to enable or not.
        void enableSfSerializationPointerTracking(bool enable);

    private:
        StubEntryAddRef stubEntryAddRef;
        MethodInvocationRequest request;
        OnWriteCompletedCallback onWriteCompletedCallback;
        StubEntryPtr stubEntryPtr; // session-specific server stub, e.g. for a subscription session
    };

} // namespace RCF

#endif // ! INCLUDE_RCF_SESSION_HPP