| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/protocol/ |
| H A D | CorbaClientRequestDispatcherImpl.java | 261 addServiceContexts(messageMediator); in beginRequest()
274 registerWaiter(messageMediator); in beginRequest()
337 messageMediator.initializeMessage(); in beginRequest()
470 if (messageMediator.isOneWay()) { in processResponse()
742 messageMediator.getConnection().registerWaiter(messageMediator); in registerWaiter()
748 MessageMediator messageMediator = in unregisterWaiter() local
750 if (messageMediator!=null && messageMediator.getConnection() != null) { in unregisterWaiter()
754 messageMediator.getConnection().unregisterWaiter(messageMediator); in unregisterWaiter()
838 CorbaMessageMediator messageMediator, in getExceptionDetailMessage() argument
876 MessageMediator messageMediator = in endRequest() local
[all …]
|
| H A D | CorbaMessageMediatorImpl.java | 1556 beginRequest(messageMediator); in handleRequest()
1573 endRequest(messageMediator); in handleRequest()
1592 endRequest(messageMediator); in handleRequest()
1700 sc.dispatch(messageMediator); in handleRequestRequest()
1879 messageMediator, in handleThrowableDuringServerDispatch()
2014 messageMediator, in createResponse()
2023 messageMediator, in createUserExceptionResponse()
2207 messageMediator, messageMediator.getReplyHeader(), in createResponseHelper()
2212 .createOutputObject(messageMediator.getBroker(), messageMediator); in createResponseHelper()
2215 messageMediator.getOutputObject().setMessageMediator(messageMediator); in createResponseHelper()
[all …]
|
| H A D | SharedCDRClientRequestDispatcherImpl.java | 142 CorbaMessageMediator messageMediator = null; in marshalingComplete() local
144 messageMediator = (CorbaMessageMediator) in marshalingComplete()
147 orb = (ORB) messageMediator.getBroker(); in marshalingComplete()
150 dprint(".marshalingComplete->: " + opAndId(messageMediator)); in marshalingComplete()
172 messageMediator.setInputObject(cdrInputObject); in marshalingComplete()
173 cdrInputObject.setMessageMediator(messageMediator); in marshalingComplete()
180 ((CorbaMessageMediatorImpl)messageMediator).handleRequestRequest( in marshalingComplete()
181 messageMediator); in marshalingComplete()
215 messageMediator.setInputObject(cdrInputObject); in marshalingComplete()
216 cdrInputObject.setMessageMediator(messageMediator); in marshalingComplete()
[all …]
|
| H A D | CorbaInvocationInfo.java | 49 private MessageMediator messageMediator; field in CorbaInvocationInfo
107 public void setMessageMediator(MessageMediator messageMediator) in setMessageMediator() argument
109 this.messageMediator = messageMediator; in setMessageMediator()
114 return messageMediator; in getMessageMediator()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/protocol/ |
| H A D | CorbaClientRequestDispatcherImpl.java | 261 addServiceContexts(messageMediator); in beginRequest()
274 registerWaiter(messageMediator); in beginRequest()
337 messageMediator.initializeMessage(); in beginRequest()
470 if (messageMediator.isOneWay()) { in processResponse()
742 messageMediator.getConnection().registerWaiter(messageMediator); in registerWaiter()
748 MessageMediator messageMediator = in unregisterWaiter() local
750 if (messageMediator!=null && messageMediator.getConnection() != null) { in unregisterWaiter()
754 messageMediator.getConnection().unregisterWaiter(messageMediator); in unregisterWaiter()
838 CorbaMessageMediator messageMediator, in getExceptionDetailMessage() argument
876 MessageMediator messageMediator = in endRequest() local
[all …]
|
| H A D | CorbaMessageMediatorImpl.java | 1556 beginRequest(messageMediator); in handleRequest()
1573 endRequest(messageMediator); in handleRequest()
1592 endRequest(messageMediator); in handleRequest()
1700 sc.dispatch(messageMediator); in handleRequestRequest()
1879 messageMediator, in handleThrowableDuringServerDispatch()
2014 messageMediator, in createResponse()
2023 messageMediator, in createUserExceptionResponse()
2207 messageMediator, messageMediator.getReplyHeader(), in createResponseHelper()
2212 .createOutputObject(messageMediator.getBroker(), messageMediator); in createResponseHelper()
2215 messageMediator.getOutputObject().setMessageMediator(messageMediator); in createResponseHelper()
[all …]
|
| H A D | SharedCDRClientRequestDispatcherImpl.java | 142 CorbaMessageMediator messageMediator = null; in marshalingComplete() local
144 messageMediator = (CorbaMessageMediator) in marshalingComplete()
147 orb = (ORB) messageMediator.getBroker(); in marshalingComplete()
150 dprint(".marshalingComplete->: " + opAndId(messageMediator)); in marshalingComplete()
172 messageMediator.setInputObject(cdrInputObject); in marshalingComplete()
173 cdrInputObject.setMessageMediator(messageMediator); in marshalingComplete()
180 ((CorbaMessageMediatorImpl)messageMediator).handleRequestRequest( in marshalingComplete()
181 messageMediator); in marshalingComplete()
215 messageMediator.setInputObject(cdrInputObject); in marshalingComplete()
216 cdrInputObject.setMessageMediator(messageMediator); in marshalingComplete()
[all …]
|
| H A D | CorbaInvocationInfo.java | 49 private MessageMediator messageMediator; field in CorbaInvocationInfo
107 public void setMessageMediator(MessageMediator messageMediator) in setMessageMediator() argument
109 this.messageMediator = messageMediator; in setMessageMediator()
114 return messageMediator; in getMessageMediator()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/transport/ |
| H A D | CorbaResponseWaitingRoomImpl.java | 64 MessageMediator messageMediator; field in CorbaResponseWaitingRoomImpl.OutCallDesc
103 call.messageMediator = messageMediator; in registerWaiter()
134 if (messageMediator.isOneWay()) { in waitForResponse()
140 + opAndId(messageMediator)); in waitForResponse()
160 + opAndId(messageMediator)); in waitForResponse()
169 + opAndId(messageMediator)); in waitForResponse()
237 call.messageMediator; in responseReceived()
241 + opAndId(messageMediator) in responseReceived()
245 messageMediator.setReplyHeader(header); in responseReceived()
246 messageMediator.setInputObject(is); in responseReceived()
[all …]
|
| H A D | CorbaContactInfoBase.java | 130 CorbaMessageMediator messageMediator = in createMessageMediator() local
143 return messageMediator; in createMessageMediator()
176 CorbaMessageMediator messageMediator = in createMessageMediator() local
179 return messageMediator; in createMessageMediator()
184 Connection conn, MessageMediator messageMediator) in finishCreatingMessageMediator() argument
189 (CorbaMessageMediator)messageMediator; in finishCreatingMessageMediator()
211 public OutputObject createOutputObject(MessageMediator messageMediator) in createOutputObject() argument
214 messageMediator; in createOutputObject()
221 messageMediator.setOutputObject(outputObject); in createOutputObject()
226 MessageMediator messageMediator) in createInputObject() argument
[all …]
|
| H A D | SocketOrChannelConnectionImpl.java | 308 if (messageMediator != null) { in read()
311 return dispatch(messageMediator); in read()
329 MessageMediator messageMediator; in readBits() local
332 messageMediator = in readBits()
401 messageMediator = in finishReadingBits()
404 messageMediator = in finishReadingBits()
474 .handleRequest(messageMediator); in dispatch()
1232 messageMediator = finishReadingBits(messageMediator); in doWork()
1234 if (messageMediator != null) { in doWork()
1237 dispatch(messageMediator); in doWork()
[all …]
|
| H A D | SharedCDRContactInfoImpl.java | 115 CorbaMessageMediator messageMediator = in createMessageMediator() local
128 return messageMediator; in createMessageMediator()
131 public OutputObject createOutputObject(MessageMediator messageMediator) in createOutputObject() argument
134 messageMediator; in createOutputObject()
137 sun.corba.OutputStreamFactory.newCDROutputObject(orb, messageMediator, in createOutputObject()
141 messageMediator.setOutputObject(outputObject); in createOutputObject()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/transport/ |
| H A D | CorbaResponseWaitingRoomImpl.java | 64 MessageMediator messageMediator; field in CorbaResponseWaitingRoomImpl.OutCallDesc
103 call.messageMediator = messageMediator; in registerWaiter()
134 if (messageMediator.isOneWay()) { in waitForResponse()
140 + opAndId(messageMediator)); in waitForResponse()
160 + opAndId(messageMediator)); in waitForResponse()
169 + opAndId(messageMediator)); in waitForResponse()
237 call.messageMediator; in responseReceived()
241 + opAndId(messageMediator) in responseReceived()
245 messageMediator.setReplyHeader(header); in responseReceived()
246 messageMediator.setInputObject(is); in responseReceived()
[all …]
|
| H A D | CorbaContactInfoBase.java | 130 CorbaMessageMediator messageMediator = in createMessageMediator() local
143 return messageMediator; in createMessageMediator()
176 CorbaMessageMediator messageMediator = in createMessageMediator() local
179 return messageMediator; in createMessageMediator()
184 Connection conn, MessageMediator messageMediator) in finishCreatingMessageMediator() argument
189 (CorbaMessageMediator)messageMediator; in finishCreatingMessageMediator()
211 public OutputObject createOutputObject(MessageMediator messageMediator) in createOutputObject() argument
214 messageMediator; in createOutputObject()
221 messageMediator.setOutputObject(outputObject); in createOutputObject()
226 MessageMediator messageMediator) in createInputObject() argument
[all …]
|
| H A D | SocketOrChannelConnectionImpl.java | 308 if (messageMediator != null) { in read()
311 return dispatch(messageMediator); in read()
329 MessageMediator messageMediator; in readBits() local
332 messageMediator = in readBits()
401 messageMediator = in finishReadingBits()
404 messageMediator = in finishReadingBits()
474 .handleRequest(messageMediator); in dispatch()
1232 messageMediator = finishReadingBits(messageMediator); in doWork()
1234 if (messageMediator != null) { in doWork()
1237 dispatch(messageMediator); in doWork()
[all …]
|
| H A D | SharedCDRContactInfoImpl.java | 115 CorbaMessageMediator messageMediator = in createMessageMediator() local
128 return messageMediator; in createMessageMediator()
131 public OutputObject createOutputObject(MessageMediator messageMediator) in createOutputObject() argument
134 messageMediator; in createOutputObject()
137 sun.corba.OutputStreamFactory.newCDROutputObject(orb, messageMediator, in createOutputObject()
141 messageMediator.setOutputObject(outputObject); in createOutputObject()
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/spi/protocol/ |
| H A D | CorbaProtocolHandler.java | 48 CorbaMessageMediator messageMediator); in handleRequest() argument
51 CorbaMessageMediator messageMediator); in handleRequest() argument
54 CorbaMessageMediator messageMediator, in createResponse() argument
57 CorbaMessageMediator messageMediator, in createUserExceptionResponse() argument
60 CorbaMessageMediator messageMediator, in createUnknownExceptionResponse() argument
63 CorbaMessageMediator messageMediator, in createSystemExceptionResponse() argument
67 CorbaMessageMediator messageMediator, in createLocationForward() argument
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/spi/protocol/ |
| H A D | CorbaProtocolHandler.java | 48 CorbaMessageMediator messageMediator); in handleRequest() argument
51 CorbaMessageMediator messageMediator); in handleRequest() argument
54 CorbaMessageMediator messageMediator, in createResponse() argument
57 CorbaMessageMediator messageMediator, in createUserExceptionResponse() argument
60 CorbaMessageMediator messageMediator, in createUnknownExceptionResponse() argument
63 CorbaMessageMediator messageMediator, in createSystemExceptionResponse() argument
67 CorbaMessageMediator messageMediator, in createLocationForward() argument
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/interceptors/ |
| H A D | ClientRequestInfoImpl.java | 129 private CorbaMessageMediator messageMediator; field in ClientRequestInfoImpl
175 messageMediator = null; in reset()
287 messageMediator.getContactInfo(); in target()
310 messageMediator.getContactInfo(); in effective_target()
330 messageMediator.getContactInfo(); in effective_profile()
428 messageMediator.getContactInfo(); in get_effective_components()
504 return messageMediator.getRequestId(); in request_id()
697 return ! messageMediator.isOneWay(); in response_expected()
809 messageMediator.getConnection(); in connection()
821 this.messageMediator = (CorbaMessageMediator)messageMediator; in setInfo()
[all …]
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/interceptors/ |
| H A D | ClientRequestInfoImpl.java | 129 private CorbaMessageMediator messageMediator; field in ClientRequestInfoImpl
175 messageMediator = null; in reset()
287 messageMediator.getContactInfo(); in target()
310 messageMediator.getContactInfo(); in effective_target()
330 messageMediator.getContactInfo(); in effective_profile()
428 messageMediator.getContactInfo(); in get_effective_components()
504 return messageMediator.getRequestId(); in request_id()
697 return ! messageMediator.isOneWay(); in response_expected()
809 messageMediator.getConnection(); in connection()
821 this.messageMediator = (CorbaMessageMediator)messageMediator; in setInfo()
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/pept/transport/ |
| H A D | ResponseWaitingRoom.java | 36 public void registerWaiter(MessageMediator messageMediator); in registerWaiter() argument
39 public InputObject waitForResponse(MessageMediator messageMediator); in waitForResponse() argument
43 public void unregisterWaiter(MessageMediator messageMediator); in unregisterWaiter() argument
|
| H A D | Connection.java | 199 public void registerWaiter(MessageMediator messageMediator); in registerWaiter() argument
211 public InputObject waitForResponse(MessageMediator messageMediator); in waitForResponse() argument
220 public void unregisterWaiter(MessageMediator messageMediator); in unregisterWaiter() argument
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/pept/transport/ |
| H A D | ResponseWaitingRoom.java | 36 public void registerWaiter(MessageMediator messageMediator); in registerWaiter() argument
39 public InputObject waitForResponse(MessageMediator messageMediator); in waitForResponse() argument
43 public void unregisterWaiter(MessageMediator messageMediator); in unregisterWaiter() argument
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/encoding/ |
| H A D | CDROutputObject.java | 95 MessageMediator messageMediator, in CDROutputObject() argument
101 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
104 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
108 (CorbaMessageMediator)messageMediator); in CDROutputObject()
115 MessageMediator messageMediator, in CDROutputObject() argument
122 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
129 (CorbaMessageMediator)messageMediator); in CDROutputObject()
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/encoding/ |
| H A D | CDROutputObject.java | 95 MessageMediator messageMediator, in CDROutputObject() argument
101 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
104 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
108 (CorbaMessageMediator)messageMediator); in CDROutputObject()
115 MessageMediator messageMediator, in CDROutputObject() argument
122 ((CorbaMessageMediator)messageMediator).getGIOPVersion(), in CDROutputObject()
129 (CorbaMessageMediator)messageMediator); in CDROutputObject()
|