• file
• revisions
• annotate
• diff
• comparison
• raw

src/share/classes/com/sun/corba/se/spi/protocol/CorbaMessageMediator.java@6845b95cba6b (annotated)

src/share/classes/com/sun/corba/se/spi/protocol/CorbaMessageMediator.java

Thu, 31 Aug 2017 18:10:36 +0800

author

aoqi

date

Thu, 31 Aug 2017 18:10:36 +0800

changeset 748

6845b95cba6b

parent 158

91006f157c46

parent 0

7ef37b2cdcad

permissions

-rw-r--r--

merge

aoqi@0	1	/*
aoqi@0	2	* Copyright (c) 2002, 2004, Oracle and/or its affiliates. All rights reserved.
aoqi@0	3	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
aoqi@0	4	*
aoqi@0	5	* This code is free software; you can redistribute it and/or modify it
aoqi@0	6	* under the terms of the GNU General Public License version 2 only, as
aoqi@0	7	* published by the Free Software Foundation. Oracle designates this
aoqi@0	8	* particular file as subject to the "Classpath" exception as provided
aoqi@0	9	* by Oracle in the LICENSE file that accompanied this code.
aoqi@0	10	*
aoqi@0	11	* This code is distributed in the hope that it will be useful, but WITHOUT
aoqi@0	12	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
aoqi@0	13	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
aoqi@0	14	* version 2 for more details (a copy is included in the LICENSE file that
aoqi@0	15	* accompanied this code).
aoqi@0	16	*
aoqi@0	17	* You should have received a copy of the GNU General Public License version
aoqi@0	18	* 2 along with this work; if not, write to the Free Software Foundation,
aoqi@0	19	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
aoqi@0	20	*
aoqi@0	21	* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
aoqi@0	22	* or visit www.oracle.com if you need additional information or have any
aoqi@0	23	* questions.
aoqi@0	24	*/
aoqi@0	25
aoqi@0	26	package com.sun.corba.se.spi.protocol;
aoqi@0	27
aoqi@0	28	import java.nio.ByteBuffer;
aoqi@0	29
aoqi@0	30	import org.omg.CORBA.INTERNAL;
aoqi@0	31	import org.omg.CORBA.SystemException;
aoqi@0	32	import org.omg.CORBA.portable.ResponseHandler;
aoqi@0	33	import org.omg.CORBA.portable.UnknownException;
aoqi@0	34	import org.omg.CORBA_2_3.portable.InputStream;
aoqi@0	35	import org.omg.CORBA_2_3.portable.OutputStream;
aoqi@0	36
aoqi@0	37	import com.sun.corba.se.pept.broker.Broker;
aoqi@0	38	import com.sun.corba.se.pept.protocol.MessageMediator;
aoqi@0	39	import com.sun.corba.se.pept.encoding.InputObject;
aoqi@0	40	import com.sun.corba.se.pept.encoding.OutputObject;
aoqi@0	41	import com.sun.corba.se.pept.protocol.ProtocolHandler;
aoqi@0	42	import com.sun.corba.se.pept.transport.Connection;
aoqi@0	43
aoqi@0	44	import com.sun.corba.se.spi.ior.IOR;
aoqi@0	45	import com.sun.corba.se.spi.ior.ObjectKey;
aoqi@0	46	import com.sun.corba.se.spi.ior.iiop.GIOPVersion;
aoqi@0	47	import com.sun.corba.se.spi.protocol.CorbaProtocolHandler;
aoqi@0	48	import com.sun.corba.se.spi.servicecontext.ServiceContexts;
aoqi@0	49
aoqi@0	50	import com.sun.corba.se.impl.protocol.giopmsgheaders.LocateReplyMessage;
aoqi@0	51	import com.sun.corba.se.impl.protocol.giopmsgheaders.LocateReplyOrReplyMessage;
aoqi@0	52	import com.sun.corba.se.impl.protocol.giopmsgheaders.Message;
aoqi@0	53	import com.sun.corba.se.impl.protocol.giopmsgheaders.MessageBase;
aoqi@0	54	import com.sun.corba.se.impl.protocol.giopmsgheaders.MessageHandler;
aoqi@0	55	import com.sun.corba.se.impl.protocol.giopmsgheaders.ReplyMessage;
aoqi@0	56	import com.sun.corba.se.impl.protocol.giopmsgheaders.ReplyMessage_1_0;
aoqi@0	57	import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage;
aoqi@0	58	import com.sun.corba.se.impl.protocol.giopmsgheaders.RequestMessage_1_0;
aoqi@0	59
aoqi@0	60	/**
aoqi@0	61	* @author Harold Carr
aoqi@0	62	*/
aoqi@0	63	public interface CorbaMessageMediator
aoqi@0	64	extends
aoqi@0	65	MessageMediator,
aoqi@0	66	ResponseHandler
aoqi@0	67	{
aoqi@0	68	public void setReplyHeader(LocateReplyOrReplyMessage header);
aoqi@0	69	public LocateReplyMessage getLocateReplyHeader();
aoqi@0	70	public ReplyMessage getReplyHeader();
aoqi@0	71	public void setReplyExceptionDetailMessage(String message);
aoqi@0	72	public RequestMessage getRequestHeader();
aoqi@0	73	public GIOPVersion getGIOPVersion();
aoqi@0	74	public byte getEncodingVersion();
aoqi@0	75	public int getRequestId();
aoqi@0	76	public Integer getRequestIdInteger();
aoqi@0	77	public boolean isOneWay();
aoqi@0	78	public short getAddrDisposition();
aoqi@0	79	public String getOperationName();
aoqi@0	80	public ServiceContexts getRequestServiceContexts();
aoqi@0	81	public ServiceContexts getReplyServiceContexts();
aoqi@0	82	public Message getDispatchHeader();
aoqi@0	83	public void setDispatchHeader(Message msg);
aoqi@0	84	public ByteBuffer getDispatchBuffer();
aoqi@0	85	public void setDispatchBuffer(ByteBuffer byteBuffer);
aoqi@0	86	public int getThreadPoolToUse();
aoqi@0	87	public byte getStreamFormatVersion(); // REVIST name ForRequest?
aoqi@0	88	public byte getStreamFormatVersionForReply();
aoqi@0	89
aoqi@0	90	// REVISIT - not sure if the final fragment and DII stuff should
aoqi@0	91	// go here.
aoqi@0	92
aoqi@0	93	public void sendCancelRequestIfFinalFragmentNotSent();
aoqi@0	94
aoqi@0	95	public void setDIIInfo(org.omg.CORBA.Request request);
aoqi@0	96	public boolean isDIIRequest();
aoqi@0	97	public Exception unmarshalDIIUserException(String repoId,
aoqi@0	98	InputStream inputStream);
aoqi@0	99	public void setDIIException(Exception exception);
aoqi@0	100	public void handleDIIReply(InputStream inputStream);
aoqi@0	101
aoqi@0	102
aoqi@0	103	public boolean isSystemExceptionReply();
aoqi@0	104	public boolean isUserExceptionReply();
aoqi@0	105	public boolean isLocationForwardReply();
aoqi@0	106	public boolean isDifferentAddrDispositionRequestedReply();
aoqi@0	107	public short getAddrDispositionReply();
aoqi@0	108	public IOR getForwardedIOR();
aoqi@0	109	public SystemException getSystemExceptionReply();
aoqi@0	110
aoqi@0	111	////////////////////////////////////////////////////
aoqi@0	112	//
aoqi@0	113	// Server side
aoqi@0	114	//
aoqi@0	115
aoqi@0	116	public ObjectKey getObjectKey();
aoqi@0	117	public void setProtocolHandler(CorbaProtocolHandler protocolHandler);
aoqi@0	118	public CorbaProtocolHandler getProtocolHandler();
aoqi@0	119
aoqi@0	120	////////////////////////////////////////////////////
aoqi@0	121	//
aoqi@0	122	// ResponseHandler
aoqi@0	123	//
aoqi@0	124
aoqi@0	125	public org.omg.CORBA.portable.OutputStream createReply();
aoqi@0	126	public org.omg.CORBA.portable.OutputStream createExceptionReply();
aoqi@0	127
aoqi@0	128	////////////////////////////////////////////////////
aoqi@0	129	//
aoqi@0	130	// from core.ServerRequest
aoqi@0	131	//
aoqi@0	132
aoqi@0	133	public boolean executeReturnServantInResponseConstructor();
aoqi@0	134
aoqi@0	135	public void setExecuteReturnServantInResponseConstructor(boolean b);
aoqi@0	136
aoqi@0	137	public boolean executeRemoveThreadInfoInResponseConstructor();
aoqi@0	138
aoqi@0	139	public void setExecuteRemoveThreadInfoInResponseConstructor(boolean b);
aoqi@0	140
aoqi@0	141	public boolean executePIInResponseConstructor();
aoqi@0	142
aoqi@0	143	public void setExecutePIInResponseConstructor( boolean b );
aoqi@0	144	}
aoqi@0	145
aoqi@0	146	// End of file.