1 /* 2 * Copyright (c) 2013, 2019, Oracle and/or its affiliates. All rights reserved. 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4 * 5 * This code is free software; you can redistribute it and/or modify it 6 * under the terms of the GNU General Public License version 2 only, as 7 * published by the Free Software Foundation. Oracle designates this 8 * particular file as subject to the "Classpath" exception as provided 9 * by Oracle in the LICENSE file that accompanied this code. 10 * 11 * This code is distributed in the hope that it will be useful, but WITHOUT 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 14 * version 2 for more details (a copy is included in the LICENSE file that 15 * accompanied this code). 16 * 17 * You should have received a copy of the GNU General Public License version 18 * 2 along with this work; if not, write to the Free Software Foundation, 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 20 * 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 22 * or visit www.oracle.com if you need additional information or have any 23 * questions. 24 */ 25 26 package jdk.jfr.event.gc.objectcount; 27 28 import java.util.List; 29 import java.util.Optional; 30 import java.util.stream.Collectors; 31 32 import jdk.jfr.Recording; 33 import jdk.jfr.consumer.RecordedEvent; 34 import jdk.testlibrary.Asserts; 35 import jdk.testlibrary.jfr.EventNames; 36 import jdk.testlibrary.jfr.Events; 37 38 39 public class ObjectCountAfterGCEvent { 40 41 private static final String objectCountEventPath = EventNames.ObjectCountAfterGC; 42 private static final String gcEventPath = EventNames.GarbageCollection; 43 private static final String heapSummaryEventPath = EventNames.GCHeapSummary; 44 45 public static void test(String gcName) throws Exception { 46 Recording recording = new Recording(); 47 recording.enable(objectCountEventPath); 48 recording.enable(gcEventPath); 49 recording.enable(heapSummaryEventPath); 50 51 ObjectCountEventVerifier.createTestData(); 52 recording.start(); 53 System.gc(); 54 System.gc(); 55 recording.stop(); 56 57 System.out.println("gcName=" + gcName); 58 for (RecordedEvent event : Events.fromRecording(recording)) { 59 System.out.println("Event: " + event); 60 } 61 62 List<RecordedEvent> events= Events.fromRecording(recording); 63 Optional<RecordedEvent> gcEvent = events.stream() 64 .filter(e -> isMySystemGc(e, gcName)) 65 .findFirst(); 66 Asserts.assertTrue(gcEvent.isPresent(), "No event System.gc event of type " + gcEventPath); 67 System.out.println("Found System.gc event: " + gcEvent.get()); 68 int gcId = Events.assertField(gcEvent.get(), "gcId").getValue(); 69 70 List<RecordedEvent> objCountEvents = events.stream() 71 .filter(e -> Events.isEventType(e, objectCountEventPath)) 72 .filter(e -> isGcId(e, gcId)) 73 .collect(Collectors.toList()); 74 Asserts.assertFalse(objCountEvents.isEmpty(), "No objCountEvents for gcId=" + gcId); 75 76 Optional<RecordedEvent> heapSummaryEvent = events.stream() 77 .filter(e -> Events.isEventType(e, heapSummaryEventPath)) 78 .filter(e -> isGcId(e, gcId)) 79 .filter(e -> "After GC".equals(Events.assertField(e, "when").getValue())) 80 .findFirst(); 81 Asserts.assertTrue(heapSummaryEvent.isPresent(), "No heapSummary for gcId=" + gcId); 82 System.out.println("Found heapSummaryEvent: " + heapSummaryEvent.get()); 83 84 Events.assertField(heapSummaryEvent.get(), "heapUsed").atLeast(0L).getValue(); 85 ObjectCountEventVerifier.verify(objCountEvents); 86 } 87 88 private static boolean isGcId(RecordedEvent event, int gcId) { 89 return gcId == (int)Events.assertField(event, "gcId").getValue(); 90 } 91 92 private static boolean isMySystemGc(RecordedEvent event, String gcName) { 93 return Events.isEventType(event, gcEventPath) && 94 gcName.equals(Events.assertField(event, "name").getValue()) && 95 "System.gc()".equals(Events.assertField(event, "cause").getValue()); 96 } 97 98 }