final public void writeChunk(L locator,KVO<O>[] chunk) throws MockStaleLocatorException {
synchronized (this) {
    if (staleLocators.contains(locator.getPartitionId())) {
      throw new MockStaleLocatorException(locator);
    }
    if (!knownLocators.contains(locator.getPartitionId())) {
      throw new RuntimeException("Locator not registered on DS: " + locator);
    }
  }
  acceptWrite(locator,chunk);
}

final public void writeChunk ( L locator , KVO < O > [ ] chunk ) throws MockStaleLocatorException { synchronized ( this ) { if ( staleLocators . contains ( locator . getPartitionId ( ) ) ) { throw new MockStaleLocatorException ( locator ) ; } if ( ! knownLocators . contains ( locator . getPartitionId ( ) ) ) { throw new RuntimeException ( "Locator not registered on DS: " + locator ) ; } } acceptWrite ( locator , chunk ) ; }
write a chunk onto the data service .
