Removed endpoint.disableRemoteKeyValidation, as it's no longer
necessary for "loopback" connections
This commit is contained in:
parent
1215fce459
commit
1aaae4c30b
|
@ -82,7 +82,6 @@ public class ChunkedDataIdleTest extends BaseTest {
|
|||
private void sendObject(final Data mainData, Configuration configuration, final ConnectionType type)
|
||||
throws InitializationException, SecurityException, IOException, InterruptedException {
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
|
||||
addEndPoint(server);
|
||||
server.setIdleTimeout(10);
|
||||
|
@ -107,7 +106,6 @@ public class ChunkedDataIdleTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
client.setIdleTimeout(10);
|
||||
addEndPoint(client);
|
||||
client.listeners().add(new Listener<Data>() {
|
||||
|
|
|
@ -48,7 +48,6 @@ class ClientSendTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
|
@ -64,7 +63,6 @@ class ClientSendTest extends BaseTest {
|
|||
});
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.connect(5000);
|
||||
|
||||
|
|
|
@ -137,7 +137,6 @@ class ConnectionTest extends BaseTest {
|
|||
Server startServer(Configuration configuration) throws InitializationException, SecurityException, IOException {
|
||||
Server server = new Server(configuration);
|
||||
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
|
||||
server.bind(false);
|
||||
|
@ -176,7 +175,6 @@ class ConnectionTest extends BaseTest {
|
|||
else {
|
||||
client = new Client();
|
||||
}
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.listeners()
|
||||
|
|
|
@ -43,7 +43,6 @@ class DiscoverHostTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
|
@ -57,7 +56,6 @@ class DiscoverHostTest extends BaseTest {
|
|||
}
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<Object>() {
|
||||
|
|
|
@ -121,7 +121,6 @@ class IdleTest extends BaseTest {
|
|||
throws InitializationException, SecurityException, IOException, InterruptedException {
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.setIdleTimeout(100);
|
||||
server.bind(false);
|
||||
|
@ -150,7 +149,6 @@ class IdleTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<Data>() {
|
||||
|
@ -180,7 +178,6 @@ class IdleTest extends BaseTest {
|
|||
void streamSpecificType(final int largeDataSize, Configuration configuration, final ConnectionType type)
|
||||
throws InitializationException, SecurityException, IOException, InterruptedException {
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.setIdleTimeout(100);
|
||||
server.bind(false);
|
||||
|
@ -244,7 +241,6 @@ class IdleTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<byte[]>() {
|
||||
|
|
|
@ -55,7 +55,6 @@ class LargeResizeBufferTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
|
@ -84,7 +83,6 @@ class LargeResizeBufferTest extends BaseTest {
|
|||
});
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.listeners()
|
||||
|
|
|
@ -92,7 +92,6 @@ class ListenerTest extends BaseTest {
|
|||
}
|
||||
};
|
||||
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
|
@ -174,7 +173,6 @@ class ListenerTest extends BaseTest {
|
|||
|
||||
Client client = new Client(configuration);
|
||||
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
|
|
@ -47,7 +47,6 @@ class MultipleServerTest extends BaseTest {
|
|||
configuration1.localChannelName = "chan1";
|
||||
|
||||
Server server1 = new Server(configuration1);
|
||||
server1.disableRemoteKeyValidation();
|
||||
addEndPoint(server1);
|
||||
|
||||
server1.bind(false);
|
||||
|
@ -71,7 +70,6 @@ class MultipleServerTest extends BaseTest {
|
|||
configuration2.localChannelName = "chan2";
|
||||
|
||||
Server server2 = new Server(configuration2);
|
||||
server2.disableRemoteKeyValidation();
|
||||
|
||||
addEndPoint(server2);
|
||||
server2.bind(false);
|
||||
|
@ -95,7 +93,6 @@ class MultipleServerTest extends BaseTest {
|
|||
configuration1.host = host;
|
||||
|
||||
Client client1 = new Client(configuration1);
|
||||
client1.disableRemoteKeyValidation();
|
||||
addEndPoint(client1);
|
||||
client1.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
@ -113,7 +110,6 @@ class MultipleServerTest extends BaseTest {
|
|||
configuration2.host = host;
|
||||
|
||||
Client client2 = new Client(configuration2);
|
||||
client2.disableRemoteKeyValidation();
|
||||
addEndPoint(client2);
|
||||
client2.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
|
|
@ -65,7 +65,6 @@ class MultipleThreadTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
final Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
@ -125,8 +124,6 @@ class MultipleThreadTest extends BaseTest {
|
|||
final int index = i;
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
|
||||
this.clients.add(client);
|
||||
|
||||
addEndPoint(client);
|
||||
|
|
|
@ -48,7 +48,6 @@ public class PingPongLocalTest extends BaseTest {
|
|||
populateData(dataLOCAL);
|
||||
|
||||
Server server = new Server();
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
server.listeners().add(new Listener<Data>() {
|
||||
|
@ -71,7 +70,6 @@ public class PingPongLocalTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client();
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners().add(new Listener<Data>() {
|
||||
AtomicInteger check = new AtomicInteger(0);
|
||||
|
|
|
@ -73,7 +73,6 @@ class PingPongTest extends BaseTest {
|
|||
populateData(dataUDT, TYPE.UDT);
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
server.listeners()
|
||||
|
@ -121,7 +120,6 @@ class PingPongTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<Data>() {
|
||||
|
|
|
@ -42,14 +42,12 @@ class PingTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.connect(5000);
|
||||
|
@ -78,14 +76,12 @@ class PingTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.connect(5000);
|
||||
|
@ -135,14 +131,12 @@ class PingTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.connect(5000);
|
||||
|
@ -185,14 +179,12 @@ class PingTest extends BaseTest {
|
|||
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.connect(5000);
|
||||
|
@ -225,14 +217,12 @@ class PingTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
|
||||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
|
||||
client.connect(5000);
|
||||
|
|
|
@ -42,7 +42,6 @@ class ReconnectTest extends BaseTest {
|
|||
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
|
||||
server.bind(false);
|
||||
addEndPoint(server);
|
||||
|
@ -67,7 +66,6 @@ class ReconnectTest extends BaseTest {
|
|||
|
||||
final AtomicInteger reconnectCount = new AtomicInteger();
|
||||
final Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<Object>() {
|
||||
|
|
|
@ -47,7 +47,6 @@ class ReuseTest extends BaseTest {
|
|||
configuration.host = host;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
@ -71,7 +70,6 @@ class ReuseTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
@ -122,7 +120,6 @@ class ReuseTest extends BaseTest {
|
|||
this.clientCount = new AtomicInteger(0);
|
||||
|
||||
Server server = new Server();
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
@ -144,7 +141,6 @@ class ReuseTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client();
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<String>() {
|
||||
|
|
|
@ -63,7 +63,6 @@ class UnregisteredClassTest extends BaseTest {
|
|||
populateData(dataUDP, false);
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
addEndPoint(server);
|
||||
server.bind(false);
|
||||
server.listeners()
|
||||
|
@ -101,7 +100,6 @@ class UnregisteredClassTest extends BaseTest {
|
|||
// ----
|
||||
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
addEndPoint(client);
|
||||
client.listeners()
|
||||
.add(new Listener<Data>() {
|
||||
|
|
|
@ -220,7 +220,6 @@ class RmiGlobalTest extends BaseTest {
|
|||
configuration.rmiEnabled = true;
|
||||
|
||||
final Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
server.setIdleTimeout(0);
|
||||
|
||||
// register this object as a global object that the client will get
|
||||
|
@ -254,7 +253,6 @@ class RmiGlobalTest extends BaseTest {
|
|||
|
||||
final Client client = new Client(configuration);
|
||||
client.setIdleTimeout(0);
|
||||
client.disableRemoteKeyValidation();
|
||||
|
||||
// register this object as a global object that the server will get
|
||||
CLIENT_GLOBAL_OBJECT_ID = client.createGlobalObject(globalRemoteClientObject);
|
||||
|
|
|
@ -78,7 +78,6 @@ class RmiSendObjectOverrideMethodTest extends BaseTest {
|
|||
configuration.rmiEnabled = true;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
server.setIdleTimeout(0);
|
||||
|
||||
|
||||
|
@ -105,7 +104,6 @@ class RmiSendObjectOverrideMethodTest extends BaseTest {
|
|||
|
||||
// ----
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
client.setIdleTimeout(0);
|
||||
|
||||
addEndPoint(client);
|
||||
|
|
|
@ -76,7 +76,6 @@ class RmiSendObjectTest extends BaseTest {
|
|||
configuration.rmiEnabled = true;
|
||||
|
||||
Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
server.setIdleTimeout(0);
|
||||
|
||||
|
||||
|
@ -101,7 +100,6 @@ class RmiSendObjectTest extends BaseTest {
|
|||
|
||||
// ----
|
||||
Client client = new Client(configuration);
|
||||
client.disableRemoteKeyValidation();
|
||||
client.setIdleTimeout(0);
|
||||
|
||||
addEndPoint(client);
|
||||
|
|
|
@ -205,7 +205,6 @@ class RmiTest extends BaseTest {
|
|||
configuration.rmiEnabled = true;
|
||||
|
||||
final Server server = new Server(configuration);
|
||||
server.disableRemoteKeyValidation();
|
||||
server.setIdleTimeout(0);
|
||||
|
||||
addEndPoint(server);
|
||||
|
@ -238,7 +237,6 @@ class RmiTest extends BaseTest {
|
|||
|
||||
final Client client = new Client(configuration);
|
||||
client.setIdleTimeout(0);
|
||||
client.disableRemoteKeyValidation();
|
||||
|
||||
addEndPoint(client);
|
||||
|
||||
|
|
Loading…
Reference in New Issue
Block a user