org.omg.CORBA.portable.InputStream类的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(167)

本文整理了Java中org.omg.CORBA.portable.InputStream类的一些代码示例，展示了InputStream类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。InputStream类的具体详情如下：
包路径：org.omg.CORBA.portable.InputStream
类名称：InputStream

InputStream介绍

暂无

代码示例

代码示例来源：origin: org.jacorb/jacorb-services

public static org.omg.CosTrading.RegisterPackage.InterfaceTypeMismatch read (final org.omg.CORBA.portable.InputStream in)
{
  String id = in.read_string();
  if (!id.equals(id())) throw new org.omg.CORBA.MARSHAL("wrong id: " + id);
  java.lang.String x0;
  x0=in.read_string();
  org.omg.CORBA.Object x1;
  x1=in.read_Object();
  final org.omg.CosTrading.RegisterPackage.InterfaceTypeMismatch result = new org.omg.CosTrading.RegisterPackage.InterfaceTypeMismatch(id, x0, x1);
  return result;
}
public static void write (final org.omg.CORBA.portable.OutputStream out, final org.omg.CosTrading.RegisterPackage.InterfaceTypeMismatch s)

代码示例来源：origin: org.jboss.spec.javax.rmi/jboss-rmi-api_1.0_spec

public void read(org.omg.CORBA.portable.InputStream istream)
{
  super.read(istream);
  this.service_contexts = new ServiceContexts((org.omg.CORBA_2_3.portable.InputStream) istream);
  this.request_id = istream.read_ulong();
  this.response_expected = istream.read_boolean();
  int _len0 = istream.read_long();
  this.object_key = new byte[_len0];
  istream.read_octet_array(this.object_key, 0, _len0);
  this.operation = istream.read_string();
  this.requesting_principal = istream.read_Principal();
}

代码示例来源：origin: org.jacorb/jacorb-services

public static org.omg.TimeBase.UtcT read (final org.omg.CORBA.portable.InputStream in)
{
  org.omg.TimeBase.UtcT result = new org.omg.TimeBase.UtcT();
  result.time=in.read_ulonglong();
  result.inacclo=in.read_ulong();
  result.inacchi=in.read_ushort();
  result.tdf=in.read_short();
  return result;
}
public static void write (final org.omg.CORBA.portable.OutputStream out, final org.omg.TimeBase.UtcT s)

代码示例来源：origin: org.eclipse.persistence/org.eclipse.persistence.core

@Override
public java.io.Serializable read_value(org.omg.CORBA.portable.InputStream istream) {
  byte[] tmp;
  int _len0 = istream.read_long();
  tmp = new byte[_len0];
  istream.read_octet_array(tmp, 0, _len0);
  return tmp;
}

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public void
_read(org.omg.CORBA.portable.InputStream in)
{
  is_system_exception = in.read_boolean();
  byte_order = in.read_boolean();
  int len0 = in.read_ulong();
  marshaled_exception = new byte[len0];
  in.read_octet_array(marshaled_exception, 0, len0);
}

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public static org.omg.CORBA.Any[]
read(org.omg.CORBA.portable.InputStream in)
{
  org.omg.CORBA.Any[] _ob_v;
  int len0 = in.read_ulong();
  _ob_v = new org.omg.CORBA.Any[len0];
  for(int i0 = 0; i0 < len0; i0++)
    _ob_v[i0] = in.read_any();
  return _ob_v;
}

代码示例来源：origin: jboss.jbossts/jbossjts

_os.write_string(name);
  _os.write_long(rmid);
  _os.write_ulong(flags);
  _is = _invoke(_os);
  int _result = _is.read_long();
  return _result;
catch( org.omg.CORBA.portable.ApplicationException _ax )
  String _id = _ax.getId();
  throw new RuntimeException("Unexpected exception " + _id );
  throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
