jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: PipedConnection_Test.java,v $
  10  * $Revision: 1.5 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 package com.sun.star.comp.connections;
  32
  33 import complexlib.ComplexTestCase;
  34
  35 public final class PipedConnection_Test extends ComplexTestCase {
  36     public String getTestObjectName() {
  37         return getClass().getName();
  38     }
  39
  40     public String[] getTestMethodNames() {
  41         return new String[] { "test" };
  42     }
  43
  44     public void test() throws Exception {
  45         PipedConnection rightSide = new PipedConnection(new Object[0]);
  46         PipedConnection leftSide = new PipedConnection(new Object[]{rightSide});
  47
  48         byte theByte[] = new byte[1];
  49
  50         Reader reader = new Reader(rightSide, theByte);
  51         Writer writer = new Writer(leftSide, theByte, reader);
  52
  53         reader.start();
  54         writer.start();
  55
  56         Thread.sleep(2000);
  57
  58         writer.term();
  59         writer.join();
  60
  61         reader.join();
  62
  63         assure("", writer._state && reader._state);
  64     }
  65
  66     static class Reader extends Thread {
  67         PipedConnection _pipedConnection;
  68         byte _theByte[];
  69         boolean _quit;
  70         boolean _state = false;
  71
  72         Reader(PipedConnection pipedConnection, byte theByte[]) {
  73             _pipedConnection = pipedConnection;
  74             _theByte = theByte;
  75         }
  76
  77         public void run() {
  78             try {
  79                 byte bytes[][] = new byte[1][];
  80
  81                 while(!_quit) {
  82                     int read = _pipedConnection.read(bytes, 1);
  83
  84                     if(read == 1) {
  85 //                          System.err.println("read :" + bytes[0][0]);
  86
  87                         if(_theByte[0] != bytes[0][0])
  88                             throw new NullPointerException();
  89
  90                         synchronized(this) {
  91                             notifyAll();
  92                         }
  93                     }
  94                     else
  95                         _quit = true; // EOF
  96                 }
  97
  98                 _pipedConnection.close();
  99                 _state = true;
 100             }
 101             catch(com.sun.star.io.IOException ioException) {
 102                 System.err.println("#### Reader - unexpected:" + ioException);
 103             }
 104
 105         }
 106     }
 107
 108     static class Writer extends Thread {
 109         PipedConnection _pipedConnection;
 110         byte _theByte[];
 111         Reader _reader;
 112         boolean _quit;
 113         boolean _state = false;
 114
 115         Writer(PipedConnection pipedConnection, byte theByte[], Reader reader) {
 116             _pipedConnection = pipedConnection;
 117             _reader = reader;
 118             _theByte = theByte;
 119         }
 120
 121         public void run() {
 122             try {
 123                 while(!_quit) {
 124                     synchronized(_reader) {
 125                         _pipedConnection.write(_theByte);
 126                         _pipedConnection.flush();
 127 //                          System.err.println("written :" + _theByte[0]);
 128
 129                         _reader.wait();
 130                     }
 131                     ++ _theByte[0];
 132                 }
 133
 134                 _pipedConnection.close();
 135
 136                 _state = true;
 137             }
 138             catch(com.sun.star.io.IOException ioException) {
 139                 System.err.println("#### Writer:" + ioException);
 140             }
 141             catch(InterruptedException interruptedException) {
 142                 System.err.println("#### Writer:" + interruptedException);
 143             }
 144         }
 145
 146         public void term() {
 147             _quit = true;
 148         }
 149     }
 150 }