}

func (stmt *Stmt) Close() error {
	<-stmt.prepared

	if stmt.Stmt != nil {
		return stmt.Stmt.Close()
	}
	return nil
}

// Store defines an interface for managing the caching operations of SQL statements (Stmt).
// This interface provides methods for creating new statements, retrieving all cache keys,
// getting cached statements, setting cached statements, and deleting cached statements.
type Store interface {

E...

            // Some operations might succeed before key wipe, some might fail after
            // At minimum, we expect some activity (not all operations should be no-ops)
            int totalOperations = successCount.get() + failureCount.get();
            assertTrue(totalOperations > 0, "Some signing/verification operations should have been attempted");
        }

        @Test

import java.util.concurrent.CopyOnWriteArraySet;
import org.jspecify.annotations.NullMarked;
import org.jspecify.annotations.Nullable;
import org.junit.Ignore;

/**
 * A generic JUnit test which tests {@code listIterator} operations on a list. Can't be invoked
 * directly; please see {@link com.google.common.collect.testing.ListTestSuiteBuilder}.
 *
 * @author Chris Povirk
 * @author Kevin Bourrillion
 */
@GwtCompatible

import jcifs.internal.smb2.rdma.RdmaProvider;

/**
 * DiSNI RDMA provider for InfiniBand/RoCE networks.
 *
 * This provider uses the DiSNI (Direct Storage and Networking Interface)
 * library to provide high-performance RDMA operations over InfiniBand
 * and RoCE (RDMA over Converged Ethernet) networks.
 */
public class DisniRdmaProvider implements RdmaProvider {

    /**
     * Creates a new DiSNI RDMA provider instance
     */

import org.slf4j.LoggerFactory;

import jcifs.Configuration;
import jcifs.RuntimeCIFSException;

/**
 * Utility class for string manipulation and conversion operations in the jCIFS library.
 * Provides methods for encoding, decoding, and manipulating strings in SMB operations.
 *
 * @author mbechler
 */
public final class Strings {

    private static final Logger log = LoggerFactory.getLogger(Strings.class);

        protected Writer writer;

        /** The mapping item being updated, or null for read-only operations. */
        protected CharMappingItem item;

        /**
         * Constructs a new MappingUpdater for handling file updates.
         *
         * @param newItem the character mapping item to update, or null for read-only operations
         */
        protected MappingUpdater(final CharMappingItem newItem) {
            try {

/**
 * Service class for managing request headers used in web crawling configurations.
 * This service provides CRUD operations for request headers that are applied
 * during web crawling to configure HTTP request behavior.
 *
 */
public class RequestHeaderService {

    /**
     * Behavior for request header database operations.
     */
    @Resource
    protected RequestHeaderBhv requestHeaderBhv;

    /**

 * matches the insertion order. All optional operations (adding and removing) are supported. All
 * elements, including {@code null}, are permitted.
 *
 * <p>{@code contains(x)}, {@code add(x)} and {@code remove(x)}, are all (expected and amortized)
 * constant time operations. Expected in the hashtable sense (depends on the hash function doing a

 * views are modifiable.
 *
 * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
 * read operations will work correctly. To allow concurrent update operations, wrap your multimap
 * with a call to {@link Multimaps#synchronizedListMultimap}.
 *
 * <p>See the Guava User Guide article on <a href=