XASwitchOperations _localServant = (XASwitchOperations)_so.servant;
int _result;

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public boolean refresh (org.omg.CORBA.Any refresh_data)
{
     org.omg.CORBA.portable.InputStream $in = null;
     try {
       org.omg.CORBA.portable.OutputStream $out = _request ("refresh", true);
       $out.write_any (refresh_data);
       $in = _invoke ($out);
       boolean $result = $in.read_boolean ();
       return $result;
     } catch (org.omg.CORBA.portable.ApplicationException $ex) {
       $in = $ex.getInputStream ();
       String _id = $ex.getId ();
       throw new org.omg.CORBA.MARSHAL (_id);
     } catch (org.omg.CORBA.portable.RemarshalException $rm) {
       return refresh (refresh_data        );
     } finally {
       _releaseReply ($in);
     }
} // refresh

代码示例来源：origin: jbosstm/narayana

public int xa_close (String name, int rmid, int flags)
{
     org.omg.CORBA.portable.InputStream $in = null;
     try {
       org.omg.CORBA.portable.OutputStream $out = _request ("xa_close", true);
       $out.write_string (name);
       $out.write_long (rmid);
       $out.write_ulong (flags);
       $in = _invoke ($out);
       int $result = $in.read_long ();
       return $result;
     } catch (org.omg.CORBA.portable.ApplicationException $ex) {
       $in = $ex.getInputStream ();
       String _id = $ex.getId ();
       throw new org.omg.CORBA.MARSHAL (_id);
     } catch (org.omg.CORBA.portable.RemarshalException $rm) {
       return xa_close (name, rmid, flags        );
     } finally {
       _releaseReply ($in);
     }
} // xa_close

代码示例来源：origin: jboss.jbossts/jbossjts

org.omg.CosTransactions.CoordinatorHelper.write(_os,tc);
  _is = _invoke(_os);
  boolean _result = _is.read_boolean();
  return _result;
catch( org.omg.CORBA.portable.ApplicationException _ax )
  String _id = _ax.getId();
  throw new RuntimeException("Unexpected exception " + _id );
  throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
CoordinatorOperations _localServant = (CoordinatorOperations)_so.servant;
boolean _result;

代码示例来源：origin: itesla/ipst

public String sendClass(String model) {
  org.omg.CORBA.portable.InputStream $in = null;
  try {
    org.omg.CORBA.portable.OutputStream $out = _request("sendClass", true);
    $out.write_string(model);
    $in = _invoke($out);
    String $result = $in.read_string();
    return $result;
  } catch (org.omg.CORBA.portable.ApplicationException $ex) {
    $in = $ex.getInputStream();
    String _id = $ex.getId();
    throw new org.omg.CORBA.MARSHAL(_id);
  } catch (org.omg.CORBA.portable.RemarshalException $rm) {
    return sendClass(model);
  } finally {
    _releaseReply($in);
  }
} // sendClass

代码示例来源：origin: jbosstm/narayana

public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
  throws org.omg.CORBA.SystemException
{
  org.omg.CORBA.portable.OutputStream _out = null;
  // do something
  // quick lookup of operation
  java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
  if ( null == opsIndex )
    throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
  switch ( opsIndex.intValue() )
  {
    case 0: // register_before_completion_callback
    {
      org.omg.XA.BeforeCompletionCallback _arg0=org.omg.XA.BeforeCompletionCallbackHelper.read(_input);
      _out = handler.createReply();
      _out.write_ulong(register_before_completion_callback(_arg0));
      break;
    }
    case 1: // unregister_before_completion_callback
    {
      int _arg0=_input.read_ulong();
      _out = handler.createReply();
      unregister_before_completion_callback(_arg0);
      break;
    }
  }
  return _out;
}

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public static BAD_TYPECODE read(org.omg.CORBA.portable.InputStream in) {
  if (!id().equals(in.read_string()))
    throw new MARSHAL();
  BAD_TYPECODE val = new BAD_TYPECODE();
  val.minor = in.read_ulong();
  val.completed = CompletionStatus.from_int(in.read_ulong());
  return val;
}

代码示例来源：origin: org.apache.yoko/yoko-spec-corba

public static UNKNOWN read(org.omg.CORBA.portable.InputStream in) {
  if (!id().equals(in.read_string()))
    throw new MARSHAL();
  UNKNOWN val = new UNKNOWN();
  val.minor = in.read_ulong();
  val.completed = CompletionStatus.from_int(in.read_ulong());
  return val;
}

代码示例来源：origin: org.fudaa.business/dodico-corba

