vncsk.cpp

realvnc是一个非常流行的远程控制程序

#endif
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      msgsize = omni::align_to(msgsize, omni::ALIGN_2) + 2;
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      result >>= giop_s;
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "closeConnection") ) {
    
    CORBA::UShort arg_connectionId;
    
    arg_connectionId <<= giop_s;
    
    giop_s.RequestReceived();
    
    this->closeConnection(arg_connectionId);
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "getTimeSinceLastConnection") ) {
    
    giop_s.RequestReceived();
    CORBA::ULong result;
    
    result = this->getTimeSinceLastConnection();
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      msgsize = omni::align_to(msgsize, omni::ALIGN_4) + 4;
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      result >>= giop_s;
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "shutdown") ) {
    
    giop_s.RequestReceived();
    
    this->shutdown();
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "enableKeyboardDevice") ) {
    
    CORBA::UShort arg_periperalId;
    
    arg_periperalId <<= giop_s;
    
    giop_s.RequestReceived();
    
    this->enableKeyboardDevice(arg_periperalId);
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "disableKeyboardDevice") ) {
    
    CORBA::UShort arg_peripheralId;
    
    arg_peripheralId <<= giop_s;
    
    giop_s.RequestReceived();
    
    this->disableKeyboardDevice(arg_peripheralId);
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "enablePointerDevice") ) {
    
    CORBA::UShort arg_periperalId;
    
    arg_periperalId <<= giop_s;
    
    giop_s.RequestReceived();
    
    this->enablePointerDevice(arg_periperalId);
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "disablePointerDevice") ) {
    
    CORBA::UShort arg_peripheralId;
    
    arg_peripheralId <<= giop_s;
    
    giop_s.RequestReceived();
    
    this->disablePointerDevice(arg_peripheralId);
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  return 0;
}

void*
vnc::_impl_controller::_ptrToInterface(const char* id)
{
  if( !strcmp(id, CORBA::Object::_PD_repoId) )
    return (void*) 1;
  if( !strcmp(id, vnc::controller::_PD_repoId) )
    return (_impl_controller*) this;
  
  return 0;
}

const char*
vnc::_impl_controller::_mostDerivedRepoId()
{
  return vnc::controller::_PD_repoId;
}

vnc::watch_ptr vnc::watch_Helper::_nil() {
  return vnc::watch::_nil();
}

CORBA::Boolean vnc::watch_Helper::is_nil(vnc::watch_ptr p) {
  return CORBA::is_nil(p);

}

void vnc::watch_Helper::release(vnc::watch_ptr p) {
  CORBA::release(p);
}

void vnc::watch_Helper::duplicate(vnc::watch_ptr p) {
  if( p && !p->_NP_is_nil() )  omni::duplicateObjRef(p);
}

size_t vnc::watch_Helper::NP_alignedSize(vnc::watch_ptr obj, size_t offset) {
  return vnc::watch::_alignedSize(obj, offset);
}

void vnc::watch_Helper::marshalObjRef(vnc::watch_ptr obj, NetBufferedStream& s) {
  vnc::watch::_marshalObjRef(obj, s);
}

vnc::watch_ptr vnc::watch_Helper::unmarshalObjRef(NetBufferedStream& s) {
  return vnc::watch::_unmarshalObjRef(s);
}

void vnc::watch_Helper::marshalObjRef(vnc::watch_ptr obj, MemBufferedStream& s) {
  vnc::watch::_marshalObjRef(obj, s);
}

vnc::watch_ptr vnc::watch_Helper::unmarshalObjRef(MemBufferedStream& s) {
  return vnc::watch::_unmarshalObjRef(s);
}

vnc::watch_ptr
vnc::watch::_duplicate(vnc::watch_ptr obj)
{
  if( obj && !obj->_NP_is_nil() )  omni::duplicateObjRef(obj);

  return obj;
}

vnc::watch_ptr
vnc::watch::_narrow(CORBA::Object_ptr obj)
{
  if( !obj || obj->_NP_is_nil() || obj->_NP_is_pseudo() ) return _nil();
  _ptr_type e = (_ptr_type) obj->_PR_getobj()->_realNarrow(_PD_repoId);
  return e ? e : _nil();
}

vnc::watch_ptr
vnc::watch::_nil()
{
  static _objref_watch* _the_nil_ptr = 0;
  if( !_the_nil_ptr ) {
    omni::nilRefLock().lock();
  if( !_the_nil_ptr )  _the_nil_ptr = new _objref_watch;
    omni::nilRefLock().unlock();
  }
  return _the_nil_ptr;
}

const char* vnc::watch::_PD_repoId = "IDL:vnc/watch:1.0";

vnc::_objref_watch::~_objref_watch() {}

vnc::_objref_watch::_objref_watch(const char* mdri,
   IOP::TaggedProfileList* p, omniIdentity* id, omniLocalIdentity* lid) :
   
   omniObjRef(vnc::watch::_PD_repoId, mdri, p, id, lid)
{
  _PR_setobj(this);
}

