Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 163 for mock (0.14 sec)

  1. cmd/erasure-common.go

    				//   unformatted or simply not accessible for some reason.
    				//
    				// - Do not consume disks which are being healed
    				//
    				// - Future: skip busy disks
    				return
    			}
    
    			mu.Lock()
    			newDisks = append(newDisks, disks[i])
    			mu.Unlock()
    		}()
    	}
    	wg.Wait()
    	return newDisks
    }
    
    func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) {
    	disks := er.getOnlineDisks()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    		return
    	}
    
    	// Take read lock on object, here so subsequent lower-level
    	// calls do not need to.
    	lock := objectAPI.NewNSLock(bucket, object)
    	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/generic-handlers_test.go

    // Tests request guess function for net/rpc requests.
    func TestGuessIsRPC(t *testing.T) {
    	if guessIsRPCReq(nil) {
    		t.Fatal("Unexpected return for nil request")
    	}
    
    	u, err := url.Parse("http://localhost:9000/minio/lock")
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	r := &http.Request{
    		Proto:  "HTTP/1.0",
    		Method: http.MethodPost,
    		URL:    u,
    	}
    	if !guessIsRPCReq(r) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. cmd/api-errors.go

    	ErrObjectLockConfigurationNotFound: {
    		Code:           "ObjectLockConfigurationNotFoundError",
    		Description:    "Object Lock configuration does not exist for this bucket",
    		HTTPStatusCode: http.StatusNotFound,
    	},
    	ErrObjectLockConfigurationNotAllowed: {
    		Code:           "InvalidBucketState",
    		Description:    "Object Lock configuration cannot be enabled on existing buckets",
    		HTTPStatusCode: http.StatusConflict,
    	},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  5. cmd/object-api-errors.go

    	return "No bucket tags found for bucket: " + e.Bucket
    }
    
    // BucketObjectLockConfigNotFound - no bucket object lock config found
    type BucketObjectLockConfigNotFound GenericError
    
    func (e BucketObjectLockConfigNotFound) Error() string {
    	return "No bucket object lock configuration found for bucket: " + e.Bucket
    }
    
    // BucketQuotaConfigNotFound - no bucket quota config found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  6. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) Close() (err error) {
    	if err = d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.Close()
    }
    
    func (d *naughtyDisk) calcError() (err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	d.callNR++
    	if err, ok := d.errors[d.callNR]; ok {
    		return err
    	}
    	if d.defaultErr != nil {
    		return d.defaultErr
    	}
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  7. internal/config/identity/openid/jwt.go

    		pkey, err := key.DecodePublicKey()
    		if err != nil {
    			return err
    		}
    		pk.add(key.Kid, pkey)
    	}
    
    	return nil
    }
    
    func (pk *publicKeys) add(keyID string, key interface{}) {
    	pk.Lock()
    	defer pk.Unlock()
    
    	pk.pkMap[keyID] = key
    }
    
    func (pk *publicKeys) get(kid string) interface{} {
    	pk.RLock()
    	defer pk.RUnlock()
    	return pk.pkMap[kid]
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 8.3K bytes
    - Viewed (5)
  8. cmd/object_api_suite_test.go

    	globalCompressConfigMu.Lock()
    	globalCompressConfig.Enabled = false
    	globalCompressConfigMu.Unlock()
    
    	globalAutoEncryption = true
    	var err error
    	GlobalKMS, err = kms.Parse("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=")
    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    func resetCompressEncryption() {
    	// Reset...
    	globalCompressConfigMu.Lock()
    	globalCompressConfig.Enabled = false
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/podcgroupns.go

    	// - 0::/../crio-45490e76e0878aaa4d9808f7d2eefba37f093c3efbba9838b6d8ab804d9bd814.scope
    	// First trim off any .scope suffix. This allows for a cleaner regex since
    	// we don't have to muck with greediness. TrimSuffix is no-copy so this
    	// is cheap.
    	cgroupPath = strings.TrimSuffix(cgroupPath, ".scope")
    
    	var matchResults map[string]string
    	for _, regex := range cgroupREs {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  10. cmd/xl-storage-disk-id-check.go

    			newAcc := &AccElem{}
    			old := e.cached.Swap(newAcc)
    			var a AccElem
    			a.Size = atomic.LoadInt64(&old.Size)
    			a.Total = atomic.LoadInt64(&old.Total)
    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    			e.lastMinuteLatency.addAll(t-1, a)
    			e.mu.Unlock()
    			acc = newAcc
    		} else {
    			// We may be able to grab the new accumulator by yielding.
    			runtime.Gosched()
    			acc = e.cached.Load()
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
Back to top