- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 279 for readdir (0.18 sec)
-
tests/integration/pilot/tunneling_test.go
} ctx.ConfigIstio().EvalFile(externalNs, templateParams, forwardProxyServiceFile).ApplyOrFail(ctx) } func listFilesInDirectory(ctx framework.TestContext, dir string) []string { files, err := os.ReadDir("testdata/tunneling/" + dir) if err != nil { ctx.Fatalf("failed to read files in directory: %s", err) } filesList := make([]string, 0, len(files)) for _, file := range files {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
// - https://www.kernel.org/doc/Documentation/cgroup-v2.txt 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 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux.go
for _, qosContainerName := range qosContainersList { // get the subsystems QoS cgroup absolute name qcConversion := m.cgroupManager.Name(qosContainerName) qc := path.Join(val, qcConversion) dirInfo, err := os.ReadDir(qc) if err != nil { if os.IsNotExist(err) { continue } return nil, fmt.Errorf("failed to read the cgroup directory %v : %v", qc, err) } for i := range dirInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:38:36 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/volume/util/volumepathhandler/volume_path_handler.go
} // GetDeviceBindMountRefs searches bind mounts under global map path func (v VolumePathHandler) GetDeviceBindMountRefs(devPath string, mapPath string) ([]string, error) { var refs []string files, err := os.ReadDir(mapPath) if err != nil { return nil, err } for _, file := range files { if file.Type()&os.ModeDevice != os.ModeDevice { continue } filename := file.Name()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.7K bytes - Viewed (0) -
src/cmd/go/internal/clean/clean.go
".so": true, } func clean(p *load.Package) { if cleaned[p] { return } cleaned[p] = true if p.Dir == "" { base.Errorf("%v", p.Error) return } dirs, err := os.ReadDir(p.Dir) if err != nil { base.Errorf("go: %s: %v", p.Dir, err) return } sh := work.NewShell("", fmt.Print) packageFile := map[string]bool{} if p.Name != "main" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
if err != nil { // Failed to create object, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } for _, disk := range disks { tmpMetaDir := path.Join(disk, minioMetaTmpBucket) files, err := os.ReadDir(tmpMetaDir) if err != nil { t.Fatal(err) } var found bool for _, fi := range files { if fi.Name() == ".trash" { continue } found = true } if found {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
src/cmd/go/script_test.go
archive.Files[gosumIdx].Data = newGosumData } return rewrite } func readCounters(t *testing.T, telemetryDir string) map[string]uint64 { localDir := filepath.Join(telemetryDir, "local") dirents, err := os.ReadDir(localDir) if err != nil { if os.IsNotExist(err) { return nil // The Go command didn't ever run so the local dir wasn't created } t.Fatalf("reading telemetry local dir: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/metacache-walk.go
// Limit the number of returned objects if > 0. Limit int // DiskID contains the disk ID of the disk. // Leave empty to not check disk ID. DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/log/config_test.go
}() } wg.Wait() Sync() ticker := time.NewTicker(100 * time.Millisecond) defer ticker.Stop() var rd []os.DirEntry for { select { case <-ticker.C: rd, err := os.ReadDir(dir) if err != nil { t.Fatalf("Unable to read dir: %v", err) } if len(rd) == o.RotationMaxBackups+1 { // perfect, we're done return } case <-time.After(5 * time.Second):
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 10.9K bytes - Viewed (0)