diff options
Diffstat (limited to 'jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java')
-rw-r--r-- | jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java | 147 |
1 files changed, 0 insertions, 147 deletions
diff --git a/jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java b/jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java deleted file mode 100644 index 41a2e56f3..000000000 --- a/jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java +++ /dev/null @@ -1,147 +0,0 @@ -/************************************************************************* - * - * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. - * - * Copyright 2000, 2010 Oracle and/or its affiliates. - * - * OpenOffice.org - a multi-platform office productivity suite - * - * This file is part of OpenOffice.org. - * - * OpenOffice.org is free software: you can redistribute it and/or modify - * it under the terms of the GNU Lesser General Public License version 3 - * only, as published by the Free Software Foundation. - * - * OpenOffice.org 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 Lesser General Public License version 3 for more details - * (a copy is included in the LICENSE file that accompanied this code). - * - * You should have received a copy of the GNU Lesser General Public License - * version 3 along with OpenOffice.org. If not, see - * <http://www.openoffice.org/license.html> - * for a copy of the LGPLv3 License. - * - ************************************************************************/ - -package com.sun.star.comp.connections; - -import complexlib.ComplexTestCase; - -public final class PipedConnection_Test extends ComplexTestCase { - public String getTestObjectName() { - return getClass().getName(); - } - - public String[] getTestMethodNames() { - return new String[] { "test" }; - } - - public void test() throws Exception { - PipedConnection rightSide = new PipedConnection(new Object[0]); - PipedConnection leftSide = new PipedConnection(new Object[]{rightSide}); - - byte theByte[] = new byte[1]; - - Reader reader = new Reader(rightSide, theByte); - Writer writer = new Writer(leftSide, theByte, reader); - - reader.start(); - writer.start(); - - Thread.sleep(2000); - - writer.term(); - writer.join(); - - reader.join(); - - assure("", writer._state && reader._state); - } - - static class Reader extends Thread { - PipedConnection _pipedConnection; - byte _theByte[]; - boolean _quit; - boolean _state = false; - - Reader(PipedConnection pipedConnection, byte theByte[]) { - _pipedConnection = pipedConnection; - _theByte = theByte; - } - - public void run() { - try { - byte bytes[][] = new byte[1][]; - - while(!_quit) { - int read = _pipedConnection.read(bytes, 1); - - if(read == 1) { -// System.err.println("read :" + bytes[0][0]); - - if(_theByte[0] != bytes[0][0]) - throw new NullPointerException(); - - synchronized(this) { - notifyAll(); - } - } - else - _quit = true; // EOF - } - - _pipedConnection.close(); - _state = true; - } - catch(com.sun.star.io.IOException ioException) { - System.err.println("#### Reader - unexpected:" + ioException); - } - - } - } - - static class Writer extends Thread { - PipedConnection _pipedConnection; - byte _theByte[]; - Reader _reader; - boolean _quit; - boolean _state = false; - - Writer(PipedConnection pipedConnection, byte theByte[], Reader reader) { - _pipedConnection = pipedConnection; - _reader = reader; - _theByte = theByte; - } - - public void run() { - try { - while(!_quit) { - synchronized(_reader) { - _pipedConnection.write(_theByte); - _pipedConnection.flush(); -// System.err.println("written :" + _theByte[0]); - - _reader.wait(); - } - ++ _theByte[0]; - } - - _pipedConnection.close(); - - _state = true; - } - catch(com.sun.star.io.IOException ioException) { - System.err.println("#### Writer:" + ioException); - } - catch(InterruptedException interruptedException) { - System.err.println("#### Writer:" + interruptedException); - } - } - - public void term() { - _quit = true; - } - } -} |