- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 293 for Kappen (0.17 sec)
-
internal/ioutil/append-file_nix.go
package ioutil import ( "io" "os" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE if osync { flags |= os.O_SYNC } appendFile, err := os.OpenFile(dst, flags, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := os.Open(src)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
if len(listObjectsInfo.Prefixes) == 0 || commonPrefix != listObjectsInfo.Prefixes[len(listObjectsInfo.Prefixes)-1] { listObjectsInfo.Prefixes = append(listObjectsInfo.Prefixes, commonPrefix) count++ } goto next } } listObjectsInfo.Objects = append(listObjectsInfo.Objects, ObjectInfo{ Bucket: bucket, Name: objName, Size: int64(file.UncompressedSize64),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 09 10:41:25 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/metacache-set.go
for i, info := range infos { mutations := info.Metrics.TotalDeletes + info.Metrics.TotalWrites if mutations >= commonMutations { newDisks = append(newDisks, disks[i]) newInfos = append(newInfos, infos[i]) } } return newDisks, newInfos } func getQuorumDisks(disks []StorageAPI, infos []DiskInfo, readQuorum int) (newDisks []StorageAPI) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 18 04:42:11 GMT 2024 - 30.4K bytes - Viewed (0) -
internal/config/config.go
kvs.Set(kv.Key, kv.Value) } } targets = append(targets, Target{ SubSystem: inputs[0], KVS: kvs, }) } else { // Use help for sub-system to preserve the order. Add deprecated // keys at the end (in some order). kvsOrder := append([]HelpKV{}, HelpSubSysMap[""]...) for _, v := range HelpDeprecatedSubSysMap { kvsOrder = append(kvsOrder, v) } for _, hkv := range kvsOrder {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/notification.go
} replies[idx] = info }(client, i) } wg.Wait() // Add local to this server. replies = append(replies, objLayer.LocalStorageInfo(GlobalContext, metrics)) storageInfo.Backend = objLayer.BackendInfo() for _, sinfo := range replies { storageInfo.Disks = append(storageInfo.Disks, sinfo.Disks...) } return storageInfo }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/admin-handlers.go
hostErrs = append(hostErrs, globalNotificationSys.StartProfiling(profiler)...) // Start profiling locally as well. prof, err := startProfiler(profiler) if err != nil { hostErrs = append(hostErrs, NotificationPeerErr{ Host: *thisAddr, Err: err, }) } else { globalProfiler[profiler] = prof hostErrs = append(hostErrs, NotificationPeerErr{
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/erasure-multipart.go
MetadataOnly: true, } for _, part := range parts { req.Files = append(req.Files, fmt.Sprintf("part.%d.meta", part.PartNumber)) } partInfoFiles, err := readMultipleFiles(ctx, onlineDisks, req, writeQuorum) if err != nil { return oi, err } if len(partInfoFiles) != len(parts) { // Should only happen through internal error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 42.4K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
// returns file mode creation mask. func getUmask() int { mask := syscall.Umask(0) syscall.Umask(mask) return mask } // Tests if the directory and file creations happen with proper umask. func TestIsValidUmaskVol(t *testing.T) { tmpPath := t.TempDir() testCases := []struct { volName string expectedUmask int }{ {"is-this-valid", getUmask()}, }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 3.4K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
// map header, size 5 // string "Name" o = append(o, 0x85, 0xa4, 0x4e, 0x61, 0x6d, 0x65) o = msgp.AppendString(o, z.Name) // string "Created" o = append(o, 0xa7, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x64) o = msgp.AppendTime(o, z.Created) // string "Deleted" o = append(o, 0xa7, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x64) o = msgp.AppendTime(o, z.Deleted) // string "Versioning"
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0) -
cmd/batch-handlers_gen.go
// string "v" o = append(o, 0xde, 0x0, 0x10, 0xa1, 0x76) o = msgp.AppendInt(o, z.Version) // string "jid" o = append(o, 0xa3, 0x6a, 0x69, 0x64) o = msgp.AppendString(o, z.JobID) // string "jt" o = append(o, 0xa2, 0x6a, 0x74) o = msgp.AppendString(o, z.JobType) // string "st" o = append(o, 0xa2, 0x73, 0x74) o = msgp.AppendTime(o, z.StartTime) // string "lu" o = append(o, 0xa2, 0x6c, 0x75)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 07 18:58:22 GMT 2024 - 18.1K bytes - Viewed (0)