void*
vnc::_objref_watch::_ptrToObjRef(const char* id)
{
  if( !strcmp(id, CORBA::Object::_PD_repoId) )
    return (CORBA::Object_ptr) this;
  if( !strcmp(id, vnc::watch::_PD_repoId) )
    return (vnc::watch_ptr) this;
  
  return 0;
}

// Proxy call descriptor class. Mangled signature:
//  _cstring
class _0RL_cd_22cbff1b827fd898_21000000
  : public omniCallDescriptor
{
public:
  inline _0RL_cd_22cbff1b827fd898_21000000(LocalCallFn lcfn, const char* op, size_t oplen, _CORBA_Boolean oneway):
     omniCallDescriptor(lcfn, op, oplen, oneway) {}

  virtual void unmarshalReturnedValues(GIOP_C&);
    
  inline char * result() { return pd_result; }
  
  char * pd_result;
};

void _0RL_cd_22cbff1b827fd898_21000000::unmarshalReturnedValues(GIOP_C& giop_client)
{
  
  {
    CORBA::String_member _0RL_str_tmp;
    _0RL_str_tmp <<=  giop_client;
    pd_result = _0RL_str_tmp._ptr;
    _0RL_str_tmp._ptr = 0;
  }
  
}

// Local call call-back function.
static void
_0RL_lcfn_22cbff1b827fd898_31000000(omniCallDescriptor* cd, omniServant* svnt)
{
  _0RL_cd_22cbff1b827fd898_21000000* tcd = (_0RL_cd_22cbff1b827fd898_21000000*) cd;
  vnc::_impl_watch* impl = (vnc::_impl_watch*) svnt->_ptrToInterface(vnc::watch::_PD_repoId);
  tcd->pd_result = impl->getHost();
}

char* vnc::_objref_watch::getHost()
{
  _0RL_cd_22cbff1b827fd898_21000000 _call_desc(_0RL_lcfn_22cbff1b827fd898_31000000, "getHost", 8, 0);
  
  _invoke(_call_desc);
  return _call_desc.result();
}

// Local call call-back function.
static void
_0RL_lcfn_22cbff1b827fd898_41000000(omniCallDescriptor* cd, omniServant* svnt)
{
  
  vnc::_impl_watch* impl = (vnc::_impl_watch*) svnt->_ptrToInterface(vnc::watch::_PD_repoId);
  impl->shutdown();
}

void vnc::_objref_watch::shutdown()
{
  omniStdCallDesc::void_call _call_desc(_0RL_lcfn_22cbff1b827fd898_41000000, "shutdown", 9, 1/*oneway*/);
  
  _invoke(_call_desc);
  
}

vnc::_pof_watch::~_pof_watch() {}

omniObjRef*
vnc::_pof_watch::newObjRef(const char* mdri, IOP::TaggedProfileList* p,
               omniIdentity* id, omniLocalIdentity* lid)
{
  return new vnc::_objref_watch(mdri, p, id, lid);
}

CORBA::Boolean
vnc::_pof_watch::is_a(const char* id) const
{
  if( !strcmp(id, vnc::watch::_PD_repoId) )
    return 1;
  
  return 0;
}

const vnc::_pof_watch _the_pof_vnc_mwatch;

vnc::_impl_watch::~_impl_watch() {}

CORBA::Boolean
vnc::_impl_watch::_dispatch(GIOP_S& giop_s)
{
  if( !strcmp(giop_s.operation(), "getHost") ) {
    
    giop_s.RequestReceived();
    CORBA::String_var result;
    
    result = this->getHost();
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      msgsize = omni::align_to(msgsize, omni::ALIGN_4) + 4;
      msgsize += ((const char*) result) ? strlen((const char*) result) + 1 : 1;
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      {
        CORBA::ULong _len = (((const char*) result)? strlen((const char*) result) + 1 : 1);
        
        _len >>= giop_s;
        if (_len > 1)
          giop_s.put_char_array((const CORBA::Char *)((const char*)result),_len);
        else {
          if ((const char*) result == 0 && omniORB::traceLevel > 1)
            _CORBA_null_string_ptr(0);
          CORBA::Char('\0') >>= giop_s;
        }
      }
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  if( !strcmp(giop_s.operation(), "shutdown") ) {
    
    giop_s.RequestReceived();
    
    this->shutdown();
    
    if( giop_s.response_expected() ) {
      size_t msgsize = (size_t) GIOP_S::ReplyHeaderSize();
      
      giop_s.InitialiseReply(GIOP::NO_EXCEPTION, (CORBA::ULong) msgsize);
      
    }
    giop_s.ReplyCompleted();
    return 1;
  }

  return 0;
}

void*
vnc::_impl_watch::_ptrToInterface(const char* id)
{
  if( !strcmp(id, CORBA::Object::_PD_repoId) )
    return (void*) 1;
  if( !strcmp(id, vnc::watch::_PD_repoId) )
    return (_impl_watch*) this;
  
  return 0;
}

const char*
vnc::_impl_watch::_mostDerivedRepoId()
{
  return vnc::watch::_PD_repoId;
}

POA_vnc::controller::~controller() {}

POA_vnc::watch::~watch() {}