"sync_bg": "not set",
}

errors = []


async def get_state():
    return state


class AsyncDependencyError(Exception):
    pass


class SyncDependencyError(Exception):
    pass


class OtherDependencyError(Exception):
    pass


async def asyncgen_state(state: dict[str, str] = Depends(get_state)):
    state["/async"] = "asyncgen started"
    yield state["/async"]

        registration.setState(WitnessRegistrationState.REGISTERED);
        assertEquals(WitnessRegistrationState.REGISTERED, registration.getState());

        registration.setState(WitnessRegistrationState.UNREGISTERING);
        assertEquals(WitnessRegistrationState.UNREGISTERING, registration.getState());

        registration.setState(WitnessRegistrationState.FAILED);

        assertEquals(ChannelState.ESTABLISHED, channelInfo.getState());
        assertTrue(channelInfo.isHealthy());

        channelInfo.setState(ChannelState.ACTIVE);
        assertTrue(channelInfo.isHealthy());

        channelInfo.setState(ChannelState.FAILED);
        assertFalse(channelInfo.isHealthy());
    }

    @Test
    void testActivityTracking() {

        channel.setState(ChannelState.ESTABLISHED);

        // Simulate failure
        IOException failure = new IOException("Connection lost");
        failover.handleFailure(channel, failure);

        // Verify channel state changed
        assertFalse(channel.isHealthy());
        assertEquals(ChannelState.FAILED, channel.getState());
    }

    @Test

    /**
     * Monitors active registrations and sends heartbeats.
     */
    private void monitorRegistrations() {
        for (WitnessRegistration registration : registrations.values()) {
            if (registration.getState() == WitnessRegistrationState.REGISTERED) {
                // Send periodic heartbeat
                sendHeartbeat(registration);
            }
        }
    }

    /**

    public InetAddress getServerAddress() { return serverAddress; }
    public WitnessServiceType getServiceType() { return serviceType; }
    public WitnessRegistrationState getState() { return state; }
    public void setState(WitnessRegistrationState state) { this.state = state; }
}
```

### 4.2 Witness Notification
```java
package jcifs.internal.witness;

import java.util.List;

        failedChannel.setState(ChannelState.ESTABLISHED);

        when(mockChannelManager.getLoadBalancer()).thenReturn(mockLoadBalancer);
    }

    @Test
    void testHandleFailure() {
        IOException error = new IOException("Connection failed");

        failover.handleFailure(failedChannel, error);

        assertEquals(ChannelState.FAILED, failedChannel.getState());

     *
     * @return the current registration state
     */
    public WitnessRegistrationState getState() {
        return state;
    }

    /**
     * Sets the registration state.
     *
     * @param state the new registration state
     */
    public void setState(WitnessRegistrationState state) {
        this.state = state;
    }

    /**
     * Gets the registration flags.

    }

    /**
     * Get current channel state
     *
     * @return channel state
     */
    public ChannelState getState() {
        return state;
    }

    /**
     * Set channel state
     *
     * @param state new state
     */
    public void setState(ChannelState state) {
        this.state = state;
    }

    /**
     * Get the time when channel was established
     *

    failover.handleFailure(channel, error);
    
    // Verify channel marked as failed
    assertEquals(ChannelState.FAILED, channel.getState());
    
    // Verify recovery attempted
    Thread.sleep(2000);
    assertTrue(channel.getState() == ChannelState.ESTABLISHED 
        || manager.getChannels().isEmpty());
}
```

### 7.2 Integration Tests
```java
@Test