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 17 java.rmi.jmod - RMI Module
JDK 17 java.rmi.jmod is the JMOD file for JDK 17 RMI (Remote Method Invocation) module.
JDK 17 RMI module compiled class files are stored in \fyicenter\jdk-17.0.5\jmods\java.rmi.jmod.
JDK 17 RMI module compiled class files are also linked and stored in the \fyicenter\jdk-17.0.5\lib\modules JImage file.
JDK 17 RMI module source code files are stored in \fyicenter\jdk-17.0.5\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, 2021, 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.ObjectInputFilter; 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 java.security.AccessController; import java.security.PrivilegedAction; 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 ObjectInputFilter filter = null; 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; } } public void setObjectInputFilter(ObjectInputFilter filter) { if (in != null) { throw new IllegalStateException("set filter must occur before calling getInputStream"); } this.filter = filter; } /** * Get the InputStream the stub/skeleton should get results/arguments * from. */ @SuppressWarnings("removal") public ObjectInput getInputStream() throws IOException { if (in == null) { Transport.transportLog.log(Log.VERBOSE, "getting input stream"); in = new ConnectionInputStream(conn.getInputStream()); if (filter != null) { AccessController.doPrivileged((PrivilegedAction<Void>) () -> { in.setObjectInputFilter(filter); return null; }); } } 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) { discardPendingRefs(); 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 { discardPendingRefs(); 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-17.0.5-src.zip File size: 220001 bytes Release date: 2022-09-13 Download
⇒ JDK 17 java.scripting.jmod - Scripting Module
2023-11-06, 10017👍, 0💬
Popular Posts:
What Is poi-scratchpad-5.2.3.jar ?poi-scratchpad-5.2.3.jar is one of the JAR files for Apache POI 5....
JDK 6 tools.jar is the JAR file for JDK 6 tools. It contains Java classes to support different JDK t...
How to download and install ojdbc11.jar for Oracle 21c? ojdbc11.jar for Oracle 21c is a Java JDBC Dr...
XStream is a simple library to serialize objects to XML and back again. JAR File Size and Download L...
JDK 11 jdk.xml.dom.jmod is the JMOD file for JDK 11 XML DOM module. JDK 11 XML DOM module compiled c...