Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 55 for refresh (0.16 sec)

  1. internal/s3select/sql/value.go

    	case []Value:
    		_, ok = b.value.([]Value)
    	default:
    		ok = reflect.TypeOf(v.value) == reflect.TypeOf(b.value)
    	}
    	return ok
    }
    
    // ToBool returns the bool value; second return value refers to if the bool
    // conversion succeeded.
    func (v Value) ToBool() (val bool, ok bool) {
    	val, ok = v.value.(bool)
    	return
    }
    
    // ToTimestamp returns the timestamp value if present.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  2. docs/config/README.md

    ## Configuration Directory
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	}
    
    	// Fill all the necessary metadata.
    	// Update `xl.meta` content on each disks.
    	for index := range partsMetadata {
    		partsMetadata[index].Size = n
    		partsMetadata[index].Fresh = true
    		partsMetadata[index].ModTime = modTime
    		partsMetadata[index].Metadata = opts.UserDefined
    	}
    
    	// Set an additional header when data is inlined.
    	for index := range partsMetadata {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/lock-rest-client.go

    // RUnlock calls read unlock REST API.
    func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRUnlock, &args)
    }
    
    // Refresh calls Refresh REST API.
    func (c *lockRESTClient) Refresh(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRefresh, &args)
    }
    
    // Unlock calls write unlock RPC.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Nov 24 17:07:14 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  5. cmd/lock-rest-server.go

    type lockRESTServer struct {
    	ll *localLocker
    }
    
    // RefreshHandler - refresh the current lock
    func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCRefresh.NewResponse()
    	refreshed, err := l.ll.Refresh(context.Background(), *args)
    	if err != nil {
    		return l.makeResp(resp, err)
    	}
    	if !refreshed {
    		return l.makeResp(resp, errLockNotFound)
    	}
    	return l.makeResp(resp, err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  6. cmd/iam-store.go

    	//
    	// An in-memory cache must be replaced only if we know for sure that the
    	// values loaded from disk are not stale. They might be stale if the
    	// cached.updatedAt is more recent than the refresh cycle began.
    	if cache.updatedAt.Before(loadedAt) {
    		// No one has updated anything since the config was loaded,
    		// so we just replace whatever is on the disk into memory.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  7. internal/kms/kes.go

    	if err != nil {
    		logger.LogOnceIf(ctx, fmt.Errorf("%s, using default of 10s", err.Error()), "refresh-kms-master-key")
    		cacheDuration = defaultCacheDuration
    	}
    	if cacheDuration < time.Second {
    		logger.LogOnceIf(ctx, errors.New("cache duration is less than 1s, using default of 10s"), "refresh-kms-master-key")
    		cacheDuration = defaultCacheDuration
    	}
    	timer := time.NewTimer(cacheDuration)
    	defer timer.Stop()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  8. cmd/local-locker.go

    				idx++
    				continue
    			}
    			reply = true
    			l.removeEntry(resource, dsync.LockArgs{UID: args.UID}, &lris)
    			idx++
    		}
    	}
    }
    
    func (l *localLocker) Refresh(ctx context.Context, args dsync.LockArgs) (refreshed bool, err error) {
    	select {
    	case <-ctx.Done():
    		return false, ctx.Err()
    	default:
    		l.mutex.Lock()
    		defer l.mutex.Unlock()
    
    		// Check whether uid is still active.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. cmd/site-replication.go

    				took := time.Since(refreshStart).Seconds()
    				if took > maxRefreshDurationSecondsForLog {
    					// Log if we took a lot of time.
    					logger.Info("Site replication healing refresh took %.2fs", took)
    				}
    
    				// wait for 200 millisecond, if we are experience lot of I/O
    				waitForLowIO(runtime.GOMAXPROCS(0), 200*time.Millisecond, currentHTTPIO)
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  10. cmd/format-erasure.go

    		Version string `json:"version"` // Version of 'xl' format.
    		Disk    string `json:"drive"`   // Disk field carries assigned disk uuid.
    		// JBOD field carries the input disk order generated the first
    		// time when fresh disks were supplied.
    		JBOD []string `json:"jbod"`
    	} `json:"xl"` // Erasure field holds xl format.
    }
    
    // Represents the V2 backend disk structure version
    // under `.minio.sys` and actual data namespace.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
Back to top