Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for updating (0.18 sec)

  1. internal/cachevalue/cache.go

    	if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 && (v.e == nil || t.opts.CacheError) {
    		if t.updating.TryLock() {
    			go func() {
    				defer t.updating.Unlock()
    				t.update()
    			}()
    		}
    		return v.v, v.e
    	}
    
    	// Get lock. Either we get it or we wait for it.
    	t.updating.Lock()
    	if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
    		// There is a new value, release lock and return it.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  2. cmd/xl-storage_noatime_supported.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    var (
    	// Disallow updating access times
    	readMode = os.O_RDONLY | 0x40000 // O_NOATIME
    
    	// Write with data sync only used only for `xl.meta` writes
    	writeMode = 0x1000 // O_DSYNC
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 1K bytes
    - Viewed (0)
  3. cmd/object-api-common.go

    	// Deleted Buckets prefix.
    	deletedBucketsPrefix = ".deleted"
    
    	// ETag (hex encoded md5sum) of empty string.
    	emptyETag = "d41d8cd98f00b204e9800998ecf8427e"
    )
    
    // Global object layer mutex, used for safely updating object layer.
    var globalObjLayerMutex sync.RWMutex
    
    // Global object layer, only accessed by globalObjectAPI.
    var globalObjectAPI ObjectLayer
    
    type storageOpts struct {
    	cleanUp     bool
    	healthCheck bool
    }
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  4. cmd/metacache-manager.go

    	m.init.Do(m.initManager)
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	for bucket, b := range m.buckets {
    		b.deleteAll()
    		delete(m.buckets, bucket)
    	}
    }
    
    // checkMetacacheState should be used if data is not updating.
    // Should only be called if a failure occurred.
    func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error {
    	// We operate on a copy...
    	o.Create = false
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  5. docs/compression/README.md

    ## Get Started
    
    ### 1. Prerequisites
    
    Install MinIO - [MinIO Quickstart Guide](https://min.io/docs/minio/linux/index.html#quickstart-for-linux).
    
    ### 2. Run MinIO with compression
    
    Compression can be enabled by updating the `compress` config settings for MinIO server config.
    Config `compress` settings take extensions and mime-types to be compressed.
    
    ```bash
    ~ mc admin config get myminio compression
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    	CheckPrecondFn      CheckPreconditionFn // only set during GetObject/HeadObject/CopyObjectPart preconditional valuation
    	EvalMetadataFn      EvalMetadataFn      // only set for retention settings, meant to be used only when updating metadata in-place.
    	DeleteReplication   ReplicationState    // Represents internal replication state needed for Delete replication
    	Transition          TransitionOptions
    	Expiration          ExpirationOptions
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    		return
    	}
    
    	user, exists := globalIAMSys.GetUser(ctx, accessKey)
    	if exists && (user.Credentials.IsTemp() || user.Credentials.IsServiceAccount()) {
    		// Updating STS credential is not allowed, and this API does not
    		// support updating service accounts.
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAddUserInvalidArgument), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 18 15:15:02 GMT 2024
    - 76K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    		queued:    time.Now(),
    	})
    }
    
    func (er erasureObjects) PutObjectMetadata(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, error) {
    	if !opts.NoLock {
    		// Lock the object before updating metadata.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  9. docs/bucket/notifications/README.md

    Before updating the configuration, let's start with `mc admin config get` command to get the current configuration.
    
    ```sh
    $ mc admin config get myminio/ notify_mysql
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  10. cmd/bucket-replication.go

    	object := ri.Name
    
    	// set defaults for replication action based on operation being performed - actual
    	// replication action can only be determined after stat on remote. This default is
    	// needed for updating replication metrics correctly when target is offline.
    	rAction := replicateMetadata
    
    	rinfo = replicatedTargetInfo{
    		Size:                  ri.ActualSize,
    		Arn:                   tgt.ARN,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
Back to top