summaryrefslogtreecommitdiff
path: root/jurt/test/com/sun/star/comp/connections/PipedConnection_Test.java
diff options
context:
space:
mode:
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.java147
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;
- }
- }
-}