/*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code 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
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
/* @test
* @summary Test SocketChannel.finishConnect
* @library ..
*/
public class FinishConnect {
test1(dayTimeServer, true, true);
test1(dayTimeServer, true, false);
test1(dayTimeServer, false, true);
test1(dayTimeServer, false, false);
}
}
boolean select,
boolean setBlocking)
throws Exception
{
daytimeServer.getPort());
sc.configureBlocking(false);
int attempts = 0;
try {
throw new RuntimeException("Allowed another connect call");
} catch (IllegalStateException ise) {
// Correct behavior
}
if (setBlocking)
sc.configureBlocking(true);
while (!connected) {
if (keysAdded > 0) {
while (i.hasNext()) {
}
}
}
}
while (!connected) {
if (attempts++ > 30)
throw new RuntimeException("Failed to connect");
}
int bytesRead = 0;
int totalRead = 0;
while (totalRead < 20) {
if (bytesRead > 0)
if (bytesRead < 0)
throw new RuntimeException("Message shorter than expected");
}
}
daytimeServer.getPort());
boolean done = false;
int globalAttempts = 0;
int connectSuccess = 0;
while (!done) {
// When using a local daytime server it is not always possible
// to get a pending connection, as sc.connect(isa) may always
// return true.
// So we're going to throw the exception only if there was
// at least 1 case where we did not manage to connect.
if (globalAttempts++ > 50) {
break;
}
throw new RuntimeException("Failed to connect");
}
sc.configureBlocking(false);
int localAttempts = 0;
while (!connected) {
if (localAttempts++ > 500)
throw new RuntimeException("Failed to connect");
if (connected) {
done = true;
break;
}
}
if (connected) {
}
}
}
}