application/tests/org.openjdk.jmc.rjmx.services.jfr.test/src/test/java/org/openjdk/jmc/rjmx/services/jfr/test/JfrControlTest.java

*** 89,109 ****
          public void testStartTimedRecording() throws Exception {
                  assumeHotSpot7u12OrLater(getConnectionHandle());
  
                  IQuantity duration = MILLISECOND.quantity(5000);
                  Random rnd = new Random();
!                 String name = "test_recording_" + rnd.nextInt() % 4711; //$NON-NLS-1$
                  IFlightRecorderService service = getFlightRecorderService();
                  IConstrainedMap<String> recordingOptions = new RecordingOptionsBuilder(service).name(name).duration(duration)
                                  .build();
                  IRecordingDescriptor recording = service.start(recordingOptions, null);
                  IConstrainedMap<String> options = service.getRecordingOptions(recording);
                  Object durationOption = options.get(RecordingOptionsBuilder.KEY_DURATION);
                  assertNotNull(durationOption);
                  assertSame(duration, (IQuantity) durationOption);
                  assertEquals(IRecordingDescriptor.RecordingState.RUNNING, recording.getState());
!                 System.out.println("Started " + recording.getName()); //$NON-NLS-1$
                  assertEquals(name, recording.getName());
  
                  service.stop(recording);
                  for (int stopCount = 0; stopCount < 15; stopCount += 1) {
                          recording = service.getUpdatedRecordingDescription(recording);
--- 89,109 ----
          public void testStartTimedRecording() throws Exception {
                  assumeHotSpot7u12OrLater(getConnectionHandle());
  
                  IQuantity duration = MILLISECOND.quantity(5000);
                  Random rnd = new Random();
!                 String name = "test_recording_" + rnd.nextInt() % 4711;
                  IFlightRecorderService service = getFlightRecorderService();
                  IConstrainedMap<String> recordingOptions = new RecordingOptionsBuilder(service).name(name).duration(duration)
                                  .build();
                  IRecordingDescriptor recording = service.start(recordingOptions, null);
                  IConstrainedMap<String> options = service.getRecordingOptions(recording);
                  Object durationOption = options.get(RecordingOptionsBuilder.KEY_DURATION);
                  assertNotNull(durationOption);
                  assertSame(duration, (IQuantity) durationOption);
                  assertEquals(IRecordingDescriptor.RecordingState.RUNNING, recording.getState());
!                 System.out.println("Started " + recording.getName());
                  assertEquals(name, recording.getName());
  
                  service.stop(recording);
                  for (int stopCount = 0; stopCount < 15; stopCount += 1) {
                          recording = service.getUpdatedRecordingDescription(recording);
*** 111,121 ****
                                  break;
                          }
                          Thread.sleep(1000);
                  }
                  assertEquals(IRecordingDescriptor.RecordingState.STOPPED, recording.getState());
!                 System.out.println("Stopped " + recording.getName()); //$NON-NLS-1$
                  service.close(recording);
                  recording = service.getUpdatedRecordingDescription(recording);
                  assertNull(recording);
          }
  
--- 111,121 ----
                                  break;
                          }
                          Thread.sleep(1000);
                  }
                  assertEquals(IRecordingDescriptor.RecordingState.STOPPED, recording.getState());
!                 System.out.println("Stopped " + recording.getName());
                  service.close(recording);
                  recording = service.getUpdatedRecordingDescription(recording);
                  assertNull(recording);
          }
  
*** 140,149 ****
                  InputStream stream = service.openStream(descriptor, false);
                  int lastRead = -1;
                  while ((lastRead = stream.read(bytes)) != -1) {
                          read += lastRead;
                  }
!                 assertMin("Should have read something!", 1, read); //$NON-NLS-1$
                  stream.close();
                  stopRecording(recording);
          }
  }
--- 140,149 ----
                  InputStream stream = service.openStream(descriptor, false);
                  int lastRead = -1;
                  while ((lastRead = stream.read(bytes)) != -1) {
                          read += lastRead;
                  }
!                 assertMin("Should have read something!", 1, read);
                  stream.close();
                  stopRecording(recording);
          }
  }