test/java/rmi/testlibrary/StreamPipe.java

Print this page


   1 /*
   2  * Copyright (c) 1998, 1999, 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.
   8  *
   9  * This code is distributed in the hope that it will be useful, but WITHOUT
  10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  12  * version 2 for more details (a copy is included in the LICENSE file that
  13  * accompanied this code).
  14  *
  15  * You should have received a copy of the GNU General Public License version
  16  * 2 along with this work; if not, write to the Free Software Foundation,
  17  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  18  *
  19  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  20  * or visit www.oracle.com if you need additional information or have any
  21  * questions.
  22  */


  96 
  97             /* This is to check that the distant vm has started,
  98              * if such a vm has been provided at construction :
  99              * - As soon as we can read something from r BufferedReader,
 100              *   that means the distant vm is already started.
 101              * Thus we signal associated JavaVM object that it is now started.
 102              */
 103             if (((line = r.readLine()) != null) &&
 104                 (javaVM != null)) {
 105                 javaVM.setStarted();
 106             }
 107 
 108             // Redirects r on w.
 109             while (line != null) {
 110                 w.write(preamble);
 111                 w.write(line);
 112                 w.newLine();
 113                 w.flush();
 114                 line = r.readLine();
 115             }
 116 


 117         } catch (IOException e) {
 118             System.err.println("*** IOException in StreamPipe.run:");
 119             e.printStackTrace();
 120         }
 121     }
 122 
 123 }
   1 /*
   2  * Copyright (c) 1998, 2012, 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.
   8  *
   9  * This code is distributed in the hope that it will be useful, but WITHOUT
  10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  12  * version 2 for more details (a copy is included in the LICENSE file that
  13  * accompanied this code).
  14  *
  15  * You should have received a copy of the GNU General Public License version
  16  * 2 along with this work; if not, write to the Free Software Foundation,
  17  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  18  *
  19  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  20  * or visit www.oracle.com if you need additional information or have any
  21  * questions.
  22  */


  96 
  97             /* This is to check that the distant vm has started,
  98              * if such a vm has been provided at construction :
  99              * - As soon as we can read something from r BufferedReader,
 100              *   that means the distant vm is already started.
 101              * Thus we signal associated JavaVM object that it is now started.
 102              */
 103             if (((line = r.readLine()) != null) &&
 104                 (javaVM != null)) {
 105                 javaVM.setStarted();
 106             }
 107 
 108             // Redirects r on w.
 109             while (line != null) {
 110                 w.write(preamble);
 111                 w.write(line);
 112                 w.newLine();
 113                 w.flush();
 114                 line = r.readLine();
 115             }
 116         } catch (InterruptedIOException iioe) {
 117             // Thread interrupted during IO operation. Terminate StreamPipe.
 118             return;
 119         } catch (IOException e) {
 120             System.err.println("*** IOException in StreamPipe.run:");
 121             e.printStackTrace();
 122         }
 123     }
 124 
 125 }