Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for right (0.32 sec)

  1. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrParseExpectedRightParenBuiltinFunctionCall: {
    		Code:           "ParseExpectedRightParenBuiltinFunctionCall",
    		Description:    "Did not find the expected right parenthesis character in the SQL expression.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrParseExpectedTypeName: {
    		Code:           "ParseExpectedTypeName",
    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)
  2. cni/pkg/nodeagent/net.go

    		}
    
    	}
    	return pruneHostIPset(sets.New(addedIPSnapshot...), &s.hostsideProbeIPSet)
    }
    
    // addPodToHostNSIpset:
    // 1. get pod manifest
    // 2. Get all pod ips (might be several, v6/v4)
    // 3. update ipsets accordingly
    func addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr, hostsideProbeSet *ipset.IPSet) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  3. cmd/erasure-object.go

    		}
    
    		wg.Wait()
    		xioutil.SafeClose(done)
    
    		fi, ok := <-mrfCheck
    		if !ok {
    			return
    		}
    
    		if fi.Deleted {
    			return
    		}
    
    		// if one of the disk is offline, return right here no need
    		// to attempt a heal on the object.
    		if countErrs(errs, errDiskNotFound) > 0 {
    			return
    		}
    
    		var missingBlocks int
    		for i := range errs {
    			if IsErr(errs[i],
    				errFileNotFound,
    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/bucket-replication.go

    					Object:     objInfo,
    					UserAgent:  "Internal: [Replication]",
    					Host:       globalLocalNodeName,
    				})
    			}
    			// object with same VersionID already exists, replication kicked off by
    			// PutObject might have completed
    			if objInfo.TargetReplicationStatus(tgt.ARN) == replication.Pending ||
    				objInfo.TargetReplicationStatus(tgt.ARN) == replication.Failed ||
    				ri.OpType == replication.ExistingObjectReplicationType {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  5. cmd/site-replication.go

    					},
    				},
    				UpdatedAt: acc.UpdatedAt,
    			}); err != nil {
    				return errSRIAMError(err)
    			}
    		}
    	}
    
    	// Next should be Groups for some of these users, LDAP might have some Group
    	// DNs here
    	{
    		groups := make(map[string]GroupInfo)
    		err := globalIAMSys.store.loadGroups(ctx, groups)
    		if err != nil {
    			return errSRBackendIssue(err)
    		}
    
    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)
  6. cmd/xl-storage.go

    				versionID = nullVersionID
    			}
    
    			// PR #11758 used DataDir, preserve it
    			// for users who might have used master
    			// branch
    			xlMeta.data.remove(versionID, dataDir)
    
    			// We need to attempt delete "dataDir" on the disk
    			// due to a CopyObject() bug where it might have
    			// inlined the data incorrectly, to avoid a situation
    			// where we potentially leave "DataDir"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    	// cycle until we can safely update the in-memory cache.
    	//
    	// 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,
    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)
  8. cmd/common-main.go

    			err = fmt.Errorf("Unable to load TLS certificate '%s,%s': %w", certFile, keyFile, err)
    			bootLogIf(GlobalContext, err, logger.ErrorKind)
    		}
    	}
    	secureConn = true
    
    	// Certs might be symlinks, reload them every 10 seconds.
    	manager.UpdateReloadDuration(10 * time.Second)
    
    	// syscall.SIGHUP to reload the certs.
    	manager.ReloadOnSignal(syscall.SIGHUP)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  9. internal/auth/credentials.go

    // AnonymousCredentials simply points to empty credentials
    var AnonymousCredentials = Credentials{}
    
    // IsAccessKeyValid - validate access key for right length.
    func IsAccessKeyValid(accessKey string) bool {
    	return len(accessKey) >= accessKeyMinLen
    }
    
    // IsSecretKeyValid - validate secret key for right length.
    func IsSecretKeyValid(secretKey string) bool {
    	return len(secretKey) >= secretKeyMinLen
    }
    
    // Default access and secret keys.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 11.7K bytes
    - Viewed (0)
  10. cmd/mrf.go

    func (m *mrfState) healRoutine(z *erasureServerPools) {
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case u, ok := <-m.opCh:
    			if !ok {
    				return
    			}
    
    			// We might land at .metacache, .trash, .multipart
    			// no need to heal them skip, only when bucket
    			// is '.minio.sys'
    			if u.bucket == minioMetaBucket {
    				// No MRF needed for temporary objects
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
Back to top