Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for hasEnded (0.04 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. 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)
  5. 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)
  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. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    calling out in a confused way, `Prizes! Prizes!'
    
      Alice had no idea what to do, and in despair she put her hand
    in her pocket, and pulled out a box of comfits, (luckily the salt
    water had not got into it), and handed them round as prizes.
    There was exactly one a-piece all round.
    
      `But she must have a prize herself, you know,' said the Mouse.
    
      `Of course,' the Dodo replied very gravely.  `What else have
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
  10. 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)
Back to top