---

oSession.h

Go to the documentation of this file.

#ifndef D_SESSION_H
#define D_SESSION_H
//------------------------------------------------------------------------------

#include "d_Transaction.h"
#include "oNoTxContext.h"

#include "oThread.h"

//------------------------------------------------------------------------------
class oSession
{
  public:

    oSession( d_String iName );
    oSession( d_String iName, oThread::tEntry iEntryPoint, oThread::tArgument iArg, oUInt2 iFlag );
    ~oSession();

    void                  addContext( const oContext* iTrans );
    void                  removeContext( const oContext* iTrans );
    oContext*             getActiveContext() const;
    oNoTxContext*         getNoTxContext() const;

    bool                  wait();

    // Internal.
    d_Object* getPendingObject() const;
    // Internal.
    void setPendingObject( d_Object* iPending );

    // Internal.
    int getPendingEmbedded() const;
    // Internal.
    void setPendingEmbedded( int iPending );

    // FORCE THE SOFT SHUTDOWN OF SESSION
    void            forceShutdown( int iSignalCode );
    // Check if shutdown is raised. If yes throws a d_Error exception
    // with code = ?
    void            checkForShutdown();

    const char*     getName() const;
    static otThreadFunc flow( oThread::tArgument iArg );

#ifdef OMT
    oThread::tId    threadId() const;
#endif

  private:
    //--------------------------------------------------------------------------
    // ATTRIBUTES:
    //--------------------------------------------------------------------------
    d_String      name;

    oArray<oContext*>      txs;
    oContext*              activeContext;

    d_Object*              pendingObject;
    int                    pendingEmbedded;

    oThread::tEntry        entryPoint;
    oThread::tArgument     argument;

    bool                   shutdownCode; // FORCE SHUTDOWN OF SESSION ?
#ifdef OMT
    oThread*               _thread;
#endif
};
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
inline oContext* oSession::getActiveContext() const
{
  return activeContext;
}
//------------------------------------------------------------------------------
inline oNoTxContext* oSession::getNoTxContext() const
{
  // RETURNS FIRST TX THAT IS ALWAYS THE PRE-BUILT NO-TX CONTEXT
  return static_cast<oNoTxContext*>( txs[0] );
}
//------------------------------------------------------------------------------
inline const char* oSession::getName() const
{
  return name;
}
//------------------------------------------------------------------------------
#ifdef OMT
inline oThread::tId oSession::threadId() const
{
  if( _thread )
    return _thread->id();

  // NO THREAD
  return 0;
}
#endif
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------

#endif

---