- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newCoordinator (0.1 sec)
-
src/internal/fuzz/worker_test.go
// RPC messages until it's stopped. The process is stopped and cleaned up // automatically when the test is done. func newWorkerForTest(tb testing.TB) *worker { tb.Helper() c, err := newCoordinator(CoordinateFuzzingOpts{ Types: []reflect.Type{reflect.TypeOf([]byte(nil))}, Log: io.Discard, }) if err != nil { tb.Fatal(err) } dir := "" // same as self
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 4.8K bytes - Viewed (0) -
src/internal/fuzz/fuzz.go
opts.Parallel = runtime.GOMAXPROCS(0) } if opts.Limit > 0 && int64(opts.Parallel) > opts.Limit { // Don't start more workers than we need. opts.Parallel = int(opts.Limit) } c, err := newCoordinator(opts) if err != nil { return err } if opts.Timeout > 0 { var cancel func() ctx, cancel = context.WithTimeout(ctx, opts.Timeout) defer cancel() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 34.1K bytes - Viewed (0)