- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for Parent (0.15 sec)
-
cmd/os-reliable.go
} return nil } // Reliably retries os.MkdirAll if for some reason os.MkdirAll returns // syscall.ENOENT (parent does not exist). func reliableMkdirAll(dirPath string, mode os.FileMode, baseDir string) (err error) { i := 0 for { // Creates all the parent directories, with mode 0777 mkdir honors system umask. if err = osMkdirAll(dirPath, mode, baseDir); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/object-api-deleteobject_test.go
{ "bucket1", []objectUpload{{"object0", "content"}, {"object1", "content"}}, "object0", []string{"object1"}, }, // Test 2: remove an object inside a directory and checks it is deleted // with its parent since this former becomes empty { "bucket2", []objectUpload{{"object0", "content"}, {"dir/object1", "content"}}, "dir/object1", []string{"object0"}, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 23 15:46:00 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/disk/stat_linux.go
break } } if devName != "" { info.Name = devName qst, err := bfs.SysBlockDeviceQueueStats(devName) if err != nil { // Mostly not found error // Check if there is a parent device: // e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the // real device name (nvme0n1) to get its sysfs information parentDevPath, e := os.Readlink("/sys/class/block/" + devName)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
if s1.Mode()&os.ModeSymlink != 0 { return false } s2, err := os.Lstat(filepath.Dir(strings.TrimSuffix(path, "/"))) if err != nil { return false } // If the directory has a different device as parent, then it is a mountpoint. if s1.Sys().(*syscall.Stat_t).Dev != s2.Sys().(*syscall.Stat_t).Dev { // path/.. on a different device as path return true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.7K bytes - Viewed (0) -
cmd/os_unix.go
} if len(buf) < int(dirent.Reclen) { return consumed, nil, typ, fmt.Errorf("buf size %d < record length %d", len(buf), dirent.Reclen) } consumed = int(dirent.Reclen) if direntInode(dirent) == 0 { // File absent in directory. return } switch dirent.Type { case syscall.DT_REG: typ = 0 case syscall.DT_DIR: typ = os.ModeDir
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/bucket-policy.go
currTime := UTCNow() var ( username = cred.AccessKey claims = cred.Claims groups = cred.Groups ) if cred.IsTemp() || cred.IsServiceAccount() { // For derived credentials, check the parent user's permissions. username = cred.ParentUser } principalType := "Anonymous" if username != "" { principalType = "User" if len(claims) > 0 { principalType = "AssumedRole" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
cmd/os-dirent_namelen_linux.go
package cmd import ( "bytes" "fmt" "syscall" "unsafe" ) func direntNamlen(dirent *syscall.Dirent) (uint64, error) { const fixedHdr = uint16(unsafe.Offsetof(syscall.Dirent{}.Name)) nameBuf := (*[unsafe.Sizeof(dirent.Name)]byte)(unsafe.Pointer(&dirent.Name[0])) const nameBufLen = uint16(len(nameBuf)) limit := dirent.Reclen - fixedHdr if limit > nameBufLen { limit = nameBufLen } // Avoid bugs in long file names
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 1.5K bytes - Viewed (0) -
internal/logger/reqinfo.go
// Reading/writing directly to struct requires appropriate R/W lock. type ReqInfo struct { RemoteHost string // Client Host/IP Host string // Node Host/IP UserAgent string // User Agent DeploymentID string // x-minio-deployment-id RequestID string // x-amz-request-id API string // API name - GetObject PutObject NewMultipartUpload etc.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
internal/config/policy/opa/config.go
return err } oa := Args(so) if oa.URL == nil || oa.URL.String() == "" { *a = oa return nil } *a = oa return nil } // Opa - implements opa policy agent calls. type Opa struct { args Args client *http.Client } // Enabled returns if opa is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
internal/grid/muxserver.go
} else { m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID}) } m.parent.deleteMux(true, m.ID) } func (m *muxServer) send(msg message) { m.sendMu.Lock() defer m.sendMu.Unlock() msg.MuxID = m.ID msg.Seq = m.SendSeq m.SendSeq++ if debugPrint { fmt.Printf("Mux %d, Sending %+v\n", m.ID, msg) } gridLogIf(m.ctx, m.parent.queueMsg(msg, nil)) } func (m *muxServer) close() { m.cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0)