@Override
              public void run2() throws CacheException {
                getCache(); // create a cache so we have stats
                System.out.println("connecting to cache server with socket");
                try {
                  InetAddress addr = InetAddress.getByName(hostName);
                  meanSocket = new Socket(addr, port);
                } catch (Exception e) {
                  throw new RuntimeException("Test failed to connect or was interrupted", e);
                }
              }
test that a server times out waiting for a handshake that never arrives.
geode-core/src/distributedTest/java/org/apache/geode/cache30/ClientMembershipDUnitTest.java