myvtm/Module/mod_recorder/Recorder_server_g.h

#ifndef __RECORDER_SERVER_G_H
#define __RECORDER_SERVER_G_H

#pragma once

// This code is generated by spgen tool!

#include "Recorder_def_g.h"

namespace Recorder
{
class RecorderSerVice_ServerSessionBase : public CServerSessionBase
{
public:
    RecorderSerVice_ServerSessionBase()
    {
        /// override by user
    }

    virtual ~RecorderSerVice_ServerSessionBase()
    {
        /// override by user
    }

    virtual bool IsExclusive() { return false; }

    virtual bool IsSessionOverlap() { return true; }

    virtual ErrorCodeEnum GetMessageAttr(DWORD dwMessageID, DWORD dwSignature, bool& bOverlap)
    {
        ErrorCodeEnum Error = Error_Succeed;
        switch (dwMessageID) {
        case RecorderSerVice_Method_StartTransactionRecord:
            if (dwSignature == RecorderSerVice_MethodSignature_StartTransactionRecord) {
                bOverlap = true;
            } else {
                Error = Error_MethodSignatureFailed;
            }
            break;
        case RecorderSerVice_Method_StopTransactionRecord:
            if (dwSignature == RecorderSerVice_MethodSignature_StopTransactionRecord) {
                bOverlap = true;
            } else {
                Error = Error_MethodSignatureFailed;
            }
            break;
        default:
            Error = Error_MethodNotFound;
            break;
        }
        return Error;
    }

    int CheckMessageSignature(DWORD dwMessageID, DWORD dwSignature)
    {
        ErrorCodeEnum Error = Error_Succeed;
        switch (dwMessageID) {
        case RecorderSerVice_Method_StartTransactionRecord:
            if (dwSignature != RecorderSerVice_MethodSignature_StartTransactionRecord) {
                Error = Error_MethodSignatureFailed;
            }
            break;
        case RecorderSerVice_Method_StopTransactionRecord:
            if (dwSignature != RecorderSerVice_MethodSignature_StopTransactionRecord) {
                Error = Error_MethodSignatureFailed;
            }
            break;
        default:
            Error = Error_MethodNotFound;
            break;
        }
        return Error;
    }

    virtual void Handle_StartTransactionRecord(SpReqAnsContext<RecorderSerVice_StartTransactionRecord_Req, RecorderSerVice_StartTransactionRecord_Ans>::Pointer ctx)
    {
        /// override by user
    }

    virtual void Handle_StopTransactionRecord(SpReqAnsContext<RecorderSerVice_StopTransactionRecord_Req, RecorderSerVice_StopTransactionRecord_Ans>::Pointer ctx)
    {
        /// override by user
    }

    virtual void OnRequest(CSmartPointer<ITransactionContext> pTransactionContext)
    {
        CAutoBuffer Buf;
        DWORD dwMessageID;
        DWORD dwMessageSignature;
        ErrorCodeEnum Error = pTransactionContext->GetReceiveBuffer(dwMessageID, dwMessageSignature, Buf);
        if (Error == Error_Succeed) {
#ifdef DEBUG
            assert(CheckMessageSignature(dwMessageID, dwMessageSignature) == Error_Succeed);
#else
            if (CheckMessageSignature(dwMessageID, dwMessageSignature) != Error_Succeed) {
                pTransactionContext->SendAnswer(Error_MethodSignatureFailed);
                return;
            }
#endif
            switch (dwMessageID) {
            case RecorderSerVice_Method_StartTransactionRecord:
            {
                SpReqAnsContext<RecorderSerVice_StartTransactionRecord_Req, RecorderSerVice_StartTransactionRecord_Ans>::Pointer ctx;
                ctx.Attach(new SpReqAnsContext<RecorderSerVice_StartTransactionRecord_Req, RecorderSerVice_StartTransactionRecord_Ans>(pTransactionContext));
                SpBuffer2Object(Buf, ctx->Req);
                pTransactionContext->GetLinkContext(ctx->link);
                Handle_StartTransactionRecord(ctx);
            }
            break;
            case RecorderSerVice_Method_StopTransactionRecord:
            {
                SpReqAnsContext<RecorderSerVice_StopTransactionRecord_Req, RecorderSerVice_StopTransactionRecord_Ans>::Pointer ctx;
                ctx.Attach(new SpReqAnsContext<RecorderSerVice_StopTransactionRecord_Req, RecorderSerVice_StopTransactionRecord_Ans>(pTransactionContext));
                SpBuffer2Object(Buf, ctx->Req);
                pTransactionContext->GetLinkContext(ctx->link);
                Handle_StopTransactionRecord(ctx);
            }
            break;
            default:
                assert(0);
                break;
            }

        } else {
            pTransactionContext->SendAnswer(Error);
        }
    }

};


///////////////////////////

} // namespace Recorder
#endif // __RECORDER_SERVER_G_H