ft_eventservice.h

来自「这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用」· C头文件 代码 · 共 53 行

// -*- C++ -*-

//=============================================================================
/**
 *  @file   FT_EventService.h
 *
 *  FT_EventService.h,v 1.5 2003/12/30 12:42:40 jwillemsen Exp
 *
 *  @author Huang-Ming Huang <[e-mail]>
 */
//=============================================================================
#ifndef FT_EVENTSERVICE_H
#define FT_EVENTSERVICE_H

#include "orbsvcs/CosNamingC.h"
#include "orbsvcs/FtRtecEventChannelAdminC.h"
#include "orbsvcs/FtRtEvent/EventChannel/FTEC_Event_Channel.h"
#include "orbsvcs/FtRtEvent/EventChannel/FTEC_Become_Primary_Listener.h"
#include "TP_Task.h"

namespace POA_RtecScheduler
{
    class Scheduler;
}

class FT_EventService : private TAO_FTEC_Become_Primary_Listener
{
public:
  FT_EventService();
  ~FT_EventService();

  int run(int argc, ACE_TCHAR* argv[]);

private:
  int parse_args (int argc, ACE_TCHAR* argv []);
  void setup_scheduler(CosNaming::NamingContext_ptr naming_context
                                        ACE_ENV_ARG_DECL);
  int report_factory(CORBA::ORB_ptr orb,
                   FtRtecEventChannelAdmin::EventChannel_ptr ec);
  virtual void become_primary();

  int global_scheduler_;
  // Should we use a global scheduler or a local one?
  POA_RtecScheduler::Scheduler *sched_impl_;
  // The Scheduler implementation.
  TAO_FTEC_Event_Channel::MEMBERSHIP membership_;
  int num_threads_;
  CORBA::ORB_var orb_;
  TP_Task task_;
};

#endif