}

  fun closeCodeExceptionMessage(code: Int): String? =
    if (code < 1000 || code >= 5000) {
      "Code must be in range [1000,5000): $code"
    } else if (code in 1004..1006 || code in 1015..2999) {
      "Code $code is reserved and may not be used."
    } else {
      null
    }

  fun validateCloseCode(code: Int) {
    val message = closeCodeExceptionMessage(code)
    require(message == null) { message!! }

    UnicodeEscaper e = new PercentEscaper("", false);
    for (char c = 0; c < 128; c++) {
      if ((c >= '0' && c <= '9') || (c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z')) {
        assertUnescaped(e, c);
      } else {
        assertEscaping(e, escapeAscii(c), c);
      }
    }

    // Testing multibyte escape sequences
    assertEscaping(e, "%00", '\u0000'); // nul
    assertEscaping(e, "%7F", '\u007f'); // del

                if (params[i] instanceof byte[]) {
                    paramTypes[i] = byte[].class;
                } else if (params[i] instanceof Integer) {
                    paramTypes[i] = int.class; // Use primitive int.class instead of Integer.class
                } else {
                    paramTypes[i] = params[i].getClass();
                }
            }

        // Write length
        if (content.length < 128) {
            baos.write(content.length);
        } else if (content.length < 256) {
            baos.write(0x81); // length of length = 1
            baos.write(content.length);
        } else {
            baos.write(0x82); // length of length = 2
            baos.write((content.length >> 8) & 0xFF);

    } else {
      return unmodifiableSortedSet((SortedSet<E>) collection);
    }
  }

  @Override
  Collection<V> wrapCollection(@ParametricNullness K key, Collection<V> collection) {
    if (collection instanceof NavigableSet) {
      return new WrappedNavigableSet(key, (NavigableSet<V>) collection, null);
    } else {

                }
                System.err.println("And then amend the merge commit to remove all offending changes.")
                System.exit(1)
            } else {
                println(" -> No bad files found")
            }
        } else {
            println(" -> is not a merge commit we're looking for.")
        }
    }

    static List<String> filesFromMerge(String commit) {

        } else {
            SMBUtil.writeInt4(0, buffer, offset + 4);
        }

        // Group SID offset
        if (includeGroup) {
            SMBUtil.writeInt4(currentOffset, buffer, offset + 8);
            prepareSimpleSid(buffer, offset + currentOffset);
            currentOffset += 20; // Simple SID size
        } else {
            SMBUtil.writeInt4(0, buffer, offset + 8);

                         not specified. SMB signing may not work propertly.\
                          Skipping DC interrogation.""");
            }
        } else {
            final SmbSession ssn = trans.getSmbSession(NtlmPasswordAuthentication.DEFAULT);
            ssn.getSmbTree(LOGON_SHARE, null).treeConnect(null, null);
        }

			t.Errorf("Expected %s, got %s", "podman pull quay.io/minio/minio:"+minioVersion1, durl)
		}
	} else {
		if runtime.GOOS == "windows" {
			if durl != MinioReleaseURL+"minio.exe" {
				t.Errorf("Expected %s, got %s", MinioReleaseURL+"minio.exe", durl)
			}
		} else {
			if durl != MinioReleaseURL+"minio" {
				t.Errorf("Expected %s, got %s", MinioReleaseURL+"minio", durl)
			}
		}
	}

	}
	nsLk.ref++
	n.lockMap[resource] = nsLk
	n.lockMapMutex.Unlock()

	// Locking here will block (until timeout).
	if readLock {
		locked = nsLk.GetRLock(ctx, opsID, lockSource, timeout)
	} else {
		locked = nsLk.GetLock(ctx, opsID, lockSource, timeout)
	}

	if !locked { // We failed to get the lock
		// Decrement ref count since we failed to get the lock
		n.lockMapMutex.Lock()