}

	if err := DB.Session(&gorm.Session{AllowGlobalUpdate: true}).Delete(&User{}).Error; err != nil {
		t.Errorf("should returns no error while enable global update, but got err %v", err)
	}
}

func TestDeleteWithAssociations(t *testing.T) {

		APIStats: st.totalS35xxErrors.Load(toLowerKeys),
	}
	serverStats.TotalS3Canceled = ServerHTTPAPIStats{
		APIStats: st.totalS3Canceled.Load(toLowerKeys),
	}
	return serverStats
}

// Update statistics from http request and response data
func (st *HTTPStats) updateStats(api string, w *xhttp.ResponseRecorder) {
	st.totalS3Requests.Inc(api)

        LOGOUT,
        /**
         * The access action.
         */
        ACCESS,
        /**
         * The login failure action.
         */
        LOGIN_FAILURE,
        /**
         * The update permission action.
         */
        UPDATE_PERMISSION;
    }

    /**
     * Set the logger name.
     * @param loggerName The logger name.
     */

     */
    public void run(Runnable runnable) throws Exception {
        call(() -> {
            runnable.run();
            return null;
        });
    }

    /**
     * Evaluate and potentially update the circuit breaker state
     *
     * @return current state after evaluation
     */
    private State evaluateState() {
        State current = state.get();

        if (current == State.OPEN) {

        // Should not throw exception
        Smb2FlushRequest requestWithNull = new Smb2FlushRequest(mockConfig, null);
        assertNotNull(requestWithNull);
    }

    @Test
    @DisplayName("setFileId should update file ID")
    void testSetFileId() throws Exception {
        byte[] newFileId = new byte[16];
        Arrays.fill(newFileId, (byte) 0xFF);

        request.setFileId(newFileId);

     * Cache#invalidate invalidations}.
     */
    void recordEviction();

    /**
     * Returns a snapshot of this counter's values. Note that this may be an inconsistent view, as
     * it may be interleaved with update operations.
     */
    CacheStats snapshot();
  }

  /**
   * A thread-safe {@link StatsCounter} implementation for use by {@link Cache} implementors.
   *
   * @since 10.0
   */

errors.app.illegal.transition = Ungültiger Übergang. Bitte versuchen Sie es erneut.
errors.app.db.already.deleted = Es wurde möglicherweise von einem anderen Prozess gelöscht. Bitte versuchen Sie den Vorgang erneut.
errors.app.db.already.updated = Es wurde möglicherweise von einem anderen Prozess aktualisiert. Bitte versuchen Sie den Vorgang erneut.
errors.app.db.already.exists = Die Daten sind bereits vorhanden. Bitte versuchen Sie den Vorgang erneut.

        int newVersion = keyManager.rotateSessionKey(sessionId);
        assertEquals(1, newVersion, "New version should be 1");
        assertEquals(1, keyManager.getKeyVersion(sessionId), "Key version should be updated");

        // Verify old key is archived
        assertTrue(keyManager.hasSessionKey(sessionId + ".v0"), "Archived key should exist");

        // New key should be different

	}
	for id, disk := range ahs.healStatus {
		for _, ep := range healLocalDisks {
			if disk.Endpoint == ep.String() {
				delete(ahs.healStatus, id)
			}
		}
	}
}

// updateHealStatus will update the heal status.
func (ahs *allHealState) updateHealStatus(tracker *healingTracker) {
	ahs.Lock()
	defer ahs.Unlock()

	tracker.mu.RLock()
	t := *tracker

	lru := lru.NewLRU[string, int](10, nil, time.Hour)
	lru.Add("key1", 1)
	lru.Add("key1", 2)

	if value, ok := lru.Get("key1"); !ok || value != 2 {
		t.Errorf("Expected value to be updated to 2, got %v", value)
	}
}

func TestLRU_Add_NewKey_AddsEntry(t *testing.T) {
	lru := lru.NewLRU[string, int](10, nil, time.Hour)
	lru.Add("key1", 1)

	if value, ok := lru.Get("key1"); !ok || value != 1 {