- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for internalLogIf (0.21 sec)
-
cmd/bucket-object-lock.go
ret := objectlock.GetObjectRetentionMeta(objInfo.UserDefined) if ret.Mode.Valid() && (ret.Mode == objectlock.RetCompliance || ret.Mode == objectlock.RetGovernance) { t, err := objectlock.UTCNowNTP() if err != nil { internalLogIf(ctx, err, logger.WarningKind) return true } if ret.RetainUntilDate.After(t) { return true } } return false }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/license-update.go
if r.Index == 0 { internalLogIf(ctx, fmt.Errorf("license not found in response from %s", url)) return } lic := r.String() if lic == globalSubnetConfig.License { // license hasn't changed. return } kv := "subnet license=" + lic result, err := setConfigKV(ctx, objectAPI, []byte(kv)) if err != nil { internalLogIf(ctx, fmt.Errorf("error setting subnet license config: %w", err))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/callhome.go
}{Version: healthInfo.Version} enc := json.NewEncoder(gzWriter) if e := enc.Encode(header); e != nil { internalLogIf(ctx, fmt.Errorf("Could not encode health info header: %w", e)) return nil } if e := enc.Encode(healthInfo); e != nil { internalLogIf(ctx, fmt.Errorf("Could not encode health info: %w", e)) return nil } gzWriter.Flush() gzWriter.Close()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
cmd/metacache-walk.go
meta.metadata, err = xioutil.ReadFile(pathJoinBuf(sb, volumeDir, current, entry)) diskHealthCheckOK(ctx, err) if err != nil { if !IsErrIgnored(err, io.EOF, io.ErrUnexpectedEOF) { internalLogIf(ctx, err) } continue } meta.name = strings.TrimSuffix(entry, xlStorageFormatFileV1) meta.name = strings.TrimSuffix(meta.name, SlashSeparator)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/update.go
// CRI-O, Containerd etc.. // Fallback to our container specific ENVs if they are set. return env.IsSet("MINIO_ACCESS_KEY_FILE") } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil } // IsDCOS returns true if minio is running in DCOS. func IsDCOS() bool { // http://mesos.apache.org/documentation/latest/docker-containerizer/
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/bucket-quota.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
cmd/prepare-storage.go
if unformattedDisks && firstDisk { return nil, nil, errFirstDiskWait } format, err = getFormatErasureInQuorum(formatConfigs) if err != nil { internalLogIf(GlobalContext, err) return nil, nil, err } if format.ID == "" { internalLogIf(GlobalContext, errors.New("unexpected error deployment ID is missing, refusing to continue")) return nil, nil, errInvalidArgument }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
cmd/metacache-marker.go
if o.ID == "" { // Mark as returning listing... return fmt.Sprintf("%s[minio_cache:%s,return:]", marker, markerTagVersion) } if strings.ContainsAny(o.ID, "[:,") { internalLogIf(context.Background(), fmt.Errorf("encodeMarker: uuid %s contained invalid characters", o.ID)) } return fmt.Sprintf("%s[minio_cache:%s,id:%s,p:%d,s:%d]", marker, markerTagVersion, o.ID, o.pool, o.set)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/metacache-set.go
loadedPart = -1 time.Sleep(retryDelay250) continue default: internalLogIf(ctx, err) return entries, err } } // We finished at the end of the block. // And should not expect any more results. bi, err := getMetacacheBlockInfo(fi, partN) internalLogIf(ctx, err) if err != nil || bi.EOS { // We are done and there are no more parts.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/bucket-metadata.go
// If an error is returned the returned metadata will be default initialized. func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) { if name == "" { internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind) return BucketMetadata{}, errInvalidArgument } b := newBucketMetadata(name) configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 16.5K bytes - Viewed (0)