infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-04-14 17:08:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Stuart's review - no need to write start time in a file

Browse Source
This commit is contained in:
Jaikiran Pai 2026-01-29 15:45:54 +05:30
parent 3df9d3597c
commit 2cf9553718
2 changed files with 16 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
test/jdk/java/rmi/server/Unreferenced/leaseCheckInterval/LeaseCheckInterval.java
View File

@ -44,8 +44,6 @@
* @run main/othervm LeaseCheckInterval
*/
import java.nio.file.Files;
import java.nio.file.Path;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.registry.Registry;
@ -96,26 +94,25 @@ public class LeaseCheckInterval implements Remote, Unreferenced {
localRegistry.bind(BINDING, obj);
System.err.println("bound remote object in local registry");
Path outputFile = Files.createTempFile(Path.of("."), "4285878-", ".txt");
System.err.println("starting remote client VM...");
jvm = new JavaVM("SelfTerminator", "-Drmi.registry.port=" +
registryPort, outputFile.toAbsolutePath().toString());
jvm = new JavaVM("SelfTerminator", "-Drmi.registry.port=" + registryPort, "");
// launch the self terminating java application which will lookup
// the bound object and then terminate itself. before terminating
// it will write the time at which it is terminating, into the
// output file
// the bound object (thus creating a lease) and then terminate itself (thus
// creating the condition for a lease expiry).
jvm.start();
System.err.println("waiting for unreferenced() callback...");
final Instant startTime = Instant.now();
System.err.println("waiting for SelfTerminator process to complete");
final int exitCode = jvm.waitFor();
if (exitCode != 0) {
throw new AssertionError("SelfTerminator process exited with" +
" a non-zero exit code: " + exitCode);
}
System.err.println("SelfTerminator process completed in "
+ Duration.between(startTime, Instant.now())
+ ", now waiting for Unreferenced.unreferenced() callback to be invoked");
callbackInvocationLatch.await();
Instant waitEndedAt = Instant.now();
final String content = Files.readString(outputFile);
System.err.println("content in " + outputFile + ": " + content);
// parse the time, representing the time at which the SelfTerminator
// application termination started
final Instant terminationStartedAt = Instant.parse(content);
final Duration waitDuration = assertWithinExpectedTimeLimit(waitEndedAt,
terminationStartedAt);
final Instant waitEndedAt = Instant.now();
final Duration waitDuration = assertWithinExpectedTimeLimit(waitEndedAt, startTime);
System.err.println("TEST PASSED: unreferenced() invoked in timely" +
" fashion (duration=" + waitDuration + ")");
} finally {

8
test/jdk/java/rmi/server/Unreferenced/leaseCheckInterval/SelfTerminator.java
View File

@ -1,5 +1,5 @@
/*
* Copyright (c) 2001, 2025, Oracle and/or its affiliates. All rights reserved.
* Copyright (c) 2001, 2026, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
@ -21,8 +21,6 @@
* questions.
*/
import java.nio.file.Files;
import java.nio.file.Path;
import java.rmi.Remote;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
@ -33,16 +31,12 @@ public class SelfTerminator {
public static void main(String[] args) throws Exception {
try {
log("main() invoked");
Path outputFile = Path.of(args[0]);
log("output file " + outputFile);
int registryPort =
Integer.parseInt(System.getProperty("rmi.registry.port"));
Registry registry =
LocateRegistry.getRegistry("", registryPort);
Remote stub = registry.lookup(LeaseCheckInterval.BINDING);
log("looked up binding, now terminating the process");
// write out the time at which we are terminating the process
Files.writeString(outputFile, Instant.now().toString());
Runtime.getRuntime().halt(0);
} catch (Throwable t) {
log("failure: " + t);