public long dateConnexion ()
{
     org.omg.CORBA.portable.InputStream $in = null;
     try {
       org.omg.CORBA.portable.OutputStream $out = _request ("dateConnexion", true);
       $in = _invoke ($out);
       long $result = $in.read_longlong ();
       return $result;
     } catch (org.omg.CORBA.portable.ApplicationException $ex) {
       $in = $ex.getInputStream ();
       String _id = $ex.getId ();
       throw new org.omg.CORBA.MARSHAL (_id);
     } catch (org.omg.CORBA.portable.RemarshalException $rm) {
       return dateConnexion (        );
     } finally {
       _releaseReply ($in);
     }
} // dateConnexion

代码示例来源：origin: org.jacorb/jacorb-omgapi

public static org.omg.CORBA.UnknownUserException read (final org.omg.CORBA.portable.InputStream in)
{
  String id = in.read_string();
  if (!id.equals(id())) throw new org.omg.CORBA.MARSHAL("wrong id: " + id);
  org.omg.CORBA.Any x0;
  x0=in.read_any();
  final org.omg.CORBA.UnknownUserException result = new org.omg.CORBA.UnknownUserException(id, x0);
  return result;
}
public static void write (final org.omg.CORBA.portable.OutputStream out, final org.omg.CORBA.UnknownUserException s)

代码示例来源：origin: org.mobicents.resources/parlay-provider-api

public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
  throws org.omg.CORBA.SystemException
{
  org.omg.CORBA.portable.OutputStream _out = null;
  // do something
  // quick lookup of operation
  java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
  if ( null == opsIndex )
    throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
  switch ( opsIndex.intValue() )
  {
    case 0: // systemDateTimeQuery
    {
      java.lang.String _arg0=_input.read_string();
      _out = handler.createReply();
      _out.write_string(systemDateTimeQuery(_arg0));
      break;
    }
  }
  return _out;
}

代码示例来源：origin: org.jacorb/jacorb-services

public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
  throws org.omg.CORBA.SystemException
{
  org.omg.CORBA.portable.OutputStream _out = null;
  // do something
  // quick lookup of operation
  java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
  if ( null == opsIndex )
    throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
  switch ( opsIndex.intValue() )
  {
    case 0: // set_trigger_value
    {
      boolean _arg0=_input.read_boolean();
      _out = handler.createReply();
      set_trigger_value(_arg0);
      break;
    }
    case 1: // get_trigger_value
    {
      _out = handler.createReply();
      _out.write_boolean(get_trigger_value());
      break;
    }
  }
  return _out;
}

代码示例来源：origin: org.jacorb/jacorb-services

public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
  throws org.omg.CORBA.SystemException
{
  org.omg.CORBA.portable.OutputStream _out = null;
  // do something
  // quick lookup of operation
  java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
  if ( null == opsIndex )
    throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
  switch ( opsIndex.intValue() )
  {
    case 0: // compare
    {
      org.omg.CORBA.Any _arg0=_input.read_any();
      org.omg.CORBA.Any _arg1=_input.read_any();
      _out = handler.createReply();
      _out.write_long(compare(_arg0,_arg1));
      break;
    }
  }
  return _out;
}

代码示例来源：origin: org.jacorb/jacorb

public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
  throws org.omg.CORBA.SystemException
{
  org.omg.CORBA.portable.OutputStream _out = null;
  // do something
  // quick lookup of operation
  java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
  if ( null == opsIndex )
    throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
  switch ( opsIndex.intValue() )
  {
    case 0: // next_n
    {
      int _arg0=_input.read_ulong();
      org.jacorb.tao_imr.ImplementationRepository.ServerInformationListHolder _arg1= new org.jacorb.tao_imr.ImplementationRepository.ServerInformationListHolder();
      _out = handler.createReply();
      _out.write_boolean(next_n(_arg0,_arg1));
      org.jacorb.tao_imr.ImplementationRepository.ServerInformationListHelper.write(_out,_arg1.value);
      break;
    }
    case 1: // destroy
    {
      _out = handler.createReply();
      destroy();
      break;
    }
  }
  return _out;
}

内容来源于网络，如有侵权，请联系作者删除！

InputStream

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    InputStream类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com