- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 120 for Writer (0.15 sec)
-
cmd/admin-handlers_test.go
Addr: owner, Locks: locksHeld, }) } var exp madmin.LockEntries for _, lri := range lris { lockType := func(lri lockRequesterInfo) string { if lri.Writer { return "WRITE" } return "READ" } exp = append(exp, madmin.LockEntry{ Resource: lri.Name, Type: lockType(lri), ServerList: owners, Owner: lri.Owner,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/dsync/lock-args_gen.go
return } // EncodeMsg implements msgp.Encodable func (z *LockArgs) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 5 // write "UID" err = en.Append(0x85, 0xa3, 0x55, 0x49, 0x44) if err != nil { return } err = en.WriteString(z.UID) if err != nil { err = msgp.WrapError(err, "UID") return } // write "Resources" err = en.Append(0xa9, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
} // EncodeMsg implements msgp.Encodable func (z ActiveWorkerStat) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "Curr" err = en.Append(0x83, 0xa4, 0x43, 0x75, 0x72, 0x72) if err != nil { return } err = en.WriteInt(z.Curr) if err != nil { err = msgp.WrapError(err, "Curr") return } // write "Avg" err = en.Append(0xa3, 0x41, 0x76, 0x67) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
runtime.GOMAXPROCS(gomaxprocs) // Number of active readers + 10000 * number of active writers. var activity int32 cdone := make(chan bool) go writer(resource, numIterations, &activity, cdone) var i int for i = 0; i < numReaders/2; i++ { go reader(resource, numIterations, &activity, cdone) } go writer(resource, numIterations, &activity, cdone) for ; i < numReaders; i++ {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
cmd/erasure-encode_test.go
} writers := make([]io.Writer, len(disks)) for i, disk := range disks { if disk == nil { continue } writers[i] = newBitrotWriter(disk, "", "testbucket", "object2", erasure.ShardFileSize(int64(len(data[test.offset:]))), test.algorithm, erasure.ShardSize()) } for j := range disks[:test.offDisks] { switch w := writers[j].(type) { case *wholeBitrotWriter:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/storage-interface.go
DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/s3select/csv/args.go
QuoteCharacter string `xml:"QuoteCharacter"` QuoteEscapeCharacter string `xml:"QuoteEscapeCharacter"` unmarshaled bool } // IsEmpty - returns whether writer args is empty or not. func (args *WriterArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *WriterArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 5.4K bytes - Viewed (0) -
cmd/notification.go
// DownloadProfilingData - download profiling data from all remote peers. func (sys *NotificationSys) DownloadProfilingData(ctx context.Context, writer io.Writer) (profilingDataFound bool) { // Initialize a zip writer which will provide a zipped content // of profiling data of all nodes zipWriter := zip.NewWriter(writer) defer zipWriter.Close() for _, client := range sys.peerClients { if client == nil { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/bootstrap-peer-server_gen.go
func (z *ServerSystemConfig) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 3 // write "NEndpoints" err = en.Append(0x83, 0xaa, 0x4e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73) if err != nil { return } err = en.WriteInt(z.NEndpoints) if err != nil { err = msgp.WrapError(err, "NEndpoints") return } // write "CmdLines"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 24 21:36:44 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/main.go
for _, cmd := range closestCommands { console.Printf("\t‘%s’\n", cmd) } } os.Exit(1) } return app } func startupBanner(banner io.Writer) { CopyrightYear = strconv.Itoa(time.Now().Year()) fmt.Fprintln(banner, color.Blue("Copyright:")+color.Bold(" 2015-%s MinIO, Inc.", CopyrightYear)) fmt.Fprintln(banner, color.Blue("License:")+color.Bold(" "+MinioLicense))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 6.4K bytes - Viewed (0)