Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for hasEnded (0.32 sec)

  1. cmd/admin-heal-ops.go

    	defer periodicTimer.Stop()
    
    	for {
    		select {
    		case <-periodicTimer.C:
    			now := UTCNow()
    			ahs.Lock()
    			for path, h := range ahs.healSeqMap {
    				if h.hasEnded() && h.endTime.Add(keepHealSeqStateDuration).Before(now) {
    					delete(ahs.healSeqMap, path)
    				}
    			}
    			ahs.Unlock()
    
    			periodicTimer.Reset(time.Minute * 5)
    		case <-ctx.Done():
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    		globalAllHealState.Unlock()
    	}
    
    	// Init background heal state
    	if globalBackgroundHealState == nil {
    		globalBackgroundHealState = newHealState(GlobalContext, false)
    	} else {
    		globalBackgroundHealState.Lock()
    		for _, v := range globalBackgroundHealState.healSeqMap {
    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		}
    	}
    
    	healPath := pathJoin(hip.bucket, hip.objPrefix)
    	if hip.clientToken == "" && !hip.forceStart && !hip.forceStop {
    		nh, exists := globalAllHealState.getHealSequence(healPath)
    		if exists && !nh.hasEnded() && len(nh.currentStatus.Items) > 0 {
    			clientToken := nh.clientToken
    			if globalIsDistErasure {
    				clientToken = fmt.Sprintf("%s%s%d", nh.clientToken, getKeySeparator(), GetProxyEndpointLocalIndex(globalProxyEndpoints))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  4. tests/migrate_test.go

    	// not trigger alert column
    	AssertEqual(t, true, DB.Migrator().HasConstraint(&UniqueTest{}, "uni_unique_tests_name"))
    	AssertEqual(t, false, DB.Migrator().HasIndex(&UniqueTest{}, "name"))
    	AssertEqual(t, false, DB.Migrator().HasIndex(&UniqueTest{}, "name_1"))
    	AssertEqual(t, false, DB.Migrator().HasIndex(&UniqueTest{}, "name_2"))
    
    	ct, err = findColumnType(&UniqueTest{}, "name")
    	if err != nil {
    		t.Fatalf("findColumnType err:%v", err)
    	}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Aug 20 04:51:17 UTC 2025
    - 65.2K bytes
    - Viewed (0)
  5. migrator.go

    	DropConstraint(dst interface{}, name string) error
    	HasConstraint(dst interface{}, name string) bool
    
    	// Indexes
    	CreateIndex(dst interface{}, name string) error
    	DropIndex(dst interface{}, name string) error
    	HasIndex(dst interface{}, name string) bool
    	RenameIndex(dst interface{}, oldName, newName string) error
    	GetIndexes(dst interface{}) ([]Index, error)
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  6. migrator/migrator.go

    				name = idx.Name
    			}
    		}
    
    		return m.DB.Exec("DROP INDEX ? ON ?", clause.Column{Name: name}, m.CurrentTable(stmt)).Error
    	})
    }
    
    // HasIndex check has index `name` or not
    func (m Migrator) HasIndex(value interface{}, name string) bool {
    	var count int64
    	m.RunWithValue(value, func(stmt *gorm.Statement) error {
    		currentDatabase := m.DB.Migrator().CurrentDatabase()
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Jun 06 02:35:01 UTC 2025
    - 29.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/hash/HashCode.java

        return fromBytesNoCopy(bytes.clone());
      }
    
      /**
       * Creates a {@code HashCode} from a byte array. The array is <i>not</i> copied defensively, so it
       * must be handed-off so as to preserve the immutability contract of {@code HashCode}.
       */
      static HashCode fromBytesNoCopy(byte[] bytes) {
        return new BytesHashCode(bytes);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/ImmutableMultimap.java

          // at least one element.
          this.expectedValuesPerKey = max(expectedValuesPerKey, 1);
    
          return this;
        }
    
        /**
         * By default, if we are handed a value collection bigger than expectedValuesPerKey, presize to
         * accept that many elements.
         *
         * <p>This gets overridden in ImmutableSetMultimap.Builder to only trust the size of {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 28.6K bytes
    - Viewed (0)
  9. src/main/webapp/js/admin/bootstrap.min.js.map

    ARROW_UP_KEYCODE = 38 // KeyboardEvent.which value for up arrow key\nconst ARROW_DOWN_KEYCODE = 40 // KeyboardEvent.which value for down arrow key\nconst RIGHT_MOUSE_BUTTON_WHICH = 3 // MouseEvent.which value for the right button (assuming a right-handed mouse)\nconst REGEXP_KEYDOWN = new RegExp(`${ARROW_UP_KEYCODE}|${ARROW_DOWN_KEYCODE}|${ESCAPE_KEYCODE}`)\n\nconst CLASS_NAME_DISABLED = 'disabled'\nconst CLASS_NAME_SHOW = 'show'\nconst CLASS_NAME_DROPUP = 'dropup'\nconst CLASS_NAME_DROPRIGHT = 'dropright'\nconst...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 180.9K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.23.md

    Kubernetes releases are now generating provenance attestation files describing the staging and release phases of the release process and artifacts are verified as they are handed over from one phase to the next.
    This final piece completes the work needed to comply with Level 1 of the [SLSA security framework](https://slsa.dev/) (Supply-chain Levels for Software Artifacts).
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Tue Feb 28 21:06:52 UTC 2023
    - 424.5K bytes
    - Viewed (0)
Back to top