0N/A/*
157N/A * Copyright (c) 2000, 2003, Oracle and/or its affiliates. All rights reserved.
0N/A * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
0N/A *
0N/A * This code is free software; you can redistribute it and/or modify it
0N/A * under the terms of the GNU General Public License version 2 only, as
157N/A * published by the Free Software Foundation. Oracle designates this
0N/A * particular file as subject to the "Classpath" exception as provided
157N/A * by Oracle in the LICENSE file that accompanied this code.
0N/A *
0N/A * This code is distributed in the hope that it will be useful, but WITHOUT
0N/A * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
0N/A * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
0N/A * version 2 for more details (a copy is included in the LICENSE file that
0N/A * accompanied this code).
0N/A *
0N/A * You should have received a copy of the GNU General Public License version
0N/A * 2 along with this work; if not, write to the Free Software Foundation,
0N/A * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
0N/A *
157N/A * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
157N/A * or visit www.oracle.com if you need additional information or have any
157N/A * questions.
0N/A */
0N/A
0N/Apackage com.sun.corba.se.impl.protocol.giopmsgheaders;
0N/A
0N/Aimport java.nio.ByteBuffer;
0N/Aimport org.omg.CORBA.INTERNAL;
0N/Aimport org.omg.CORBA.CompletionStatus;
0N/Aimport com.sun.corba.se.spi.ior.iiop.GIOPVersion;
0N/A
0N/Aimport com.sun.corba.se.spi.logging.CORBALogDomains ;
0N/Aimport com.sun.corba.se.impl.logging.ORBUtilSystemException ;
0N/A
0N/A/*
0N/A * This implements the GIOP 1.0 Message header.
0N/A *
0N/A * @author Ram Jeyaraman 05/14/2000
0N/A */
0N/A
0N/Apublic class Message_1_0
0N/A extends com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase {
0N/A
0N/A private static ORBUtilSystemException wrapper =
0N/A ORBUtilSystemException.get( CORBALogDomains.RPC_PROTOCOL ) ;
0N/A
0N/A // Instance variables
0N/A int magic = (int) 0;
0N/A GIOPVersion GIOP_version = null;
0N/A boolean byte_order = false;
0N/A byte message_type = (byte) 0;
0N/A int message_size = (int) 0;
0N/A
0N/A // Constructor
0N/A
0N/A Message_1_0() {
0N/A }
0N/A
0N/A Message_1_0(int _magic, boolean _byte_order, byte _message_type,
0N/A int _message_size) {
0N/A magic = _magic;
0N/A GIOP_version = GIOPVersion.V1_0;
0N/A byte_order = _byte_order;
0N/A message_type = _message_type;
0N/A message_size = _message_size;
0N/A }
0N/A
0N/A // Accessor methods
0N/A
0N/A public GIOPVersion getGIOPVersion() {
0N/A return this.GIOP_version;
0N/A }
0N/A
0N/A public int getType() {
0N/A return this.message_type;
0N/A }
0N/A
0N/A public int getSize() {
0N/A return this.message_size;
0N/A }
0N/A
0N/A public boolean isLittleEndian() {
0N/A return this.byte_order;
0N/A }
0N/A
0N/A public boolean moreFragmentsToFollow() {
0N/A return false;
0N/A }
0N/A
0N/A // Mutator methods
0N/A
0N/A public void setSize(ByteBuffer byteBuffer, int size) {
0N/A this.message_size = size;
0N/A
0N/A //
0N/A // Patch the size field in the header.
0N/A //
0N/A int patch = size - GIOPMessageHeaderLength;
0N/A if (!isLittleEndian()) {
0N/A byteBuffer.put(8, (byte)((patch >>> 24) & 0xFF));
0N/A byteBuffer.put(9, (byte)((patch >>> 16) & 0xFF));
0N/A byteBuffer.put(10, (byte)((patch >>> 8) & 0xFF));
0N/A byteBuffer.put(11, (byte)((patch >>> 0) & 0xFF));
0N/A } else {
0N/A byteBuffer.put(8, (byte)((patch >>> 0) & 0xFF));
0N/A byteBuffer.put(9, (byte)((patch >>> 8) & 0xFF));
0N/A byteBuffer.put(10, (byte)((patch >>> 16) & 0xFF));
0N/A byteBuffer.put(11, (byte)((patch >>> 24) & 0xFF));
0N/A }
0N/A }
0N/A
0N/A public FragmentMessage createFragmentMessage() {
0N/A throw wrapper.fragmentationDisallowed(
0N/A CompletionStatus.COMPLETED_MAYBE);
0N/A }
0N/A
0N/A // IO methods
0N/A
0N/A // This should do nothing even if it is called. The Message Header already
0N/A // is read off java.io.InputStream (not a CDRInputStream) by IIOPConnection
0N/A // in order to choose the correct CDR Version, msg_type, and msg_size.
0N/A // So, we would never need to read the Message Header off a CDRInputStream.
0N/A public void read(org.omg.CORBA.portable.InputStream istream) {
0N/A /*
0N/A this.magic = istream.read_long();
0N/A this.GIOP_version = (new GIOPVersion()).read(istream);
0N/A this.byte_order = istream.read_boolean();
0N/A this.message_type = istream.read_octet();
0N/A this.message_size = istream.read_ulong();
0N/A */
0N/A }
0N/A
0N/A public void write(org.omg.CORBA.portable.OutputStream ostream) {
0N/A ostream.write_long(this.magic);
0N/A nullCheck(this.GIOP_version);
0N/A this.GIOP_version.write(ostream);
0N/A ostream.write_boolean(this.byte_order);
0N/A ostream.write_octet(this.message_type);
0N/A ostream.write_ulong(this.message_size);
0N/A }
0N/A
0N/A} // class Message_1_0