- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for writerPCs (0.34 sec)
-
cmd/erasure-encode.go
} // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{ writers: writers, writeQuorum: quorum, errs: make([]error, len(writers)), } for { var blocks [][]byte
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
src/io/multi.go
// provided writers, similar to the Unix tee(1) command. // // Each write is written to each listed writer, one at a time. // If a listed writer returns an error, that overall write operation // stops and returns the error; it does not continue down the list. func MultiWriter(writers ...Writer) Writer { allWriters := make([]Writer, 0, len(writers)) for _, w := range writers {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 19 15:49:05 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/channels/unbounded_test.go
wg.Wait() if !reflect.DeepEqual(reads, wantReads) { t.Errorf("reads: %#v, wantReads: %#v", reads, wantReads) } } // TestMultipleWriters starts multiple writers and one reader goroutine and // makes sure that the reader gets all the data written by all writers. func TestMultipleWriters(t *testing.T) { ub := NewUnbounded[int]() reads := []int{} var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 31 19:53:39 UTC 2022 - 2.3K bytes - Viewed (0) -
cmd/erasure-heal_test.go
writers := make([]io.Writer, len(disks)) for i, disk := range disks { writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize()) } _, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1) closeBitrotWriters(writers) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.9K bytes - Viewed (0) -
maven-toolchain-model/src/site/apt/index.apt
The following are generated from this model: * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package for Merger and v4 Reader and Writers for the Xpp3 XML parser, * A {{{./toolchains.html}Descriptor Reference}}
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jan 03 21:08:35 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/erasure-decode.go
} return bytesWritten, derr } // Heal reads from readers, reconstruct shards and writes the data to the writers. func (e Erasure) Heal(ctx context.Context, writers []io.Writer, readers []io.ReaderAt, totalLength int64, prefer []bool) (derr error) { if len(writers) != e.parityBlocks+e.dataBlocks { return errInvalidArgument } reader := newParallelReader(readers, e, 0, totalLength)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
maven-model/src/site/apt/index.apt
The following are generated from this model: * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package for Merger and v4 Reader and Writers for the Xpp3 XML parser, * A {{{./maven.html}Descriptor Reference}}
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jan 03 21:08:35 UTC 2023 - 1.7K bytes - Viewed (0) -
src/sync/rwmutex.go
// // [the Go memory model]: https://go.dev/ref/mem type RWMutex struct { w Mutex // held if there are pending writers writerSem uint32 // semaphore for writers to wait for completing readers readerSem uint32 // semaphore for readers to wait for completing writers readerCount atomic.Int32 // number of pending readers readerWait atomic.Int32 // number of departing readers }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/sync/atomic/example_test.go
m.Store(make(Map)) var mu sync.Mutex // used only by writers // read function can be used to read the data without further synchronization read := func(key string) (val string) { m1 := m.Load().(Map) return m1[key] } // insert function can be used to update the data without further synchronization insert := func(key, val string) { mu.Lock() // synchronize with other potential writers defer mu.Unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 18 23:58:54 UTC 2018 - 2.2K bytes - Viewed (0) -
maven-settings/src/site/apt/index.apt
The following are generated from this model: * {{{./apidocs/index.html}Java sources}} with Reader and Writers for the Xpp3 XML parser, <<<ToAPiV3()>>> and <<<ToApiV4()>>> transformers, and <<<v4>>> package for Merger and v4 Reader and Writers for the Xpp3 XML parser, * A {{{./settings.html}Descriptor Reference}} * An {{{https://maven.apache.org/xsd/settings-1.2.0.xsd}XSD}}
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Feb 17 18:40:11 UTC 2024 - 2K bytes - Viewed (0)