// Helper class for testing with concrete NetbiosName implementation
    private class TestNetbiosName implements NetbiosName {
        private final String name;
        private final int type;
        private final String scope;

        TestNetbiosName(String name, int type, String scope) {
            // Ensure names are uppercase and limited to 15 characters

            score += 10;

        // Penalize channels with many pending operations
        score -= (int) getRequestsPending();

        return Math.max(0, score);
    }

    @Override
    public String toString() {
        return "ChannelInfo{" + "channelId='" + channelId + '\'' + ", state=" + state + ", local=" + localInterface.getAddress()

        // Then
        // getWinsServers() returns InetAddress[], not String
        InetAddress[] winsServers = testConfig.getWinsServers();
        assertNotNull(winsServers);
        assertEquals(1, winsServers.length);
        assertEquals("192.168.1.1", winsServers[0].getHostAddress());

        // getBroadcastAddress() returns InetAddress, not String
        InetAddress broadcastAddr = testConfig.getBroadcastAddress();

    return ATOMIC_HELPER.decrementAndGetRemainingCount(this);
  }

  final void clearSeenExceptions() {
    seenExceptionsField = null;
  }

  @VisibleForTesting
  static String atomicHelperTypeForTest() {
    return ATOMIC_HELPER.atomicHelperTypeForTest();
  }

  private abstract static class AtomicHelper {

    assert app.openapi()["components"]["schemas"][body_model_name] == {
        "properties": {
            "p": {
                "type": "array",
                "items": {"type": "string", "format": "binary"},
                "title": "P",
            },
        },
        "required": ["p"],
        "title": body_model_name,
        "type": "object",
    }


@pytest.mark.parametrize(

        return size;
    }

    void appendCol(final StringBuffer sb, final String str, final int width) {
        sb.append(str);
        final int count = width - str.length();
        for (int i = 0; i < count; i++) {
            sb.append(' ');
        }
    }

    /**
     * Return a string represeting this ACE.
     * <p>
     * Note: This function should probably be changed to return SDDL

        holder.addCommandRegistry(builtins);

        // gather commands
        Map<String, ShellCommandRegistryFactory> factories =
                context.lookup.lookupMap(ShellCommandRegistryFactory.class);
        for (Map.Entry<String, ShellCommandRegistryFactory> entry : factories.entrySet()) {
            holder.addCommandRegistry(entry.getValue().createShellCommandRegistry(context));

   *
   * <p>The default implementation returns a new {@link Executor} that sets the name of its threads
   * to the string returned by {@link #serviceName}
   */
  protected Executor executor() {
    return command -> newThread(serviceName(), command).start();
  }

  @Override
  public String toString() {
    return serviceName() + " [" + state() + "]";
  }

  @Override
  public final boolean isRunning() {

)
def test_optional_str_schema(path: str):
    assert app.openapi()["paths"][path]["get"]["parameters"] == [
        {
            "required": False,
            "schema": {
                "anyOf": [{"type": "string"}, {"type": "null"}],
                "title": "P",
            },
            "name": "p",
            "in": "header",
        }
    ]


@pytest.mark.parametrize(
    "path",

class Type2MessageTest {

    private static final byte[] TEST_CHALLENGE = new byte[] { 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08 };
    private static final String TEST_TARGET = "TEST_TARGET";
    private static final String TEST_DOMAIN = "TEST_DOMAIN";
    private static final String TEST_HOSTNAME = "TEST_HOSTNAME";

    /**
     * Helper method to create a fully mocked CIFSContext with all necessary dependencies
     */