- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for Pipe (0.15 sec)
-
internal/ioutil/wait_pipe.go
err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide // synchronization between read() end with write() end. func WaitPipe() (*PipeReader, *PipeWriter) { r, w := io.Pipe() var wg sync.WaitGroup wg.Add(1) return &PipeReader{ PipeReader: r, wait: wg.Wait, }, &PipeWriter{ PipeWriter: w,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 27 14:55:36 GMT 2023 - 1.7K bytes - Viewed (0) -
buildscripts/verify-healing.sh
/tmp/mc alias set myminio http://127.0.0.1:$((start_port + 1)) minio minio123 --api=s3v4 /tmp/mc ready myminio /tmp/mc mb myminio/testbucket/ for ((i = 0; i < 20; i++)); do echo "my content" | /tmp/mc pipe myminio/testbucket/file-$i done } function perform_test() { start_port=$2 start_minio_3_node 120 $start_port echo "Testing Distributed Erasure setup healing of drives"
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
cmd/bitrot-streaming.go
// Race condition is because of io.PipeWriter implementation. i.e consider the following // sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/bucket/versioning/versioning-tests.sh
./mc mb sitea/delissue --insecure ./mc version enable sitea/delissue --insecure echo hello | ./mc pipe sitea/delissue/hello --insecure ./mc version suspend sitea/delissue --insecure ./mc rm sitea/delissue/hello --insecure ./mc version enable sitea/delissue --insecure echo hello | ./mc pipe sitea/delissue/hello --insecure ./mc version suspend sitea/delissue --insecure
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 09:50:52 GMT 2024 - 2.4K bytes - Viewed (0)