Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 283 for Lock (0.18 sec)

  1. internal/config/batch/batch.go

    		KeyRotationWorkersWait: opts.KeyRotationWorkersWait,
    		ExpirationWorkersWait:  opts.ExpirationWorkersWait,
    	}
    }
    
    // Update updates opts with nopts
    func (opts *Config) Update(nopts Config) {
    	configMu.Lock()
    	defer configMu.Unlock()
    
    	opts.ReplicationWorkersWait = nopts.ReplicationWorkersWait
    	opts.KeyRotationWorkersWait = nopts.KeyRotationWorkersWait
    	opts.ExpirationWorkersWait = nopts.ExpirationWorkersWait
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. helm/minio/templates/_helper_create_bucket.txt

    	if ! checkBucketExists $BUCKET; then
    		if [ ! -z $OBJECTLOCKING ]; then
    			if [ $OBJECTLOCKING = true ]; then
    				echo "Creating bucket with OBJECTLOCKING '$BUCKET'"
    				${MC} mb --with-lock myminio/$BUCKET
    			elif [ $OBJECTLOCKING = false ]; then
    				echo "Creating bucket '$BUCKET'"
    				${MC} mb myminio/$BUCKET
    			fi
    		elif [ -z $OBJECTLOCKING ]; then
    			echo "Creating bucket '$BUCKET'"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jan 12 18:18:57 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. internal/logger/audit.go

    		entry.API.HeaderBytes = headerBytes
    		entry.API.TimeToResponse = strconv.FormatInt(timeToResponse.Nanoseconds(), 10) + "ns"
    		entry.API.TimeToResponseInNS = strconv.FormatInt(timeToResponse.Nanoseconds(), 10)
    		// We hold the lock, so we cannot call reqInfo.GetTagsMap().
    		tags := make(map[string]interface{}, len(reqInfo.tags))
    		for _, t := range reqInfo.tags {
    			tags[t.Key] = t.Val
    		}
    		entry.Tags = tags
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle.go

    		return nil
    	}
    	workers := *w
    	return workers[h%uint64(len(workers))]
    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	// Lock to avoid multiple resizes to happen at the same time.
    	es.mu.Lock()
    	defer es.mu.Unlock()
    	var workers []chan expiryOp
    	if v := es.workers.Load(); v != nil {
    		// Copy to new array.
    		workers = append(workers, *v...)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  5. internal/config/callhome/callhome.go

    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    		return callhomeCycleDefault
    	}
    
    	return c.Frequency
    }
    
    // Update updates new callhome frequency
    func (c *Config) Update(ncfg Config) {
    	configLock.Lock()
    	defer configLock.Unlock()
    
    	c.Enable = ncfg.Enable
    	c.Frequency = ncfg.Frequency
    }
    
    // LookupConfig - lookup config and override with valid environment settings if any.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. internal/config/drive/drive.go

    	// MaxTimeout - maximum timeout for a drive operation
    	MaxTimeout time.Duration `json:"maxTimeout"`
    }
    
    // Update - updates the config with latest values
    func (c *Config) Update(new Config) error {
    	configLk.Lock()
    	defer configLk.Unlock()
    	c.MaxTimeout = getMaxTimeout(new.MaxTimeout)
    	return nil
    }
    
    // GetMaxTimeout - returns the per call drive operation timeout
    func (c *Config) GetMaxTimeout() time.Duration {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. src/main/webapp/WEB-INF/view/login/index.jsp

    						</c:set>
    						<la:password property="password" class="form-control"
    							placeholder="${ph_password}" />
    						<div class="input-group-append">
    							<span class="input-group-text">
    								<em class="fa fa-lock fa-fw">
    							</span>
    						</div>
    					</div>
    					<div class="text-center">
    						<button type="submit" name="login"
    							class="btn btn-primary btn-block"
    							value="<la:message key="labels.login"/>">
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. buildscripts/rewrite-old-new.sh

    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    	"${WORK_DIR}/mc" mb minio/healing-rewrite-bucket --quiet --with-lock
    	"${WORK_DIR}/mc" cp \
    		buildscripts/verify-build.sh \
    		minio/healing-rewrite-bucket/ \
    		--disable-multipart --quiet
    
    	"${WORK_DIR}/mc" cp \
    		buildscripts/verify-build.sh \
    		minio/healing-rewrite-bucket/ \
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. src/packaging/rpm/init.d/fess

    export FESS_CONF_PATH
    export FESS_VAR_PATH
    export FESS_DICTIONARY_PATH
    export FESS_HEAP_SIZE
    export SEARCH_ENGINE_HOME
    export SEARCH_ENGINE_HTTP_URL
    export FESS_JAVA_OPTS
    export JAVA_HOME
    
    lockfile=/var/lock/subsys/$prog
    
    # backwards compatibility for old config sysconfig files, pre 0.90.1
    if [ -n $USER ] && [ -z $FESS_USER ] ; then 
       FESS_USER=$USER
    fi
    
    checkJava() {
        if [ -x "$JAVA_HOME/bin/java" ]; then
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  10. cmd/bucket-versioning-handler.go

    	if rcfg, _ := globalBucketObjectLockSys.Get(bucket); rcfg.LockEnabled && (v.Suspended() || v.PrefixesExcluded()) {
    		writeErrorResponse(ctx, w, APIError{
    			Code:           "InvalidBucketState",
    			Description:    "An Object Lock configuration is present on this bucket, versioning cannot be suspended.",
    			HTTPStatusCode: http.StatusBadRequest,
    		}, r.URL)
    		return
    	}
    	if rc, _ := getReplicationConfig(ctx, bucket); rc != nil && v.Suspended() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top