--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/test/hotspot/jtreg/vmTestbase/nsk/share/jdwp/Transport.java Wed May 30 20:54:45 2018 -0700
@@ -0,0 +1,153 @@
+/*
+ * Copyright (c) 2001, 2018, 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.
+ *
+ * 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 nsk.share.jdwp;
+
+import nsk.share.*;
+
+import java.io.IOException;
+//import java.util.Vector;
+
+/**
+ * This class represents an abstract transport for JDWP.
+ */
+public abstract class Transport extends Log.Logger {
+
+ public static final String LOG_PREFIX = "transport> ";
+
+ /**
+ * Make base <code>Transport</code> object providing with specified Log.
+ */
+ public Transport(Log log) {
+ super(log, LOG_PREFIX);
+ }
+
+ /**
+ * Return number of bytes that can be received.
+ */
+ public abstract int available() throws IOException;
+
+ /**
+ * Flushe bytes being buffered for writing if any.
+ */
+ public abstract void flush() throws IOException;
+
+ /**
+ * Receive the next byte of data.
+ *
+ * The value byte is returned as an int in the range 0 to 255.
+ * If no byte is available, the value -1 is returned.
+ */
+ public abstract byte read() throws IOException;
+
+ /**
+ * Send the specified byte.
+ */
+ public abstract void write(int b) throws IOException;
+
+ /**
+ * Send the specified bytes.
+ */
+ public void write(byte[] b, int off, int len) throws IOException {
+ for (int i = 0; i < len; i++)
+ write(b[off + i]);
+ }
+
+ /**
+ * Receive bytes of JDWP packet for default timeout.
+ */
+ public void read(Packet packet) throws IOException {
+ packet.readFrom(this);
+ }
+
+ /**
+ * Send and flushe bytes of JDWP packet.
+ */
+ public void write(Packet packet) throws IOException {
+ packet.writeTo(this);
+ flush();
+ }
+
+ /**
+ * Perform JDWP "handshake" procedure.
+ */
+ public void handshake() throws IOException {
+
+ String hs = "JDWP-Handshake";
+ byte[] hsb = hs.getBytes();
+
+ write(hsb, 0, hsb.length);
+ flush();
+
+ try {
+ Thread.currentThread().sleep(500);
+ } catch (InterruptedException e) {
+ throw new Failure(e);
+ }
+
+ int received = 0;
+ for (int i = 0; i < Binder.CONNECT_TRIES; i++) {
+ received = available();
+ if (received < hsb.length) {
+// System.err.println("Failed to hadshake try #" + i + ", bytes: " + received);
+ try {
+ Thread.currentThread().sleep(Binder.CONNECT_TRY_DELAY);
+ } catch (InterruptedException e) {
+ throw new Failure("Thread interrupted while sleeping between connection attempts:\n\t"
+ + e);
+ }
+ } else {
+// System.err.println("Successed to hadshake try #" + i + ", bytes: " + received);
+ for (int j = 0; j < hsb.length; j++) {
+ byte b = (byte) (read() & 0xFF);
+ if (b != hsb[j])
+ throw new IOException("Target VM failed to handshake: unexpected byte #" + j
+ + ": " + b + " (expected:" + hsb[j] + ")");
+ }
+ return;
+ }
+ }
+
+ throw new IOException("Target VM failed to handshake: too few bytes in reply: "
+ + received + "(expected: " + hsb.length + ")");
+ }
+
+ /**
+ * Set timeout for reading data in milliseconds.
+ * Timeout of 0 means wait infinitly.
+ */
+ public abstract void setReadTimeout(long millisecs) throws IOException;
+
+ /**
+ * Close JDWP connection.
+ */
+ public abstract void close() throws IOException;
+
+ /**
+ * Perform finalization of object by closing JDWP connection.
+ */
+ protected void finalize() throws Throwable {
+ close();
+ }
+
+}