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

    private byte[] fileId;
    private final String fileName;
    private int closeFlags;

    /**
     * Constructs a close request with file ID and name
     *
     * @param config
     *            The configuration to use
     * @param fileId

    }

    @ParameterizedTest
    @NullAndEmptySource
    @ValueSource(strings = { "hello", " ", "unicode-∑" })
    @DisplayName("Message-only constructor: preserves provided message; null cause")
    void messageOnlyConstructor_preservesMessage(String message) {
        // Arrange & Act
        SMBProtocolDecodingException ex = new SMBProtocolDecodingException(message);

 *
 * @author Kurt Alfred Kluever
 */
@NullUnmarked
public class SynchronizedQueueTest extends TestCase {

  protected Queue<String> create() {
    TestQueue<String> inner = new TestQueue<>();
    Queue<String> outer = Synchronized.queue(inner, inner.mutex);
    outer.add("foo"); // necessary because we try to remove elements later on
    return outer;
  }

      return delegate.rowMap();
    }

    private static final long serialVersionUID = 0;
  }

  @Override
  protected Table<String, Integer, Character> create(@Nullable Object... data) {
    TestTable<String, Integer, Character> table = new TestTable<>();
    Table<String, Integer, Character> synced = Synchronized.table(table, table.mutex);
    populate(synced, data);
    return synced;
  }

        assertEscaping(xmlEscaper, "'", ch);
      } else if (shouldEscapeQuotes && ch == '"') {
        assertEscaping(xmlEscaper, """, ch);
      } else {
        String input = String.valueOf(ch);
        String escaped = xmlEscaper.escape(input);
        assertEquals(
            "char 0x" + Integer.toString(ch, 16) + " should not be escaped", input, escaped);
      }
    }

     *
     * @param modelId The identifier of the model (groupId:artifactId:version) or empty string for the super POM.
     * @return The active profiles for the specified model or an empty list if the model has no active profiles.
     * @since 4.0.0
     */
    @Nonnull
    List<Profile> getActivePomProfiles(String modelId);

    /**
     * Gets a map of all active POM profiles organized by model ID.

import (
	"bufio"
	"bytes"
	"encoding/binary"
	"flag"
	"fmt"
	"hash/crc32"
	"log"
	"os"
	"strings"

	"github.com/dchest/siphash"
	"github.com/google/uuid"
)

// hashes the key returning an integer based on the input algorithm.
// This function currently supports
// - SIPMOD
func sipHashMod(key string, cardinality int, id [16]byte) int {
	if cardinality <= 0 {
		return -1
	}

    return configureSocket(sslSocket)
  }

  override fun getDefaultCipherSuites(): Array<String> = delegate.defaultCipherSuites

  override fun getSupportedCipherSuites(): Array<String> = delegate.supportedCipherSuites

  @Throws(IOException::class)
  override fun createSocket(
    socket: Socket,
    host: String,
    port: Int,
    autoClose: Boolean,
  ): SSLSocket {

        .url("http://publicobject.com/helloworld.txt")
        .build();

    String response1Body;
    try (Response response1 = client.newCall(request).execute()) {
      if (!response1.isSuccessful()) throw new IOException("Unexpected code " + response1);

      response1Body = response1.body().string();
      System.out.println("Response 1 response:          " + response1);

     */
    @Test
    void testOverriddenMergeMethods() {
        List<String> methodNames = Stream.of(MavenMerger.class.getDeclaredMethods())
                .filter(m -> m.getName().startsWith("merge"))
                .filter(m -> {
                    String baseName = m.getName().substring(5 /* merge */);
                    String entity = baseName.substring(baseName.indexOf('_') + 1);
                    try {