Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
JDK 11 java.rmi.jmod - RMI Module
JDK 11 java.rmi.jmod is the JMOD file for JDK 11 RMI (Remote Method Invocation) module.
JDK 11 RMI module compiled class files are stored in \fyicenter\jdk-11.0.1\jmods\java.rmi.jmod.
JDK 11 RMI module compiled class files are also linked and stored in the \fyicenter\jdk-11.0.1\lib\modules JImage file.
JDK 11 RMI module source code files are stored in \fyicenter\jdk-11.0.1\lib\src.zip\java.rmi.
You can click and view the content of each source code file in the list below.
✍: FYIcenter
⏎ sun/rmi/transport/StreamRemoteCall.java
/* * Copyright (c) 1996, 2017, Oracle and/or its affiliates. All rights reserved. * ORACLE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms. * * * * * * * * * * * * * * * * * * * * */ package sun.rmi.transport; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; import java.io.StreamCorruptedException; import java.rmi.RemoteException; import java.rmi.MarshalException; import java.rmi.UnmarshalException; import java.rmi.server.ObjID; import java.rmi.server.RemoteCall; import sun.rmi.runtime.Log; import sun.rmi.server.UnicastRef; import sun.rmi.transport.tcp.TCPEndpoint; /** * Stream-based implementation of the RemoteCall interface. * * @author Ann Wollrath */ @SuppressWarnings("deprecation") public class StreamRemoteCall implements RemoteCall { private ConnectionInputStream in = null; private ConnectionOutputStream out = null; private Connection conn; private boolean resultStarted = false; private Exception serverException = null; public StreamRemoteCall(Connection c) { conn = c; } public StreamRemoteCall(Connection c, ObjID id, int op, long hash) throws RemoteException { try { conn = c; Transport.transportLog.log(Log.VERBOSE, "write remote call header..."); // write out remote call header info... // call header, part 1 (read by Transport) conn.getOutputStream().write(TransportConstants.Call); getOutputStream(); // creates a MarshalOutputStream id.write(out); // object id (target of call) // call header, part 2 (read by Dispatcher) out.writeInt(op); // method number (operation index) out.writeLong(hash); // stub/skeleton hash } catch (IOException e) { throw new MarshalException("Error marshaling call header", e); } } /** * Return the connection associated with this call. */ public Connection getConnection() { return conn; } /** * Return the output stream the stub/skeleton should put arguments/results * into. */ public ObjectOutput getOutputStream() throws IOException { return getOutputStream(false); } private ObjectOutput getOutputStream(boolean resultStream) throws IOException { if (out == null) { Transport.transportLog.log(Log.VERBOSE, "getting output stream"); out = new ConnectionOutputStream(conn, resultStream); } return out; } /** * Release the outputStream Currently, will not complain if the * output stream is released more than once. */ public void releaseOutputStream() throws IOException { try { if (out != null) { try { out.flush(); } finally { out.done(); // always start DGC ack timer } } conn.releaseOutputStream(); } finally { out = null; } } /** * Get the InputStream the stub/skeleton should get results/arguments * from. */ public ObjectInput getInputStream() throws IOException { if (in == null) { Transport.transportLog.log(Log.VERBOSE, "getting input stream"); in = new ConnectionInputStream(conn.getInputStream()); } return in; } /** * Release the input stream, this would allow some transports to release * the channel early. */ public void releaseInputStream() throws IOException { /* WARNING: Currently, the UnicastRef.java invoke methods rely * upon this method not throwing an IOException. */ try { if (in != null) { // execute MarshalInputStream "done" callbacks try { in.done(); } catch (RuntimeException e) { } // add saved references to DGC table in.registerRefs(); /* WARNING: The connection being passed to done may have * already been freed. */ in.done(conn); } conn.releaseInputStream(); } finally { in = null; } } /** * Discard any post-processing of refs the InputStream. */ public void discardPendingRefs() { in.discardRefs(); } /** * Returns an output stream (may put out header information * relating to the success of the call). * @param success If true, indicates normal return, else indicates * exceptional return. * @exception StreamCorruptedException If result stream previously * acquired * @exception IOException For any other problem with I/O. */ public ObjectOutput getResultStream(boolean success) throws IOException { /* make sure result code only marshaled once. */ if (resultStarted) throw new StreamCorruptedException("result already in progress"); else resultStarted = true; // write out return header // return header, part 1 (read by Transport) DataOutputStream wr = new DataOutputStream(conn.getOutputStream()); wr.writeByte(TransportConstants.Return);// transport op getOutputStream(true); // creates a MarshalOutputStream // return header, part 2 (read by client-side RemoteCall) if (success) // out.writeByte(TransportConstants.NormalReturn); else out.writeByte(TransportConstants.ExceptionalReturn); out.writeID(); // write id for gcAck return out; } /** * Do whatever it takes to execute the call. */ @SuppressWarnings("fallthrough") public void executeCall() throws Exception { byte returnType; // read result header DGCAckHandler ackHandler = null; try { if (out != null) { ackHandler = out.getDGCAckHandler(); } releaseOutputStream(); DataInputStream rd = new DataInputStream(conn.getInputStream()); byte op = rd.readByte(); if (op != TransportConstants.Return) { if (Transport.transportLog.isLoggable(Log.BRIEF)) { Transport.transportLog.log(Log.BRIEF, "transport return code invalid: " + op); } throw new UnmarshalException("Transport return code invalid"); } getInputStream(); returnType = in.readByte(); in.readID(); // id for DGC acknowledgement } catch (UnmarshalException e) { throw e; } catch (IOException e) { throw new UnmarshalException("Error unmarshaling return header", e); } finally { if (ackHandler != null) { ackHandler.release(); } } // read return value switch (returnType) { case TransportConstants.NormalReturn: break; case TransportConstants.ExceptionalReturn: Object ex; try { ex = in.readObject(); } catch (Exception e) { throw new UnmarshalException("Error unmarshaling return", e); } // An exception should have been received, // if so throw it, else flag error if (ex instanceof Exception) { exceptionReceivedFromServer((Exception) ex); } else { throw new UnmarshalException("Return type not Exception"); } // Exception is thrown before fallthrough can occur default: if (Transport.transportLog.isLoggable(Log.BRIEF)) { Transport.transportLog.log(Log.BRIEF, "return code invalid: " + returnType); } throw new UnmarshalException("Return code invalid"); } } /** * Routine that causes the stack traces of remote exceptions to be * filled in with the current stack trace on the client. Detail * exceptions are filled in iteratively. */ protected void exceptionReceivedFromServer(Exception ex) throws Exception { serverException = ex; StackTraceElement[] serverTrace = ex.getStackTrace(); StackTraceElement[] clientTrace = (new Throwable()).getStackTrace(); StackTraceElement[] combinedTrace = new StackTraceElement[serverTrace.length + clientTrace.length]; System.arraycopy(serverTrace, 0, combinedTrace, 0, serverTrace.length); System.arraycopy(clientTrace, 0, combinedTrace, serverTrace.length, clientTrace.length); ex.setStackTrace(combinedTrace); /* * Log the details of a server exception thrown as a result of a * remote method invocation. */ if (UnicastRef.clientCallLog.isLoggable(Log.BRIEF)) { /* log call exception returned from server before it is rethrown */ TCPEndpoint ep = (TCPEndpoint) conn.getChannel().getEndpoint(); UnicastRef.clientCallLog.log(Log.BRIEF, "outbound call " + "received exception: [" + ep.getHost() + ":" + ep.getPort() + "] exception: ", ex); } throw ex; } /* * method to retrieve possible server side exceptions (which will * be throw from exceptionReceivedFromServer(...) ) */ public Exception getServerException() { return serverException; } public void done() throws IOException { /* WARNING: Currently, the UnicastRef.java invoke methods rely * upon this method not throwing an IOException. */ releaseInputStream(); } }
⏎ sun/rmi/transport/StreamRemoteCall.java
Or download all of them as a single archive file:
File name: java.rmi-11.0.1-src.zip File size: 275032 bytes Release date: 2018-11-04 Download
⇒ JDK 11 java.scripting.jmod - Scripting Module
2023-10-10, 37364👍, 1💬
Popular Posts:
What Is commons-logging-1.2.jar? commons-logging-1.2.jar is the JAR file for Apache Commons Logging ...
Apache Log4j provides the interface that applications should code to and provides the adapter compon...
JDOM provides a solution for using XML from Java that is as simple as Java itself. There is no compe...
JDK 17 jdk.compiler.jmod is the JMOD file for JDK 17 Compiler tool, which can be invoked by the "jav...
What Is commons-codec-1.4.jar? commons-codec-1.4.jar is the JAR file for Apache Commons Codec 1.4, w...