.setSource(source, XContentType.JSON)
                    .execute()
                    .actionGet(fessConfig.getIndexIndicesTimeout());
            if (indexResponse.isAcknowledged()) {
                logger.info("Created {} index.", indexName);
                return true;
            }
            if (logger.isDebugEnabled()) {

    assertFailsWith<SocketTimeoutException> {
      source.readByte() // If Content-Length was accurate, this would return -1 immediately.
    }
    source.close()
  }

  /** Confirm that an unacknowledged write times out.  */
  @Test
  fun writeTimeouts() {
    val server = MockWebServer()
    // Sockets on some platforms can have large buffers that mean writes do not block when