- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 90 for pipe1 (0.06 sec)
-
pkg/bootstrap/testdata/tracing_opencensusagent_golden.json
"load_assignment": { "cluster_name": "sds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{ "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } } } }] }] } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 12.7K bytes - Viewed (0) -
docs/bucket/replication/test_del_marker_proxying.sh
# Run the test to make sure proxying of DEL marker doesn't happen loop_count=0 while true; do if [ $loop_count -eq 100 ]; then break fi echo "Hello World" | ./mc pipe sitea/bucket/obj$loop_count ./mc rm sitea/bucket/obj$loop_count RESULT=$({ ./mc stat sitea/bucket/obj$loop_count; } 2>&1) if [[ ${RESULT} != *"Object does not exist"* ]]; then echo "BUG: stat should fail. succeeded."
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 11:38:26 UTC 2024 - 1.8K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_benchmark_test.go
go func() { for { rb.Write(data) } }() b.ResetTimer() for i := 0; i < b.N; i++ { rb.Read(buf) } } func BenchmarkIoPipeReader(b *testing.B) { pr, pw := io.Pipe() data := []byte(strings.Repeat("a", 512)) buf := make([]byte, 512) go func() { for { pw.Write(data) } }() b.ResetTimer() for i := 0; i < b.N; i++ { pr.Read(buf) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 1.7K bytes - Viewed (0) -
src/cmd/trace/testdata/testprog/main.go
} // blockingSyscall blocks the current goroutine for duration d in a syscall and // sends a message to done when it is done or if the syscall failed. func blockingSyscall(d time.Duration, done chan<- error) { r, w, err := os.Pipe() if err != nil { done <- err return } start := time.Now() msg := []byte("hello") time.AfterFunc(d, func() { w.Write(msg) }) _, err = syscall.Read(int(r.Fd()), make([]byte, len(msg)))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/bootstrap/testdata/deferred_cluster_creation_golden.json
"load_assignment": { "cluster_name": "sds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{ "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } } } }] }] } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/volume/util/util_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.7K bytes - Viewed (0) -
src/internal/trace/trace_test.go
}) } func TestTraceStress(t *testing.T) { switch runtime.GOOS { case "js", "wasip1": t.Skip("no os.Pipe on " + runtime.GOOS) } testTraceProg(t, "stress.go", nil) } func TestTraceStressStartStop(t *testing.T) { switch runtime.GOOS { case "js", "wasip1": t.Skip("no os.Pipe on " + runtime.GOOS) } testTraceProg(t, "stress-start-stop.go", nil) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
src/syscall/syscall_darwin.go
func PtraceDetach(pid int) (err error) { return ptrace(PT_DETACH, pid, 0, 0) } //sysnb pipe(p *[2]int32) (err error) func Pipe(p []int) (err error) { if len(p) != 2 { return EINVAL } var q [2]int32 err = pipe(&q) if err == nil { p[0] = int(q[0]) p[1] = int(q[1]) } return } func Getfsstat(buf []Statfs_t, flags int) (n int, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 11K bytes - Viewed (0) -
tools/packaging/common/envoy_bootstrap.json
"load_assignment": { "cluster_name": "sds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{ "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } } } }] }] } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 22.6K bytes - Viewed (0) -
src/syscall/syscall_linux.go
return openat(dirfd, path, flags|O_LARGEFILE, mode) } func Pipe(p []int) error { return Pipe2(p, 0) } //sysnb pipe2(p *[2]_C_int, flags int) (err error) func Pipe2(p []int, flags int) error { if len(p) != 2 { return EINVAL } var pp [2]_C_int err := pipe2(&pp, flags) if err == nil { p[0] = int(pp[0]) p[1] = int(pp[1]) } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:12:46 UTC 2024 - 35.7K bytes - Viewed (0)