1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
/*************************************************************************
/* PipedReaderWriterTest.java -- Tests Piped{Reader,Writers}'s
/*
/* Copyright (c) 1998 Free Software Foundation, Inc.
/* Written by Aaron M. Renn (arenn@urbanophile.com)
/*
/* This program is free software; you can redistribute it and/or modify
/* it under the terms of the GNU General Public License as published
/* by the Free Software Foundation, either version 2 of the License, or
/* (at your option) any later version.
/*
/* This program 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 for more details.
/*
/* You should have received a copy of the GNU General Public License
/* along with this program; if not, write to the Free Software Foundation
/* Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307 USA
/*************************************************************************/
import java.io.*;
public class PipedReaderWriterTest
{
public static void
main(String[] argv) throws InterruptedException
{
// Set up a reasonable buffer size for this test if one is not already
// specified
String prop = System.getProperty("gnu.java.io.pipe_size");
// if (prop == null)
// System.setProperty("gnu.java.io.pipe_size", "32");
try
{
System.out.println("Started test of PipedReader and PipedWriter");
System.out.println("Test 1: Basic pipe test");
// Set up the thread to write
PipedTestWriter ptw = new PipedTestWriter();
String str = ptw.getStr();
PipedWriter pw = ptw.getWriter();
// Now set up our reader
PipedReader pr = new PipedReader();
pr.connect(pw);
new Thread(ptw).start();
char[] buf = new char[12];
int chars_read, total_read = 0;
while((chars_read = pr.read(buf)) != -1)
{
System.out.print(new String(buf, 0, chars_read));
System.out.flush();
Thread.sleep(10); // A short delay
total_read += chars_read;
}
if (total_read == str.length())
System.out.println("PASSED: Basic pipe test");
else
System.out.println("FAILED: Basic pipe test");
}
catch (IOException e)
{
System.out.println("FAILED: Basic pipe test: " + e);
}
}
} // class PipedReaderWriterTest
class PipedTestWriter implements Runnable
{
String str;
StringReader sbr;
PipedWriter out;
public
PipedTestWriter()
{
str = "In college, there was a tradition going for a while that people\n" +
"would get together and hang out at Showalter Fountain - in the center\n" +
"of Indiana University's campus - around midnight. It was mostly folks\n" +
"from the computer lab and just people who liked to use the Forum\n" +
"bbs system on the VAX. IU pulled the plug on the Forum after I left\n" +
"despite its huge popularity. Now they claim they are just giving\n" +
"students what they want by cutting deals to make the campus all\n" +
"Microsoft.\n";
sbr = new StringReader(str);
out = new PipedWriter();
}
public PipedWriter
getWriter()
{
return(out);
}
public String
getStr()
{
return(str);
}
public void
run()
{
char[] buf = new char[32];
int chars_read;
try
{
int b = sbr.read();
out.write(b);
while ((chars_read = sbr.read(buf)) != -1)
out.write(buf, 0, chars_read);
out.close();
}
catch(IOException e)
{
System.out.println("FAILED: Basic pipe test: " + e);
}
}
} // PipedTestWriter
|
