protected void ensurePutInAllServers(String blobId, MockServerLayout serverLayout) throws IOException {
    // Make sure all the mock servers have this put
    BlobId id = new BlobId(blobId, mockClusterMap);
    for (MockServer server : serverLayout.getMockServers()) {
      if (!server.getBlobs().containsKey(blobId)) {
        PutRequest putRequest =
            new PutRequest(NonBlockingRouter.correlationIdGenerator.incrementAndGet(), routerConfig.routerHostname, id,
                putBlobProperties, ByteBuffer.wrap(putUserMetadata), Unpooled.wrappedBuffer(putContent),
                putContent.length, BlobType.DataBlob, null);
        server.send(putRequest).release();
        putRequest.release();
      }
    }
  }
Ensure that Put request for given blob id reaches to all the mock servers in the {@link MockServerLayout}.
@param blobId The blob id of which Put request will be created.
@param serverLayout The mock server layout.
@throws IOException
ambry-router/src/test/java/com/github/ambry/router/NonBlockingRouterTestBase.java