1. /*

  2.  * @(#)CorbaConnection.java	1.28 04/06/21

  3.  * 

  4.  * Copyright 2004 Sun Microsystems, Inc. All rights reserved.

  5.  * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.

  6.  */

  7. 

  8. package com.sun.corba.se.spi.transport;

  9. 

  10. import java.io.IOException;

  11. import java.nio.ByteBuffer;

  12. import java.nio.channels.SocketChannel;

  13. 

  14. import org.omg.CORBA.SystemException;

  15. 

  16. import com.sun.org.omg.SendingContext.CodeBase;

  17. 

  18. import com.sun.corba.se.pept.encoding.InputObject;

  19. import com.sun.corba.se.pept.encoding.OutputObject;

  20. import com.sun.corba.se.pept.protocol.MessageMediator;

  21. import com.sun.corba.se.pept.transport.Connection;

  22. import com.sun.corba.se.pept.transport.ResponseWaitingRoom;

  23. 

  24. import com.sun.corba.se.spi.ior.IOR ;

  25. import com.sun.corba.se.spi.ior.iiop.GIOPVersion;

  26. import com.sun.corba.se.spi.orb.ORB;

  27. import com.sun.corba.se.spi.protocol.CorbaMessageMediator;

  28. 

  29. import com.sun.corba.se.impl.encoding.CodeSetComponentInfo;

  30. import com.sun.corba.se.impl.logging.ORBUtilSystemException;

  31. 

  32. /**

  33.  * @author Harold Carr

  34.  */

  35. public interface CorbaConnection

  36.     extends

  37. 	Connection,

  38. 	com.sun.corba.se.spi.legacy.connection.Connection

  39. {

  40.     public boolean shouldUseDirectByteBuffers();

  41. 

  42.     public boolean shouldReadGiopHeaderOnly();

  43. 

  44.     public ByteBuffer read(int size, int offset, int length, long max_wait_time)

  45. 	throws IOException;

  46. 

  47.     public ByteBuffer read(ByteBuffer byteBuffer, int offset,

  48. 	                  int length, long max_wait_time) throws IOException;

  49. 

  50.     public void write(ByteBuffer byteBuffer)

  51. 	throws IOException;

  52. 

  53.     public void dprint(String msg);

  54. 

  55.     //

  56.     // From iiop.Connection.java

  57.     //

  58. 

  59.     public int getNextRequestId();

  60.     public ORB getBroker();

  61.     public CodeSetComponentInfo.CodeSetContext getCodeSetContext();

  62.     public void setCodeSetContext(CodeSetComponentInfo.CodeSetContext csc);

  63.     

  64.     //

  65.     // from iiop.IIOPConnection.java

  66.     //

  67. 

  68.     // Facade to ResponseWaitingRoom.

  69.     public MessageMediator clientRequestMapGet(int requestId);

  70. 

  71.     public void clientReply_1_1_Put(MessageMediator x);

  72.     public MessageMediator clientReply_1_1_Get();

  73.     public void clientReply_1_1_Remove();

  74. 

  75.     public void serverRequest_1_1_Put(MessageMediator x);

  76.     public MessageMediator serverRequest_1_1_Get();

  77.     public void serverRequest_1_1_Remove();

  78. 

  79.     public boolean isPostInitialContexts();

  80. 

  81.     // Can never be unset...

  82.     public void setPostInitialContexts();

  83. 

  84.     public void purgeCalls(SystemException systemException,

  85. 			   boolean die, boolean lockHeld);

  86. 

  87.     //

  88.     // Connection status

  89.     //

  90.     public static final int OPENING = 1;

  91.     public static final int ESTABLISHED = 2;

  92.     public static final int CLOSE_SENT = 3;

  93.     public static final int CLOSE_RECVD = 4;

  94.     public static final int ABORT = 5;

  95. 

  96.     // Begin Code Base methods ---------------------------------------

  97.     //

  98.     // Set this connection's code base IOR.  The IOR comes from the

  99.     // SendingContext.  This is an optional service context, but all

  100.     // JavaSoft ORBs send it.

  101.     //

  102.     // The set and get methods don't need to be synchronized since the

  103.     // first possible get would occur during reading a valuetype, and

  104.     // that would be after the set.

  105. 

  106.     // Sets this connection's code base IOR.  This is done after

  107.     // getting the IOR out of the SendingContext service context.

  108.     // Our ORBs always send this, but it's optional in CORBA.

  109. 

  110.     void setCodeBaseIOR(IOR ior);

  111. 

  112.     IOR getCodeBaseIOR();

  113. 

  114.     // Get a CodeBase stub to use in unmarshaling.  The CachedCodeBase

  115.     // won't connect to the remote codebase unless it's necessary.

  116.     CodeBase getCodeBase();

  117. 

  118.     // End Code Base methods -----------------------------------------

  119. 

  120.     public void sendCloseConnection(GIOPVersion giopVersion)

  121. 	throws IOException;

  122. 

  123.     public void sendMessageError(GIOPVersion giopVersion)

  124. 	throws IOException;

  125. 

  126.     public void sendCancelRequest(GIOPVersion giopVersion, int requestId)

  127. 	throws

  128. 	    IOException;

  129. 

  130.     public void sendCancelRequestWithLock(GIOPVersion giopVersion,

  131. 					  int requestId)

  132. 	throws 

  133. 	    IOException;

  134. 

  135.     public ResponseWaitingRoom getResponseWaitingRoom();

  136. 

  137.     public void serverRequestMapPut(int requestId,

  138. 				    CorbaMessageMediator messageMediator);

  139.     public CorbaMessageMediator serverRequestMapGet(int requestId);

  140.     public void serverRequestMapRemove(int requestId);

  141. 

  142.     // REVISIT: WRONG: should not expose sockets here.

  143.     public SocketChannel getSocketChannel();

  144. 

  145.     // REVISIT - MessageMediator parameter?

  146.     public void serverRequestProcessingBegins();

  147.     public void serverRequestProcessingEnds();

  148. }

  149. 

  150. // End of file.

  151.