super.setUp(testInfo);
    }

    @Override
    public void tearDown(final TestInfo testInfo) throws Exception {
        super.tearDown(testInfo);
        // close runner
        runner.close();
        // delete all files
        runner.clean();
    }

    @Test
    public void test_insert_deleteTx() {
        final OpenSearchAccessResult accessResult1 = new OpenSearchAccessResult();

    }

    /**
     * Closes the file and releases any system resources associated with it.
     *
     * @throws SmbException if an I/O error occurs
     */
    public void close() throws SmbException {
        file.close();
    }

    @Override
    public final boolean readBoolean() throws SmbException {
        if (read(tmp, 0, 1) < 0) {
            throw new SmbException("EOF");
        }

        // Test boundary values
        assertEquals("1bytes", MemoryUtil.byteCountToDisplaySize(1L));
        assertEquals("999bytes", MemoryUtil.byteCountToDisplaySize(999L));

        // Test very large values close to EB boundary
        assertEquals("1.024EB", MemoryUtil.byteCountToDisplaySize(FileUtils.ONE_EB));

        // Test exact thresholds
        assertEquals("1.024KB", MemoryUtil.byteCountToDisplaySize(1024L));

	if err == nil && !reply {
		err = errLockConflict
	}
	if err != nil {
		lh.writeErrorResponse(w, err)
		return
	}
}

func stopLockServers() {
	for i := range numberOfNodes {
		nodes[i].Close()
	}
}

func startLockServers() {
	for i := range numberOfNodes {
		lsrv := &lockServer{
			mutex:   sync.Mutex{},
			lockMap: make(map[string]int64),
		}
		lockServer := lockServerHandler{

	if err != nil {
		return err
	}
	defer xhttp.DrainBody(respBody)
	_, err = waitForHTTPResponse(respBody)
	return toStorageErr(err)
}

// Close - marks the client as closed.
func (client *storageRESTClient) Close() error {
	client.restClient.Close()
	return nil
}

var emptyDiskID = ""

// Returns a storage rest client.

     *
     * @throws IOException
     *             if a network error occurs
     */

    @Override
    public void close() throws IOException {
        try {
            final SmbFileHandleImpl h = this.handle;
            if (h != null) {
                h.close();
            }
        } catch (final SmbException se) {
            throw seToIoe(se);
        } finally {
            this.tmp = null;

     */
    InputStream openInputStream() throws CIFSException;

    /**
     * Close/release the file
     *
     * This releases all resources that this file holds. If not using strict mode this is currently a no-op.
     *
     * @see java.lang.AutoCloseable#close()
     */
    @Override
    void close();

    /**
     * Fetch all children
     *

        injectAnnotation.fullyQualifiedName >> Inject.name

        repository = BinaryCompatibilityRepository.openRepositoryFor([new File(tmp.absolutePath)], [])
    }

    def cleanup() {
        repository?.close()
    }

    def "each new #apiElement requires a @Incubating annotation"() {
        given:
        JApiCompatibility jApiType = getProperty(jApiTypeName)
        def rule = withContext(new IncubatingMissingRule([:]))

                clientEventsList.add(parameters.first().toString())
              }
            }
          }
        }
      }

      override fun flush() {
      }

      override fun close() {
      }
    }.apply {
      level = Level.FINEST
    }

  private fun applyLogger(fn: Logger.() -> Unit) {
    Logger.getLogger(OkHttpClient::class.java.`package`.name).fn()

        .isEqualTo("response D")
      requestBody.writeUtf8("request E\n")
      requestBody.flush()
      assertThat(responseBody.readUtf8Line())
        .isEqualTo("response F")
      requestBody.close()
      assertThat(responseBody.readUtf8Line()).isNull()
    }
    body.awaitSuccess()
  }

  @Test
  fun trueDuplexServerWritesFirst() {
    enableProtocol(Protocol.HTTP_2)
    val body =