@Override
      public void run2() throws CacheException {
        synchronized (HAClearDistributedTest.class) {
          while (!gotClearCallback) {
            try {
              HAClearDistributedTest.class.wait();
            } catch (InterruptedException e) {
              fail("interrupted");
            }
          }
        }

        if (!gotClearCallback) {
          fail("test failed");
        }
        gotClearCallback = false;
      }
The test performs following operations 1. Create 2 servers and 3 clients 2. Perform put
operations for known set of keys directy from the server1. 3. Perform clear operation from
server1 4. verify the result of operation for other clients and other servers.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HAClearDistributedTest.java