Searched refs:messageMediator (Results 1 - 25 of 36) sorted by relevance

12

/openjdk7/corba/src/share/classes/com/sun/corba/se/pept/transport/
H A DResponseWaitingRoom.java36 public void registerWaiter(MessageMediator messageMediator); argument
39 public InputObject waitForResponse(MessageMediator messageMediator); argument
43 public void unregisterWaiter(MessageMediator messageMediator); argument
H A DConnection.java197 * @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 DAcceptor.java181 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 DContactInfo.java198 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
/openjdk7/corba/src/share/classes/com/sun/corba/se/spi/protocol/
H A DCorbaProtocolHandler.java48 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
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/protocol/
H A DCorbaClientRequestDispatcherImpl.java236 CorbaMessageMediator messageMediator = (CorbaMessageMediator)
240 dprint(".beginRequest: " + opAndId(messageMediator)
241 + ": created message mediator: " + messageMediator);
254 orb.getInvocationInfo().setMessageMediator(messageMediator);
257 performCodeSetNegotiation(messageMediator);
260 addServiceContexts(messageMediator);
263 contactInfo.createOutputObject(messageMediator);
265 dprint(".beginRequest: " + opAndId(messageMediator)
273 registerWaiter(messageMediator);
287 orb.getPIHandler().setClientPIInfo(messageMediator);
381 marshalingComplete1( ORB orb, CorbaMessageMediator messageMediator) argument
439 processResponse(ORB orb, CorbaMessageMediator messageMediator, InputObject inputObject) argument
687 continueOrThrowSystemOrRemarshal( CorbaMessageMediator messageMediator, Exception exception) argument
738 registerWaiter(CorbaMessageMediator messageMediator) argument
757 addServiceContexts(CorbaMessageMediator messageMediator) argument
790 consumeServiceContexts(ORB orb, CorbaMessageMediator messageMediator) argument
836 getExceptionDetailMessage( CorbaMessageMediator messageMediator, ORBUtilSystemException wrapper) argument
932 performCodeSetNegotiation(CorbaMessageMediator messageMediator) argument
[all...]
H A DCorbaMessageMediatorImpl.java709 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 DCorbaInvocationInfo.java49 private MessageMediator messageMediator; field in class:CorbaInvocationInfo
107 public void setMessageMediator(MessageMediator messageMediator) argument
109 this.messageMediator = messageMediator;
114 return messageMediator;
H A DSharedCDRClientRequestDispatcherImpl.java140 CorbaMessageMediator messageMediator = null;
142 messageMediator = (CorbaMessageMediator)
145 orb = (ORB) messageMediator.getBroker();
148 dprint(".marshalingComplete->: " + opAndId(messageMediator));
163 messageMediator.setInputObject(cdrInputObject);
164 cdrInputObject.setMessageMediator(messageMediator);
171 ((CorbaMessageMediatorImpl)messageMediator).handleRequestRequest(
172 messageMediator);
192 cdrOutputObject = (CDROutputObject) messageMediator.getOutputObject();
198 messageMediator
[all...]
H A DBootstrapServerRequestDispatcher.java80 public void dispatch(MessageMediator messageMediator) argument
82 CorbaMessageMediator request = (CorbaMessageMediator) messageMediator;
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/transport/
H A DCorbaResponseWaitingRoomImpl.java64 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 DCorbaContactInfoBase.java130 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 DSharedCDRContactInfoImpl.java115 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 DSocketOrChannelConnectionImpl.java307 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;
388 protected CorbaMessageMediator finishReadingBits(MessageMediator messageMediator) argument
398 messageMediator =
399 contactInfo.finishCreatingMessageMediator(orb, this, messageMediator);
455 dispatch(CorbaMessageMediator messageMediator) argument
859 createOutputObject(MessageMediator messageMediator) argument
1089 registerWaiter(MessageMediator messageMediator) argument
1094 unregisterWaiter(MessageMediator messageMediator) argument
1099 waitForResponse(MessageMediator messageMediator) argument
1278 serverRequestMapPut(int requestId, CorbaMessageMediator messageMediator) argument
1644 setPartialMessageMediator(CorbaMessageMediator messageMediator) argument
[all...]
H A DSocketOrChannelAcceptorImpl.java512 MessageMediator messageMediator)
518 connection, messageMediator);
522 MessageMediator messageMediator)
525 messageMediator;
527 (CorbaConnection)messageMediator.getConnection(),
533 MessageMediator messageMediator)
536 messageMediator;
510 finishCreatingMessageMediator(Broker broker, Connection connection, MessageMediator messageMediator) argument
521 createInputObject(Broker broker, MessageMediator messageMediator) argument
532 createOutputObject(Broker broker, MessageMediator messageMediator) argument
H A DBufferConnectionImpl.sjava185 protected boolean dispatch(CorbaMessageMediator messageMediator)
272 public OutputObject createOutputObject(MessageMediator messageMediator)
326 public void registerWaiter(MessageMediator messageMediator)
330 public void unregisterWaiter(MessageMediator messageMediator)
334 public InputObject waitForResponse(MessageMediator messageMediator)
409 CorbaMessageMediator messageMediator)
411 serverRequestMap.put(new Integer(requestId), messageMediator);
/openjdk7/corba/src/share/classes/com/sun/corba/se/pept/protocol/
H A DProtocolHandler.java50 public boolean handleRequest(MessageMediator messageMediator); argument
H A DServerRequestDispatcher.java45 public void dispatch(MessageMediator messageMediator); argument
H A DClientInvocationInfo.java55 public void setMessageMediator(MessageMediator messageMediator); argument
/openjdk7/corba/src/share/classes/com/sun/corba/se/pept/encoding/
H A DInputObject.java56 public void setMessageMediator(MessageMediator messageMediator); argument
H A DOutputObject.java58 public void setMessageMediator(MessageMediator messageMediator); argument
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/interceptors/
H A DClientRequestInfoImpl.java129 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...]
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/encoding/
H A DCDROutputObject.java95 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 DCDRInputStream.java64 protected CorbaMessageMediator messageMediator; field in class:CDRInputStream
525 public void setMessageMediator(MessageMediator messageMediator) argument
527 this.messageMediator = (CorbaMessageMediator) messageMediator;
532 return messageMediator;
/openjdk7/corba/src/share/classes/sun/corba/
H A DOutputStreamFactory.java109 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

Completed in 124 milliseconds

12