- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,171 for init (0.2 sec)
-
tensorflow/c/eager/c_api.cc
TF_CAPI_EXPORT extern void TFE_ContextSetServerDefWithTimeout( TFE_Context* ctx, int keep_alive_secs, const void* proto, size_t proto_len, int64_t init_timeout_in_ms, TF_Status* status, bool clear_existing_contexts) { TFE_ContextSetServerDefWithTimeoutAndRetries( ctx, keep_alive_secs, proto, proto_len, init_timeout_in_ms, /*retries=*/0, status, clear_existing_contexts); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Mar 12 20:00:09 GMT 2024 - 43.9K bytes - Viewed (2) -
cni/pkg/plugin/plugin_test.go
eventURL, ambientEnabled, "mock", ) } func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) { proxy := corev1.Container{Name: "mockContainer"} app := corev1.Container{Name: "foo-init"} fakePod := &corev1.Pod{ TypeMeta: metav1.TypeMeta{ APIVersion: "core/v1", Kind: "Pod", }, ObjectMeta: metav1.ObjectMeta{ Name: testPodName, Namespace: testNSName,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
// This is not actually a problem, since the foreach only needs this.futures to be non-null // at the beginning of the loop. int i = 0; for (ListenableFuture<? extends InputT> future : futures) { int index = i++; future.addListener( () -> { try { if (future.isCancelled()) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
// which will eventually replace the current target. func (h *Target) AssignMigrateTarget(migrateTgt *Target) { h.migrateTarget = migrateTgt } // Init validate and initialize the http target func (h *Target) Init(ctx context.Context) (err error) { if h.config.QueueDir != "" { return h.initQueueOnce.DoWithContext(ctx, h.initDiskStore) } return h.initQueueOnce.DoWithContext(ctx, h.initMemoryStore)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_test.cc
// Create two contexts. int32_t init_timeout_in_ms = 300000; TFE_Context* ctx_0 = CreateContext(serialized_server_def_0, /*isolate_session_state=*/false, init_timeout_in_ms); TFE_Context* ctx_1 = CreateContext(serialized_server_def_1, /*isolate_session_state=*/false, init_timeout_in_ms); // Remote device on `worker2`.
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 03:14:26 GMT 2023 - 31.5K bytes - Viewed (1) -
cmd/bucket-lifecycle.go
// transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return } t.updateWorkers(n) } func (t *transitionState) updateWorkers(n int) { for t.numWorkers < n { go t.worker(t.objAPI) t.numWorkers++ } for t.numWorkers > n {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
apache-maven/pom.xml
<exclude>src/assembly/maven/bin/m2.conf</exclude> <!-- these are partial scripts, resulting in mvn scripts --> <exclude>src/assembly/shared/init</exclude> <exclude>src/assembly/shared/init.cmd</exclude> <exclude>src/assembly/shared/mvnlauncher</exclude> <exclude>src/assembly/shared/mvnlauncher.cmd</exclude>
XML - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 08:48:58 GMT 2024 - 10.9K bytes - Viewed (0) -
cmd/iam-etcd-store.go
time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil { iamLogIf(ctx, err) // log and retry. time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } for _, event := range watchResp.Events {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
src/cmd/asm/internal/asm/endtoend_test.go
} } func Test386EndToEnd(t *testing.T) { testEndToEnd(t, "386", "386") } func TestARMEndToEnd(t *testing.T) { defer func(old int) { buildcfg.GOARM.Version = old }(buildcfg.GOARM.Version) for _, goarm := range []int{5, 6, 7} { t.Logf("GOARM=%d", goarm) buildcfg.GOARM.Version = goarm testEndToEnd(t, "arm", "arm") if goarm == 6 { testEndToEnd(t, "arm", "armv6") } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Dec 07 18:42:59 GMT 2023 - 11.6K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
"istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" ) type revisionCount struct { // pods in a revision pods int // pods that are disabled from injection disabled int // pods that are enabled for injection, but whose revision doesn't match their namespace's revision needsRestart int } func Cmd(cliContext cli.Context) *cobra.Command { cmd := &cobra.Command{ Use: "injector",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0)