- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for scandir (0.2 sec)
-
cmd/metacache-walk.go
if sterr == nil && st.Mode().IsRegular() { return errFileNotFound } } } prefix := opts.FilterPrefix var scanDir func(path string) error scanDir = func(current string) error { // Skip forward, if requested... sb := bytebufferpool.Get() defer func() { sb.Reset() bytebufferpool.Put(sb) }() forward := ""
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) -
src/cmd/api/main_test.go
return pkg, nil } } } info, err := context.ImportDir(dir, 0) if err != nil { if _, nogo := err.(*build.NoGoError); nogo { return nil, err } log.Fatalf("pkg %q, dir %q: ScanDir: %v", name, dir, err) } // Save tags list first time we see a directory. if usePkgCache { if _, ok := pkgTags[dir]; !ok { pkgTags[dir] = info.AllTags key = tagKey(dir, context, info.AllTags)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar
lean); public void setFollowSymlinks(boolean); public void setIncludes(String[]); public void setExcludes(String[]); public boolean isEverythingIncluded(); public void scan() throws IllegalStateExceptio; protected void slowScan(); protected void scandir(java.io.File, String, boolean); protected boolean isIncluded(String); protected boolean couldHoldIncluded(String); protected boolean isExcluded(String); protected boolean isSelected(String, java.io.File); public String[] getIncludedFiles(); public...
Archive - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 164.6K bytes - Viewed (0) -
internal/config/scanner/scanner.go
ExcessFolders = "alert_excess_folders" EnvExcessFolders = "MINIO_SCANNER_ALERT_EXCESS_FOLDERS" // All below are deprecated in October 2022 and // replaced them with a single speed parameter Delay = "delay" MaxWait = "max_wait" Cycle = "cycle" EnvDelay = "MINIO_SCANNER_DELAY" EnvCycle = "MINIO_SCANNER_CYCLE"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/data-scanner.go
BucketName: f.root, Object: ObjectInfo{ Name: prefixName, Size: int64(totalFolders), }, UserAgent: "Scanner", Host: globalMinioHost, }) auditLogInternal(context.Background(), AuditLogOptions{ Event: "scanner:manyprefixes", APIName: "Scanner", Bucket: f.root, Object: prefixName, Tags: map[string]interface{}{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 47.4K bytes - Viewed (0) -
internal/event/name.go
return "s3:ObjectTransition:Failed" case ObjectTransitionComplete: return "s3:ObjectTransition:Complete" case ObjectManyVersions: return "s3:Scanner:ManyVersions" case ObjectLargeVersions: return "s3:Scanner:LargeVersions" case PrefixManyFolders: return "s3:Scanner:BigPrefix" } return "" } // MarshalXML - encodes to XML data.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 17:45:03 GMT 2024 - 10.2K bytes - Viewed (0) -
cmd/config-current.go
} else { globalBatchConfig.Update(batchCfg) } case config.ScannerSubSys: scannerCfg, err := scanner.LookupConfig(s[config.ScannerSubSys][config.Default]) if err != nil { errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err)) } else { // update dynamic scanner values. scannerIdleMode.Store(scannerCfg.IdleMode) scannerCycle.Store(scannerCfg.Cycle)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 11:33:28 GMT 2024 - 30.7K bytes - Viewed (0) -
cmd/logging.go
} func scannerLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "scanner", err, errKind...) } func scannerLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "scanner", err, id, errKind...) } func ilmLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "ilm", err, errKind...)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 6.6K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) { reader := bytes.NewReader(procCgroupData.Bytes()) var cgroups []Cgroup scanner := bufio.NewScanner(reader) for scanner.Scan() { token := scanner.Text() substrings := strings.SplitN(token, ":", 3) if len(substrings) < 3 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cmd/erasure.go
return nil } // Collect disks we can use. disks, healing := er.getOnlineDisksWithHealing(false) if len(disks) == 0 { scannerLogIf(ctx, errors.New("data-scanner: all drives are offline or being healed, skipping scanner cycle")) return nil } // Load bucket totals oldCache := dataUsageCache{} if err := oldCache.load(ctx, er, dataUsageCacheName); err != nil { return err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1)