/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/pept/transport/ |
H A D | ResponseWaitingRoom.java | 36 public void registerWaiter(MessageMediator messageMediator); argument 39 public InputObject waitForResponse(MessageMediator messageMediator); argument 43 public void unregisterWaiter(MessageMediator messageMediator); argument
|
H A D | Connection.java | 197 * @param messageMediator 199 public void registerWaiter(MessageMediator messageMediator); argument 209 * @param messageMediator 211 public InputObject waitForResponse(MessageMediator messageMediator); argument 218 * @param messageMediator 220 public void unregisterWaiter(MessageMediator messageMediator); argument
|
H A D | Acceptor.java | 181 MessageMediator messageMediator); 193 MessageMediator messageMediator); 205 MessageMediator messageMediator); 179 finishCreatingMessageMediator(Broker broker, Connection xconnection, MessageMediator messageMediator) argument 192 createInputObject(Broker broker, MessageMediator messageMediator) argument 204 createOutputObject(Broker broker, MessageMediator messageMediator) argument
|
H A D | ContactInfo.java | 198 MessageMediator messageMediator); 210 MessageMediator messageMediator); 221 public OutputObject createOutputObject(MessageMediator messageMediator); argument 196 finishCreatingMessageMediator(Broker broker, Connection connection, MessageMediator messageMediator) argument 209 createInputObject(Broker broker, MessageMediator messageMediator) argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/spi/protocol/ |
H A D | CorbaProtocolHandler.java | 48 CorbaMessageMediator messageMediator); 51 CorbaMessageMediator messageMediator); 54 CorbaMessageMediator messageMediator, 57 CorbaMessageMediator messageMediator, 60 CorbaMessageMediator messageMediator, 63 CorbaMessageMediator messageMediator, 67 CorbaMessageMediator messageMediator, 47 handleRequest(RequestMessage header, CorbaMessageMediator messageMediator) argument 50 handleRequest(LocateRequestMessage header, CorbaMessageMediator messageMediator) argument 53 createResponse( CorbaMessageMediator messageMediator, ServiceContexts svc) argument 56 createUserExceptionResponse( CorbaMessageMediator messageMediator, ServiceContexts svc) argument 59 createUnknownExceptionResponse( CorbaMessageMediator messageMediator, UnknownException ex) argument 62 createSystemExceptionResponse( CorbaMessageMediator messageMediator, SystemException ex, ServiceContexts svc) argument 66 createLocationForward( CorbaMessageMediator messageMediator, IOR ior, ServiceContexts svc) argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/impl/protocol/ |
H A D | CorbaClientRequestDispatcherImpl.java | 237 CorbaMessageMediator messageMediator = (CorbaMessageMediator) 241 dprint(".beginRequest: " + opAndId(messageMediator) 242 + ": created message mediator: " + messageMediator); 255 orb.getInvocationInfo().setMessageMediator(messageMediator); 258 performCodeSetNegotiation(messageMediator); 261 addServiceContexts(messageMediator); 264 contactInfo.createOutputObject(messageMediator); 266 dprint(".beginRequest: " + opAndId(messageMediator) 274 registerWaiter(messageMediator); 288 orb.getPIHandler().setClientPIInfo(messageMediator); 382 marshalingComplete1( ORB orb, CorbaMessageMediator messageMediator) argument 440 processResponse(ORB orb, CorbaMessageMediator messageMediator, InputObject inputObject) argument 688 continueOrThrowSystemOrRemarshal( CorbaMessageMediator messageMediator, Exception exception) argument 739 registerWaiter(CorbaMessageMediator messageMediator) argument 758 addServiceContexts(CorbaMessageMediator messageMediator) argument 791 consumeServiceContexts(ORB orb, CorbaMessageMediator messageMediator) argument 837 getExceptionDetailMessage( CorbaMessageMediator messageMediator, ORBUtilSystemException wrapper) argument 933 performCodeSetNegotiation(CorbaMessageMediator messageMediator) argument [all...] |
H A D | CorbaMessageMediatorImpl.java | 709 public boolean handleRequest(MessageMediator messageMediator) argument 1553 CorbaMessageMediator messageMediator) 1556 beginRequest(messageMediator); 1558 handleRequestRequest(messageMediator); 1559 if (messageMediator.isOneWay()) { 1563 if (messageMediator.isOneWay()) { 1567 messageMediator, t, CompletionStatus.COMPLETED_MAYBE); 1569 sendResponse(messageMediator); 1571 dispatchError(messageMediator, "RequestMessage", t); 1573 endRequest(messageMediator); 1552 handleRequest(RequestMessage msg, CorbaMessageMediator messageMediator) argument 1577 handleRequest(LocateRequestMessage msg, CorbaMessageMediator messageMediator) argument 1596 beginRequest(CorbaMessageMediator messageMediator) argument 1605 dispatchError(CorbaMessageMediator messageMediator, String msg, Throwable t) argument 1618 sendResponse(CorbaMessageMediator messageMediator) argument 1633 endRequest(CorbaMessageMediator messageMediator) argument 1663 handleRequestRequest(CorbaMessageMediator messageMediator) argument 1706 handleLocateRequest(CorbaMessageMediator messageMediator) argument 1789 createAppropriateOutputObject( CorbaMessageMediator messageMediator, Message msg, LocateReplyMessage reply) argument 1815 handleThrowableDuringServerDispatch( CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus) argument 1848 handleThrowableDuringServerDispatch( CorbaMessageMediator messageMediator, Throwable throwable, CompletionStatus completionStatus, int iteration) argument 1939 handleAddressingDisposition( CorbaMessageMediator messageMediator, AddressingDispositionException ex) argument 2005 createResponse( CorbaMessageMediator messageMediator, ServiceContexts svc) argument 2018 createUserExceptionResponse( CorbaMessageMediator messageMediator, ServiceContexts svc) argument 2028 createUnknownExceptionResponse( CorbaMessageMediator messageMediator, UnknownException ex) argument 2042 createSystemExceptionResponse( CorbaMessageMediator messageMediator, SystemException ex, ServiceContexts svc) argument 2137 createLocationForward( CorbaMessageMediator messageMediator, IOR ior, ServiceContexts svc) argument 2153 createResponseHelper( CorbaMessageMediator messageMediator, ServiceContexts svc) argument 2168 createResponseHelper( CorbaMessageMediator messageMediator, ServiceContexts svc,boolean user) argument 2185 createResponseHelper( CorbaMessageMediator messageMediator, ReplyMessage reply, IOR ior) argument 2229 runServantPostInvoke(CorbaMessageMediator messageMediator) argument 2270 runInterceptors(CorbaMessageMediator messageMediator, ReplyMessage reply) argument 2291 runRemoveThreadInfo(CorbaMessageMediator messageMediator) argument 2301 getServiceContextsForReply( CorbaMessageMediator messageMediator, ServiceContexts contexts) argument [all...] |
H A D | CorbaInvocationInfo.java | 49 private MessageMediator messageMediator; field in class:CorbaInvocationInfo 107 public void setMessageMediator(MessageMediator messageMediator) argument 109 this.messageMediator = messageMediator; 114 return messageMediator;
|
H A D | SharedCDRClientRequestDispatcherImpl.java | 142 CorbaMessageMediator messageMediator = null; 144 messageMediator = (CorbaMessageMediator) 147 orb = (ORB) messageMediator.getBroker(); 150 dprint(".marshalingComplete->: " + opAndId(messageMediator)); 172 messageMediator.setInputObject(cdrInputObject); 173 cdrInputObject.setMessageMediator(messageMediator); 180 ((CorbaMessageMediatorImpl)messageMediator).handleRequestRequest( 181 messageMediator); 201 cdrOutputObject = (CDROutputObject) messageMediator.getOutputObject(); 215 messageMediator [all...] |
H A D | BootstrapServerRequestDispatcher.java | 80 public void dispatch(MessageMediator messageMediator) argument 82 CorbaMessageMediator request = (CorbaMessageMediator) messageMediator;
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/pept/protocol/ |
H A D | ProtocolHandler.java | 50 public boolean handleRequest(MessageMediator messageMediator); argument
|
H A D | ServerRequestDispatcher.java | 45 public void dispatch(MessageMediator messageMediator); argument
|
H A D | ClientInvocationInfo.java | 55 public void setMessageMediator(MessageMediator messageMediator); argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/impl/transport/ |
H A D | CorbaResponseWaitingRoomImpl.java | 64 MessageMediator messageMediator; field in class:CorbaResponseWaitingRoomImpl.OutCallDesc 93 CorbaMessageMediator messageMediator = (CorbaMessageMediator) mediator; 96 dprint(".registerWaiter: " + opAndId(messageMediator)); 99 Integer requestId = messageMediator.getRequestIdInteger(); 103 call.messageMediator = messageMediator; 109 CorbaMessageMediator messageMediator = (CorbaMessageMediator) mediator; 112 dprint(".unregisterWaiter: " + opAndId(messageMediator)); 115 Integer requestId = messageMediator.getRequestIdInteger(); 122 CorbaMessageMediator messageMediator [all...] |
H A D | CorbaContactInfoBase.java | 130 CorbaMessageMediator messageMediator = 143 return messageMediator; 176 CorbaMessageMediator messageMediator = 179 return messageMediator; 184 Connection conn, MessageMediator messageMediator) 189 (CorbaMessageMediator)messageMediator; 211 public OutputObject createOutputObject(MessageMediator messageMediator) argument 214 messageMediator; 217 sun.corba.OutputStreamFactory.newCDROutputObject(orb, messageMediator, 221 messageMediator 183 finishCreatingMessageMediator(Broker broker, Connection conn, MessageMediator messageMediator) argument 225 createInputObject(Broker broker, MessageMediator messageMediator) argument [all...] |
H A D | SharedCDRContactInfoImpl.java | 115 CorbaMessageMediator messageMediator = 128 return messageMediator; 131 public OutputObject createOutputObject(MessageMediator messageMediator) argument 134 messageMediator; 137 sun.corba.OutputStreamFactory.newCDROutputObject(orb, messageMediator, 141 messageMediator.setOutputObject(outputObject);
|
H A D | SocketOrChannelConnectionImpl.java | 307 CorbaMessageMediator messageMediator = readBits(); 308 if (messageMediator != null) { 311 return dispatch(messageMediator); 329 MessageMediator messageMediator; 332 messageMediator = 335 messageMediator = acceptor.createMessageMediator(orb, this); 340 return (CorbaMessageMediator) messageMediator; 391 protected CorbaMessageMediator finishReadingBits(MessageMediator messageMediator) argument 401 messageMediator = 402 contactInfo.finishCreatingMessageMediator(orb, this, messageMediator); 458 dispatch(CorbaMessageMediator messageMediator) argument 866 createOutputObject(MessageMediator messageMediator) argument 1096 registerWaiter(MessageMediator messageMediator) argument 1101 unregisterWaiter(MessageMediator messageMediator) argument 1106 waitForResponse(MessageMediator messageMediator) argument 1285 serverRequestMapPut(int requestId, CorbaMessageMediator messageMediator) argument 1651 setPartialMessageMediator(CorbaMessageMediator messageMediator) argument [all...] |
H A D | SocketOrChannelAcceptorImpl.java | 531 MessageMediator messageMediator) 537 connection, messageMediator); 541 MessageMediator messageMediator) 544 messageMediator; 546 (CorbaConnection)messageMediator.getConnection(), 552 MessageMediator messageMediator) 555 messageMediator; 529 finishCreatingMessageMediator(Broker broker, Connection connection, MessageMediator messageMediator) argument 540 createInputObject(Broker broker, MessageMediator messageMediator) argument 551 createOutputObject(Broker broker, MessageMediator messageMediator) argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/pept/encoding/ |
H A D | OutputObject.java | 58 public void setMessageMediator(MessageMediator messageMediator); argument
|
H A D | InputObject.java | 56 public void setMessageMediator(MessageMediator messageMediator); argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/impl/interceptors/ |
H A D | ClientRequestInfoImpl.java | 129 private CorbaMessageMediator messageMediator; field in class:ClientRequestInfoImpl 175 messageMediator = null; 287 messageMediator.getContactInfo(); 310 messageMediator.getContactInfo(); 330 messageMediator.getContactInfo(); 428 messageMediator.getContactInfo(); 475 messageMediator.getRequestServiceContexts(), 504 return messageMediator.getRequestId(); 513 return messageMediator.getOperationName(); 697 return ! messageMediator 819 setInfo(MessageMediator messageMediator) argument [all...] |
H A D | PINoOpHandlerImpl.java | 124 public void setClientPIInfo(CorbaMessageMediator messageMediator) argument
|
/openjdk10/corba/src/java.corba/share/classes/com/sun/corba/se/impl/encoding/ |
H A D | CDROutputObject.java | 95 MessageMediator messageMediator, 101 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), 104 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), 108 (CorbaMessageMediator)messageMediator); 115 MessageMediator messageMediator, 122 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), 129 (CorbaMessageMediator)messageMediator); 94 CDROutputObject(ORB orb, MessageMediator messageMediator, Message header, byte streamFormatVersion) argument 114 CDROutputObject(ORB orb, MessageMediator messageMediator, Message header, byte streamFormatVersion, int strategy) argument
|
H A D | CDRInputStream.java | 64 protected CorbaMessageMediator messageMediator; field in class:CDRInputStream 525 public void setMessageMediator(MessageMediator messageMediator) argument 527 this.messageMediator = (CorbaMessageMediator) messageMediator; 532 return messageMediator;
|
/openjdk10/corba/src/java.corba/share/classes/sun/corba/ |
H A D | OutputStreamFactory.java | 109 final ORB orb, final MessageMediator messageMediator, 115 return new CDROutputObject(orb, messageMediator, 122 final ORB orb, final MessageMediator messageMediator, 129 return new CDROutputObject(orb, messageMediator, 108 newCDROutputObject( final ORB orb, final MessageMediator messageMediator, final Message header, final byte streamFormatVersion) argument 121 newCDROutputObject( final ORB orb, final MessageMediator messageMediator, final Message header, final byte streamFormatVersion, final int strategy) argument
|