org.omg.CORBA.Any.write_value()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(6.3k)|赞(0)|评价(0)|浏览(105)

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

Any.write_value介绍

暂无

代码示例

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

protected void writeAny(OutputStream out) {
  //System.out.println(this + " writeAny of type " + type().kind().value());
  any.write_value(out);
}

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

public final void write_any(Any any) {
  if (any == null) {
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  }
  write_TypeCode(any.type());
  any.write_value(parent);
}

代码示例来源:origin: org.apache.yoko/yoko-core

public void setUserException(org.omg.CORBA.Any any) {
  if (upcallReturn_ != null) {
    org.omg.IOP.ServiceContext[] scl = new org.omg.IOP.ServiceContext[replySCL_
        .size()];
    replySCL_.copyInto(scl);
    upcallReturn_.upcallBeginUserException(this, scl);
    try {
      any.write_value(out_);
    } catch (org.omg.CORBA.SystemException ex) {
      try {
        marshalEx(ex);
      } catch (LocationForward f) {
        Assert._OB_assert(ex); // shouldn't happen
      }
    }
    //
    // In Java, we must delay the call to upcallEndUserException
    //
    // upcallReturn_.upcallEndUserException(this);
    userEx_ = true;
  }
}

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

@Override
public final void write_any(final org.omg.CORBA.Any value)
{
  if( value == null )
  {
    throw new MARSHAL("Cannot marshall null value.");
  }
  write_TypeCode( value.type() );
  value.write_value( this ) ;
}

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

public final void write_any(Any any)
{
  if (any == null)
  {
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  }
  write_TypeCode(any.type());
  any.write_value(parent);
}

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

public void write_any(Any any)
{
  if (any == null)
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  write_TypeCode(any.type());
  any.write_value(parent);
}

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

public void write_any(Any any)
{
  if ( any == null )
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  write_TypeCode(any.type());
  any.write_value(parent);
}

代码示例来源:origin: org.apache.yoko/yoko-core

public void write_any(org.omg.CORBA.Any value) {
  logger.finest("Writing an ANY value of type " + value.type().kind()); 
  write_TypeCode(value.type());
  value.write_value(this);
}

代码示例来源:origin: jboss/jboss-javaee-specs

public void write_any(Any any)
{
  if (any == null)
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  write_TypeCode(any.type());
  any.write_value(parent);
}

代码示例来源:origin: jboss/jboss-javaee-specs

public final void write_any(Any any)
{
  if (any == null)
  {
    throw wrapper.nullParam(CompletionStatus.COMPLETED_MAYBE);
  }
  write_TypeCode(any.type());
  any.write_value(parent);
}

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

/** This is called from the ORB after the DynamicImplementation.invoke
 *  returns. Here we marshal the return value and inout/out params.
 */
public void marshalReplyParams(OutputStream os)
{
  // marshal the operation return value
  _resultAny.write_value(os);
  // marshal the inouts/outs
  NamedValue arg = null;
  for (int i=0; i < _arguments.count() ; i++) {
    try {
      arg = _arguments.item(i);
    } catch (Bounds e) {}
    if ((arg.flags() == org.omg.CORBA.ARG_OUT.value) ||
      (arg.flags() == org.omg.CORBA.ARG_INOUT.value)) {
      arg.value().write_value(os);
    }
  }
}

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

public byte[] encode_value(Any data)
    throws InvalidTypeForEncoding
  {
    final CDROutputStream out = new CDROutputStream(orb);

    try
    {

      out.beginEncapsulatedArray();
      data.write_value(out);

      // do not end encapsulation since it will patch the
      // array with a size!

      return  out.getBufferCopy();
    }
    finally
    {
      out.close();
    }
  }
}

代码示例来源:origin: org.apache.yoko/yoko-core

public byte[] encode_value(org.omg.CORBA.Any data) {
  org.apache.yoko.orb.OCI.Buffer buf = new org.apache.yoko.orb.OCI.Buffer();
  org.apache.yoko.orb.CORBA.OutputStream out = new org.apache.yoko.orb.CORBA.OutputStream(
      buf);
  out._OB_ORBInstance(orbInstance_);
  out._OB_writeEndian();
  data.write_value(out);
  byte[] result = new byte[buf.length()];
  System.arraycopy(buf.data(), 0, result, 0, buf.length());
  return result;
}

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

private boolean compareComplexValue(org.omg.CORBA.Any other)
  {
    final CDROutputStream thisStream;
    if (value instanceof CDROutputStream)
    {
      thisStream = (CDROutputStream)value;
    }
    else
    {
      thisStream = new CDROutputStream(orb);
      write_value(thisStream);
    }

    final CDROutputStream otherStream;
    if (other instanceof Any &&
      ((Any) other).value instanceof CDROutputStream)
    {
      otherStream = (CDROutputStream) ((Any) other).value;
    }
    else
    {
      otherStream = new CDROutputStream(orb);
      other.write_value( otherStream );
    }

    return Arrays.equals( thisStream.getBufferCopy(),
               otherStream.getBufferCopy());
  }
}

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

protected boolean initializeAnyFromComponents() {
  //System.out.println(this + " initializeAnyFromComponents");
  OutputStream out = any.create_output_stream();
  for (int i=0; i<components.length; i++) {
    if (components[i] instanceof DynAnyImpl) {
      ((DynAnyImpl)components[i]).writeAny(out);
    } else {
      // Not our implementation. Nothing we can do to prevent copying.
      components[i].to_any().write_value(out);
    }
  }
  any.read_value(out.create_input_stream(), any.type());
  return true;
}

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

data.write_value(out);

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

protected boolean initializeAnyFromComponents() {
  OutputStream out = any.create_output_stream();
  // Writing the length first is the only difference to supers implementation
  out.write_long(components.length);
  for (int i=0; i<components.length; i++) {
    if (components[i] instanceof DynAnyImpl) {
      ((DynAnyImpl)components[i]).writeAny(out);
    } else {
      // Not our implementation. Nothing we can do to prevent copying.
      components[i].to_any().write_value(out);
    }
  }
  any.read_value(out.create_input_stream(), any.type());
  return true;
}

代码示例来源:origin: org.jboss.openjdk-orb/openjdk-orb

data.write_value( cdrOut );

代码示例来源:origin: org.apache.yoko/yoko-core

nv.value().write_value(out);

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

protected void doWriteTypeCodeParameters(TypeCode typeCode,
    CDROutputStream out, Map recursiveTCMap, Map repeatedTCMap)
                                  throws BadKind,
                                  Bounds
{
  out.write_string( typeCode.id() );
  out.write_string( typeCode.name() );
  out.write_TypeCode(typeCode.discriminator_type(),
            recursiveTCMap,
            repeatedTCMap);
  out.write_long( typeCode.default_index());
  final int memberCount = typeCode.member_count();
  out.write_long(memberCount);
  for( int i = 0; i < memberCount; i++)
  {
    if( i == typeCode.default_index() )
    {
      out.write_octet((byte)0);
    }
    else
    {
      typeCode.member_label(i).write_value( out );
    }
    out.write_string( typeCode.member_name(i));
    out.write_TypeCode( typeCode.member_type(i), recursiveTCMap, repeatedTCMap );
  }
}

相关文章