Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 723 for oper (0.03 sec)

  1. cmd/erasure-healing.go

    	if err != nil {
    		return result, err
    	}
    
    	// No modtime quorum
    	filterDisksByETag := quorumETag != ""
    
    	// List of disks having all parts as per latest metadata.
    	// NOTE: do not pass in latestDisks to diskWithAllParts since
    	// the diskWithAllParts needs to reach the drive to ensure
    	// validity of the metadata content, we should make sure that
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                    }
    
                    if (emptyListCount >= maxEmptyListCount) {
                        if (logger.isInfoEnabled()) {
                            logger.info("Terminating indexUpdater. emptyListCount is over {}.", maxEmptyListCount);
                        }
                        // terminate crawling
                        finishCrawling = true;
                        forceStop();
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  3. cmd/endpoint-ellipses.go

    				if node.nodeName == "" {
    					singleNode = true
    				}
    
    				if len(node.disks) <= i {
    					stopping = true
    					continue
    				}
    				if stopping {
    					return layout, errors.New("number of disks per node does not match")
    				}
    				eps = append(eps, node.disks[i])
    			}
    			if stopping {
    				break
    			}
    		}
    
    		for _, node := range endpointsList {
    			if node.nodeName != "" && singleNode {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  4. cmd/endpoint.go

    			if endpoint.IsLocal {
    				disks = append(disks, endpoint.Path)
    			}
    		}
    	}
    	return disks
    }
    
    // NLocalDisksPathsPerPool returns the disk paths of the local disks per pool
    func (l EndpointServerPools) NLocalDisksPathsPerPool() []int {
    	localDisksCount := make([]int, len(l))
    	for i, ep := range l {
    		for _, endpoint := range ep.Endpoints {
    			if endpoint.IsLocal {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    			objectName:         objectName,
    			accessKey:          "Invalid-AccessID",
    			secretKey:          credentials.SecretKey,
    			expectedRespStatus: http.StatusForbidden,
    		},
    	}
    
    	// Iterating over the cases, fetching the object validating the response.
    	for i, testCase := range testCases {
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  6. tensorflow/c/eager/c_api.h

    } TFE_ContextDevicePlacementPolicy;
    // LINT.ThenChange(//tensorflow/c/eager/immediate_execution_context.h)
    
    // Sets the default execution mode (sync/async). Note that this can be
    // overridden per thread using TFE_ContextSetExecutorForThread.
    TF_CAPI_EXPORT extern void TFE_ContextOptionsSetAsync(TFE_ContextOptions*,
                                                          unsigned char enable);
    
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 22.8K bytes
    - Viewed (0)
  7. cmd/perf-tests.go

    	r.buf = make([]byte, 128*humanize.KiByte)
    	rand.Read(r.buf)
    
    	connectionsPerPeer := 16
    
    	if len(globalNotificationSys.peerClients) > 16 {
    		// For a large cluster it's enough to have 1 connection per peer to saturate the network.
    		connectionsPerPeer = 1
    	}
    
    	errStr := ""
    	var wg sync.WaitGroup
    	for index := range globalNotificationSys.peerClients {
    		if globalNotificationSys.peerClients[index] == nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. internal/s3select/sql/funceval.go

    	bothNumeric := v1.isNumeric() && v2.isNumeric()
    	if atleastOneNumeric || !bothNumeric {
    		return v1, nil
    	}
    
    	if v1.SameTypeAs(*v2) {
    		return v1, nil
    	}
    
    	cmpResult, cmpErr := v1.compareOp(opEq, v2)
    	if cmpErr != nil {
    		return nil, cmpErr
    	}
    
    	if cmpResult {
    		return FromNull(), nil
    	}
    
    	return v1, nil
    }
    
    func charlen(v *Value) (*Value, error) {
    	inferTypeAsString(v)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 13.2K bytes
    - Viewed (0)
  9. helm/minio/values.yaml

      configUrl: "https://identity-provider-url/.well-known/openid-configuration"
      clientId: "minio"
      clientSecret: ""
      # Provide existing client secret from the Kubernetes Secret resource, existing secret will have priority over `clientId` and/or `clientSecret``
      existingClientSecretName: ""
      existingClientIdKey: ""
      existingClientSecretKey: ""
      claimName: "policy"
      scopes: "openid,profile,email"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 15:48:31 UTC 2024
    - 18.8K bytes
    - Viewed (1)
  10. cmd/update.go

    // Check if this is Helm package installation and report helm chart version
    func getHelmVersion(helmInfoFilePath string) string {
    	// Read the file exists.
    	helmInfoFile, err := Open(helmInfoFilePath)
    	if err != nil {
    		// Log errors and return "" as MinIO can be deployed
    		// without Helm charts as well.
    		if !osIsNotExist(err) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
Back to top