test/jdk/jdk/jfr/api/consumer/streaming/TestRepositoryMigration.java
changeset 59226 a0f39cc47387
parent 59225 80e1201f6c9a
child 59227 46084917fde7
--- 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);
-                }
-            }
-        }
-    }
-
-}