this.localAddr = localAddr;
        this.localPort = localPort;

        // Initialize circuit breaker with connection-specific name
        String circuitBreakerName = String.format("SMB-%s:%d", address.getHostAddress(), port);
        this.circuitBreaker = new SimpleCircuitBreaker(circuitBreakerName, 3, 2, 30000L);

    }

    /**
     * {@inheritDoc}
     *

                request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());

                WitnessRegisterResponse response = rpcClient.register(request);

                if (response != null && response.isSuccess()) {

                request.setVersion(registration.getVersion().getValue());
                request.setShareName(shareName);
                request.setServerAddress(serverAddress.getHostAddress());
                request.setFlags(registration.getFlags());
                
                WitnessRegisterResponse response = rpcClient.register(request);
                

     *
     * @return formatted address string for RPC connections
     */
    public String getServiceAddress() {
        try {
            return "ncacn_ip_tcp:" + getAddress().getHostAddress() + "[" + getPort() + "]";
        } catch (IOException e) {
            return "ncacn_ip_tcp:127.0.0.1[135]";
        }
    }

    /**
     * Simulate heartbeat processing
     *

                return;
            }

            try {
                rdmaConnection =
                        rdmaProvider.connect(delegate.getRemoteAddress().getHostAddress(), delegate.getContext().getConfig().getRdmaPort());
                log.info("RDMA connection established to {}", delegate.getRemoteAddress());
            } catch (IOException e) {

     *
     * @param address the InetAddress
     */
    public void setIpAddress(InetAddress address) {
        if (address != null) {
            this.ipAddress = address.getHostAddress();
        }
    }

    /**
     * Gets the IP address.
     *
     * @return the IP address
     */
    public String getIpAddress() {
        return ipAddress;
    }

    /**

        // When
        Address address = nameServiceClient.getByName("127.0.0.1");

        // Then
        assertNotNull(address, "Should return address for IP address");
        assertEquals("127.0.0.1", address.getHostAddress(), "Should return correct IP address");
    }

    @Test
    @DisplayName("Should get all addresses by name")
    void testGetAllByName() throws UnknownHostException {
        // When

        when(config.isSigningEnforced()).thenReturn(false);
        when(config.getSessionTimeout()).thenReturn(30_000);
        when(config.getResponseTimeout()).thenReturn(5_000);
        when(address.getHostAddress()).thenReturn("127.0.0.1");
        when(address.getHostName()).thenReturn("testhost");

        transport = new SmbTransportImpl(context, address, 445, null, 0, false);
    }

    /**

        List<Exception> exceptions = new ArrayList<>();

        // Mock address for testing
        Address mockAddress = Mockito.mock(Address.class);
        Mockito.when(mockAddress.getHostAddress()).thenReturn("127.0.0.1");

        // Start timing
        long overallStart = System.nanoTime();

        for (int t = 0; t < threadCount; t++) {
            executor.submit(() -> {
                try {

        when(cfg.isSigningEnforced()).thenReturn(false);
        when(cfg.getSessionTimeout()).thenReturn(30_000);
        when(cfg.getResponseTimeout()).thenReturn(5_000);
        when(address.getHostAddress()).thenReturn("127.0.0.1");
        when(address.getHostName()).thenReturn("localhost");

        // Create the transport with safe defaults (no real sockets)