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
|
/*
Derby - Class org.apache.derbyTesting.functionTests.tests.derbynet.DerbyNetNewServerTest
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package org.apache.derbyTesting.functionTests.tests.derbynet;
import java.io.ByteArrayOutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.UnknownHostException;
import junit.framework.Test;
import org.apache.derby.drda.NetworkServerControl;
import org.apache.derbyTesting.junit.BaseJDBCTestCase;
import org.apache.derbyTesting.junit.BaseTestSuite;
import org.apache.derbyTesting.junit.Derby;
import org.apache.derbyTesting.junit.JDBC;
import org.apache.derbyTesting.junit.NetworkServerTestSetup;
import org.apache.derbyTesting.junit.TestConfiguration;
/**
* Test NetworkServerControl.start(PrintWriter) writes to the print Writer
*
* test:
*<ul>
*<li> start( printWriter)
*<li> start( (PrintWriter) null)
*</ul>
*/
public class DerbyNetNewServerTest extends BaseJDBCTestCase {
public DerbyNetNewServerTest(String name) {
super(name);
}
public static Test suite() {
// Test does not run on J2ME
if (JDBC.vmSupportsJDBC3() && Derby.hasServer()) {
return new BaseTestSuite(DerbyNetNewServerTest.class);
} else {
return new BaseTestSuite("DerbyNetNewServerTest.empty");
}
}
protected void setUp() throws Exception {
// The test cases in this test start a new network server. Wait until
// the network server in the previous test case has shut down
// completely and released the network port before attempting to start
// a new server.
NetworkServerTestSetup.waitForAvailablePort();
}
public void testStartWithPrintWriter()
throws UnknownHostException,
Exception {
ByteArrayOutputStream bos = new ByteArrayOutputStream(10240);
// DERBY-1466, Test that messages are flushed to the
// writer irrespective of whether the user's writer is
// set to autoflush true.
PrintWriter writer = new PrintWriter(bos);
NetworkServerControl server = new NetworkServerControl(InetAddress
.getByName(TestConfiguration.getCurrent().getHostName()),
TestConfiguration.getCurrent().getPort());
assertEquals("No log initially", 0, bos.size());
server.start(writer);
NetworkServerTestSetup.waitForServerStart(server);
int sizeAfterPing = bos.size();
assertTrue("Create log with start message", 0 < sizeAfterPing);
server.shutdown();
// DERBY-5598: The shutdown command doesn't wait until the message has
// been written before it returns. Give the message a little time (up
// to half a minute) to propagate to the log.
int sizeAfterShutDown = bos.size();
for (int i = 0; i < 60 && sizeAfterShutDown == sizeAfterPing; i++) {
Thread.sleep(500L);
sizeAfterShutDown = bos.size();
}
bos.close();
bos = null;
writer.close();
assertTrue("Num of log item should add",
sizeAfterShutDown > sizeAfterPing);
}
public void testStartWithoutPrintWriter()
throws UnknownHostException,
Exception {
NetworkServerControl server = new NetworkServerControl(InetAddress
.getByName(TestConfiguration.getCurrent().getHostName()),
TestConfiguration.getCurrent().getPort());
server.start(null);
NetworkServerTestSetup.waitForServerStart(server);
server.shutdown();
//to show this is a right workflow.
assertTrue(true);
}
}
|
