- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 63 for Parallel (0.47 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
EnableGarbageCollection bool // DeleteCollectionWorkers is the maximum number of workers in a single // DeleteCollection call. Delete requests for the items in a collection // are issued in parallel. DeleteCollectionWorkers int // Decorator is an optional exit hook on an object returned from the // underlying storage. The returned object could be an individual object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
cmd/test-utils_test.go
globalInternodeTransport = NewInternodeHTTPTransport(0)() initHelp() resetTestGlobals() globalIsCICD = true os.Exit(m.Run()) } // concurrency level for certain parallel tests. const testConcurrencyLevel = 10 const iso8601TimeFormat = "2006-01-02T15:04:05.000Z" // Excerpts from @lsegal - https://github.com/aws/aws-sdk-js/issues/659#issuecomment-120477258 // // User-Agent:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
okhttp/api/okhttp.api
public static final field DIGEST Lokhttp3/MediaType; public static final field FORM Lokhttp3/MediaType; public static final field MIXED Lokhttp3/MediaType; public static final field PARALLEL Lokhttp3/MediaType; public final fun -deprecated_boundary ()Ljava/lang/String; public final fun -deprecated_parts ()Ljava/util/List; public final fun -deprecated_size ()I
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0) -
tests/integration/ambient/baseline_test.go
f(t, src, dst, opt) }) } }) } }) } } for _, c := range testCases { // Create a copy to avoid races, as tests are run in parallel c := c testName := strings.TrimSuffix(c.ConfigFile, filepath.Ext(c.ConfigFile)) t.NewSubTest(testName).Run(func(t framework.TestContext) { // Apply the policy.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 78.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
src/net/dnsclient_unix_test.go
t.Errorf("txt[1], got %q, want %q", txt[1], want) } } // Issue 29644: support single-request resolv.conf option in pure Go resolver. // The A and AAAA queries will be sent sequentially, not in parallel. func TestSingleRequestLookup(t *testing.T) { defer dnsWaitGroup.Wait() var ( firstcalled int32 ipv4 int32 = 1 ipv6 int32 = 2 )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 72.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// creating two multiparts uploads in two different pools if len(result.Uploads) != 0 { return z.serverPools[idx].NewMultipartUpload(ctx, bucket, object, opts) } } // any parallel writes on the object will block for this poolIdx // to return since this holds a read lock on the namespace. idx, err := z.getPoolIdx(ctx, bucket, object, -1) if err != nil { return nil, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/Sets.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 78.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_pipelining.cc
more ops on the SparseCore. Ops are broken up into: 1. SC forward pass 2. TC forward/backward pass 3. SC backward pass 4. non-TPU loop counter updates These 4 functions are then staggered so as to enable parallel execution. In pseudocode, the algorithm is as follows: // Start step 0 C_0 = cond(args_0) N_0 = non_tpu(args_0) if (C_0) { F_0 = forward(args_0, N_0) T_0 = core_tpu(args_0, N_0, F_0)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 92.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/rewrite.go
// and we want the concatenation of all of those logs. // This means, of course, that users need to rm the old log // to get fresh data. // TODO: all.bash runs compilers in parallel. Need to synchronize logging somehow? w, err := os.OpenFile(filepath.Join(os.Getenv("GOROOT"), "src", "rulelog"), os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666) if err != nil { panic(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:02:52 UTC 2024 - 64.2K bytes - Viewed (0)