drserver_impl.h

oracle下调用数据泵接口进行远程数据导出和导入（数据恢复）的CORBA服务

//      DRServer_impl.h
//      北京本地数据恢复服务接口的生产工厂
//
#ifndef  __DRServer_h__
#define  __DRServer_h__

#include <STAR/CORBA.h>
#include <MTL/MTL.h>
#include <predefine.h>


#include <DataRecovery.h>
#include <DataRecovery_skel.h>
#include "DataRecovery_impl.h"

#include <TimeOutThread.h>

#include <RequestCounter_impl.h>
#include <levelcontrol_impl.h>

//
// Interface declare ::IDRecoveryServer
//
class IDRecoveryServer_impl :
					MultiMutex,
					public POA_IDRecoveryServer,
					public PortableServer::RefCountServantBase
{
	RequestCounter_impl* m_requestCounter;
	ILevelControl_impl*  m_levelControl;
	//POA
	PortableServer::POA_var m_poa; 

	//出错信息
	CORBA::String_var m_ErrMsg;
	//DataQuery中的错误信息
	CORBA::String_var m_OCIErrMsg;
	TimeOutThreadHandle m_TimeThread;

	CORBA::String_var m_strLogFileName;
	ATF::Current_var m_current; //得到客户方通讯端口

public:

    IDRecoveryServer_impl(PortableServer::POA_ptr poa, ATF::Current_ptr current);
    ~IDRecoveryServer_impl();
    
    TimeOutThreadHandle getTimeOutThread()
    {
    	return 	m_TimeThread;
    }    
    //
    // Operation declare strErrorMessage
    //
    virtual char* strErrorMessage(CORBA::Short nErrorId)
        throw(CORBA::SystemException);

    //
    // Operation declare ResConnect
    //
    virtual DataRecovery_ptr ResGet(const char* strClientID,
                                       CORBA::Short timeOut)
        throw(CORBA::SystemException);
        	
    //
    // Attribute declare nRunLevel
    //
    virtual CORBA::Short nRunLevel()
        throw(CORBA::SystemException);
    virtual void nRunLevel(CORBA::Short rlevel)
        throw(CORBA::SystemException);

    //
    // Attribute declare nTraceLevel
    //
    virtual CORBA::Short nTraceLevel()
        throw(CORBA::SystemException);
        
    virtual void nTraceLevel(CORBA::Short tlevel)
        throw(CORBA::SystemException);

    // Attribute declare lRequestCount
    //
    virtual CORBA::ULongLong lRequestCount()
        throw(CORBA::SystemException);

        
    //
    // Operation declare vReset
    //
    virtual void vReset()
        throw(CORBA::SystemException);
        	
        	        	
        	        	
};

#endif