1 /* 2 * Copyright (c) 2013, 2018, 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.internal.instrument; 27 28 import java.io.IOException; 29 import java.net.InetAddress; 30 31 import jdk.jfr.events.SocketWriteEvent; 32 33 /** 34 * See {@link JITracer} for an explanation of this code. 35 */ 36 @JIInstrumentationTarget("java.net.SocketOutputStream") 37 @JITypeMapping(from = "jdk.jfr.internal.instrument.SocketOutputStreamInstrumentor$AbstractPlainSocketImpl", 38 to = "java.net.AbstractPlainSocketImpl") 39 final class SocketOutputStreamInstrumentor { 40 41 private SocketOutputStreamInstrumentor() { 42 } 43 44 @SuppressWarnings("deprecation") 45 @JIInstrumentationMethod 46 private void socketWrite(byte b[], int off, int len) throws IOException { 47 SocketWriteEvent event = SocketWriteEvent.EVENT.get(); 48 if (!event.isEnabled()) { 49 socketWrite(b, off, len); 50 return; 51 } 52 int bytesWritten = 0; 53 try { 54 event.begin(); 55 socketWrite(b, off, len); 56 bytesWritten = len; 57 } finally { 58 event.end() ; 59 if (event.shouldCommit()) { 60 String hostString = impl.address.toString(); 61 int delimiterIndex = hostString.lastIndexOf('/'); 62 63 event.host = hostString.substring(0, delimiterIndex); 64 event.address = hostString.substring(delimiterIndex + 1); 65 event.port = impl.port; 66 event.bytesWritten = bytesWritten < 0 ? 0 : bytesWritten; 67 68 event.commit(); 69 event.reset(); 70 } 71 } 72 } 73 74 private AbstractPlainSocketImpl impl = null; 75 76 void silenceFindBugsUnwrittenField(InetAddress dummy) { 77 impl.address = dummy; 78 } 79 80 static class AbstractPlainSocketImpl { 81 InetAddress address; 82 int port; 83 } 84 }