- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 425 for load (0.18 sec)
-
internal/grid/connection.go
if v, ok := c.outgoing.Load(m.MuxID); ok { var cErr muxConnectError _, err := cErr.UnmarshalMsg(m.Payload) gridLogIf(ctx, err) v.error(RemoteErr(cErr.Error)) return } PutByteBuffer(m.Payload) } func (c *Connection) handleAckMux(ctx context.Context, m message) { PutByteBuffer(m.Payload) v, ok := c.outgoing.Load(m.MuxID) if !ok { if m.Flags&FlagEOF == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/RelatedQueryHelper.java
@PostConstruct public void init() { if (logger.isDebugEnabled()) { logger.debug("Initialize {}", this.getClass().getSimpleName()); } load(); } public List<RelatedQuery> getAvailableRelatedQueryList() { return ComponentUtil.getComponent(RelatedQueryBhv.class).selectList(cb -> { cb.query().matchAll();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.2K bytes - Viewed (0) -
manifests/addons/dashboards/istio-extension-dashboard.json
}, "expr": "avg(envoy_wasm_remote_load_cache_hits)", "interval": "", "legendFormat": "hits", "refId": "A" }, { "datasource": { "type": "prometheus", "uid": "${datasource}" }, "expr": "avg(envoy_wasm_remote_load_cache_misses)", "interval": "",
Json - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 03:47:04 GMT 2024 - 20K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
b.ResetTimer() b.SetBytes(855) // number of versions... for i := 0; i < b.N; i++ { err = xl.Load(data) if err != nil { b.Fatal(err) } } }) } func Test_xlMetaV2Shallow_Load(t *testing.T) { // Load Legacy data, err := os.ReadFile("testdata/xl.meta-v1.2.zst") if err != nil { t.Fatal(err) } dec, _ := zstd.NewReader(nil) data, err = dec.DecodeAll(data, nil)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
cni/pkg/install/install_test.go
err := in.sleepWatchInstall(ctx, sets.String{}) if err != nil { t.Fatalf("error should be nil due to invalid config, got: %v", err) } assert.Equal(t, isReady.Load(), false) if len(c.invalidConfigFilename) > 0 { if err := os.Remove(cniConfigFilepath); err != nil { t.Fatal(err) } } // Copy a valid config file into tempDir
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/BUILD
# Experimental filesystem C APIs for TensorFlow. # Will be moved in proper place once all filesystems are converted to the # modular framework. load("//tensorflow:tensorflow.bzl", "tf_cc_test") load("//tensorflow/core/platform:rules_cc.bzl", "cc_library") package( # copybara:uncomment default_applicable_licenses = ["//tensorflow:license"], licenses = ["notice"], ) # This is only for plugins cc_library( name = "filesystem_interface",
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 2.1K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// there were no available workers. func (e *expiryStats) MissedTasks() int64 { return e.missedExpiryTasks.Load() } // MissedFreeVersTasks returns the number of free version collection tasks that // were missed since there were no available workers. func (e *expiryStats) MissedFreeVersTasks() int64 { return e.missedFreeVersTasks.Load() } // MissedTierJournalTasks returns the number of tasks to remove tiered objects
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) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirMetadataCalculator.kt
import org.jetbrains.kotlin.fir.symbols.lazyResolveToPhase import org.jetbrains.kotlin.fir.types.typeApproximator import org.jetbrains.kotlin.load.java.JvmAbi import org.jetbrains.kotlin.load.kotlin.NON_EXISTENT_CLASS_NAME import org.jetbrains.kotlin.load.kotlin.header.KotlinClassHeader import org.jetbrains.kotlin.metadata.jvm.deserialization.JvmProtoBufUtil import org.jetbrains.kotlin.metadata.jvm.serialization.JvmStringTable
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Tue Mar 26 09:19:07 GMT 2024 - 10K bytes - Viewed (0) -
schema/schema.go
var schemaCacheKey interface{} if specialTableName != "" { schemaCacheKey = fmt.Sprintf("%p-%s", modelType, specialTableName) } else { schemaCacheKey = modelType } // Load exist schema cache, return if exists if v, ok := cacheStore.Load(schemaCacheKey); ok { s := v.(*Schema) // Wait for the initialization of other goroutines to complete <-s.initialized return s, s.err }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Oct 10 06:50:29 GMT 2023 - 13.7K bytes - Viewed (0) -
cmd/config-current.go
return readServerConfig(GlobalContext, objAPI, nil) } // loadConfig - loads a new config from disk, overrides params // from env if found and valid // data is optional. If nil it will be loaded from backend. func loadConfig(objAPI ObjectLayer, data []byte) error { bootstrapTraceMsg("load the configuration") srvCfg, err := readServerConfig(GlobalContext, objAPI, data) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0)