@Test
  public void testC2SDeltaPropagationFailedStats1() throws Exception {
    int numOfKeys = 50;
    long updates = 50;
    long errors = 100, errors2 = 13;

    Object[] args =
        new Object[] {Boolean.TRUE, DataPolicy.REPLICATE, Scope.DISTRIBUTED_ACK, Boolean.TRUE};
    Integer port =
        vm0.invoke(DeltaPropagationStatsDUnitTest.class, "createServerCache", args);
    createClientCache(NetworkUtils.getServerHostName(vm0.getHost()), port);

    putErrorDeltaForReceiver(numOfKeys, updates, errors);
    putErrorDeltaForSender(numOfKeys, updates, errors2, Boolean.FALSE);
    putLastKey();

    long deltasSent = 2 * (numOfKeys * updates) - errors2;
    long deltasProcessed = deltasSent - errors;

    vm0.invoke(DeltaPropagationStatsDUnitTest::waitForLastKey);

    verifyDeltaSenderStats(CLIENT_TO_SERVER, deltasSent);
    vm0.invoke(() -> DeltaPropagationStatsDUnitTest.verifyDeltaReceiverStats(
        CLIENT_TO_SERVER, deltasProcessed, errors));
  }
Simulates error in fromDelta() and toDelta()
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/DeltaPropagationStatsDUnitTest.java