- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 687 for isInitialized (0.45 sec)
-
pkg/proxy/iptables/proxier.go
proxier.syncRunner.Loop(wait.NeverStop) } func (proxier *Proxier) setInitialized(value bool) { var initialized int32 if value { initialized = 1 } atomic.StoreInt32(&proxier.initialized, initialized) } func (proxier *Proxier) isInitialized() bool { return atomic.LoadInt32(&proxier.initialized) > 0 } // OnServiceAdd is called whenever creation of new service object // is observed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
readCompleteLatch.await() } catch (_: InterruptedException) { Thread.currentThread().interrupt() // Retain interrupted status. } } check(::publicSuffixListBytes.isInitialized) { // May have failed with an IOException "Unable to load $PUBLIC_SUFFIX_RESOURCE resource from the classpath." }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
proxier.syncRunner.Loop(wait.NeverStop) } func (proxier *Proxier) setInitialized(value bool) { var initialized int32 if value { initialized = 1 } atomic.StoreInt32(&proxier.initialized, initialized) } func (proxier *Proxier) isInitialized() bool { return atomic.LoadInt32(&proxier.initialized) > 0 } // OnServiceAdd is called whenever creation of new service object is observed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
analysis/analysis-api-impl-base/tests/org/jetbrains/kotlin/analysis/api/impl/base/test/cases/components/compilerFacility/AbstractCompilerFacilityTest.kt
val functionsWithAnnotationToCheckCalls: MutableSet<String> = mutableSetOf() override fun generate(moduleFragment: IrModuleFragment, pluginContext: IrPluginContext) { assertFalse { ::result.isInitialized } val dumpOptions = DumpIrTreeOptions( normalizeNames = true, stableOrder = true, printModuleName = false, printFilePath = false )
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:34 UTC 2024 - 13.8K bytes - Viewed (0) -
tensorflow/c/experimental/next_pluggable_device/c_api.cc
} bool TF_CoordinationServiceIsInitialized(TF_CoordinationServiceAgent* agent) { if (agent == nullptr) return false; auto* cc_agent = reinterpret_cast<tsl::CoordinationServiceAgent*>(agent); return cc_agent->IsInitialized(); } void TF_CoordinationServiceInsertKeyValue(const char* key, int64_t key_size, const char* value, int64_t value_size,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 22 05:48:24 UTC 2024 - 13.9K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/DefaultConfigurationCache.kt
stoppable.add(store) stoppable.stop() } private fun CompositeStoppable.addIfInitialized(closeable: Lazy<*>) { if (closeable.isInitialized()) { add(closeable.value) } } private fun checkFingerprint(): CheckedFingerprint { return store.useForStateLoad { layout ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 24.3K bytes - Viewed (0) -
tensorflow/c/c_api.cc
} if (!result.ok()) { status->status = result; return; } // Store results in c_outputs[] for (int i = 0; i < noutputs; ++i) { const Tensor& src = outputs[i]; if (!src.IsInitialized() || src.NumElements() == 0) { c_outputs[i] = EmptyTensor(static_cast<TF_DataType>(src.dtype()), src.shape()); continue; } c_outputs[i] = TF_TensorFromTensor(src, &status->status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Apr 15 03:35:10 UTC 2024 - 102.3K bytes - Viewed (0) -
src/cmd/cgo/internal/testshared/testdata/depBase/dep.go
"os" "reflect" "testshared/depBaseInternal" ) // Issue 61973: indirect dependencies are not initialized. func init() { if !depBaseInternal.Initialized { panic("depBaseInternal not initialized") } if os.Stdout == nil { panic("os.Stdout is nil") } Initialized = true } var Initialized bool var SlicePtr interface{} = &[]int{} var V int = 1 var HasMask []string = []string{"hi"}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 14:52:41 UTC 2024 - 1K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util_test.cc
CreateContext(); std::vector<XlaCompiler::Argument> args(2); args[0].kind = XlaCompiler::Argument::kParameter; args[0].initialized = true; args[0].type = DT_INT32; args[0].shape = TensorShape({1, 2}); args[1].kind = XlaCompiler::Argument::kParameter; args[1].initialized = true; args[1].type = DT_INT32; args[1].shape = TensorShape({1, 2}); const XlaCompiler::CompilationResult* result;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 28.8K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/NativeServicesIntegrationTest.groovy
then: nativeDir.exists() == initialized where: // Works for all cases except -D$NATIVE_SERVICES_OPTION=false description | systemProperties | initialized "initialized" | ["-D$NATIVE_SERVICES_OPTION=true"] | true "not initialized" | ["-D$NATIVE_SERVICES_OPTION=false"] | true // Should be false "initialized" | ["-D$NATIVE_SERVICES_OPTION=''"] | true
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 05:18:22 UTC 2024 - 10.9K bytes - Viewed (0)