diff -r 80e1201f6c9a -r a0f39cc47387 test/jdk/jdk/jfr/api/consumer/streaming/TestRepositoryMigration.java --- a/test/jdk/jdk/jfr/api/consumer/streaming/TestRepositoryMigration.java Fri Nov 22 09:06:35 2019 -0500 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,108 +0,0 @@ -/* - * Copyright (c) 2019, 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 - * under the terms of the GNU General Public License version 2 only, as - * published by the Free Software Foundation. Oracle designates this - * particular file as subject to the "Classpath" exception as provided - * by Oracle in the LICENSE file that accompanied this code. - * - * This code is distributed in the hope that it will be useful, but WITHOUT - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or - * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License - * version 2 for more details (a copy is included in the LICENSE file that - * accompanied this code). - * - * You should have received a copy of the GNU General Public License version - * 2 along with this work; if not, write to the Free Software Foundation, - * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. - * - * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA - * or visit www.oracle.com if you need additional information or have any - * questions. - */ - -package jdk.jfr.api.consumer.streaming; - -import java.nio.file.Files; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.time.Duration; -import java.time.Instant; -import java.util.concurrent.CountDownLatch; - -import jdk.jfr.Event; -import jdk.jfr.Recording; -import jdk.jfr.consumer.EventStream; -import jdk.jfr.jcmd.JcmdHelper; - -/** - * @test - * @summary Verifies that is possible to stream from a repository that is being - * moved. - * @key jfr - * @requires vm.hasJFR - * @library /test/lib /test/jdk - * @run main/othervm jdk.jfr.api.consumer.streaming.TestRepositoryMigration - */ -public class TestRepositoryMigration { - static class MigrationEvent extends Event { - int id; - } - - public static void main(String... args) throws Exception { - Path newRepository = Paths.get("new-repository"); - CountDownLatch event1 = new CountDownLatch(1); - CountDownLatch event2 = new CountDownLatch(1); - - try (EventStream es = EventStream.openRepository()) { - es.setStartTime(Instant.EPOCH); - es.onEvent(e -> { - System.out.println(e); - if (e.getInt("id") == 1) { - event1.countDown(); - } - if (e.getInt("id") == 2) { - event2.countDown(); - } - }); - es.startAsync(); - System.out.println("Started es.startAsync()"); - - try (Recording r = new Recording()) { - r.setFlushInterval(Duration.ofSeconds(1)); - r.start(); - // Chunk in default repository - MigrationEvent e1 = new MigrationEvent(); - e1.id = 1; - e1.commit(); - event1.await(); - System.out.println("Passed the event1.await()"); - JcmdHelper.jcmd("JFR.configure", "repositorypath=" + newRepository.toAbsolutePath()); - // Chunk in new repository - MigrationEvent e2 = new MigrationEvent(); - e2.id = 2; - e2.commit(); - r.stop(); - event2.await(); - System.out.println("Passed the event2.await()"); - // Verify that it happened in new repository - if (!Files.exists(newRepository)) { - throw new AssertionError("Could not find repository " + newRepository); - } - System.out.println("Listing contents in new repository:"); - boolean empty = true; - for (Path p : Files.newDirectoryStream(newRepository)) { - System.out.println(p.toAbsolutePath()); - empty = false; - } - System.out.println(); - if (empty) { - throw new AssertionError("Could not find contents in new repository location " + newRepository); - } - } - } - } - -}