- Sort Score
- Num 10 results
- Language All
Results 1001 - 1010 of 1,200 for Ensure (0.04 seconds)
-
cmd/storage-datatypes.go
// Make sure to bump the internode version at storage-rest-common.go type RawFileInfo struct { // Content of entire xl.meta (may contain data depending on what was requested by the caller. Buf []byte `msg:"b,allownil"` } // FileInfo - represents file stat information. // The above means that any added/deleted fields are incompatible. // Make sure to bump the internode version at storage-rest-common.goCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/RegularContiguousSet.java
if (this.domain.equals(that.domain)) { return this.first().equals(that.first()) && this.last().equals(that.last()); } } return super.equals(object); } // copied to make sure not to use the GWT-emulated version @Override public int hashCode() { return Sets.hashCodeImpl(this); } @GwtIncompatible @J2ktIncompatible
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 8.3K bytes - Click Count (0) -
compat/maven-compat/src/test/java/org/apache/maven/repository/LegacyRepositorySystemTest.java
result = repositorySystem.resolve(request); resolutionErrorHandler.throwErrors(request, result); assertEquals(1, result.getArtifacts().size()); // // Put in a bogus file to make sure missing files cause the resolution to fail. // file = new File(getBasedir(), "src/test/repository-system/maven-monkey-2.1.0.jar");
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Dec 16 13:41:14 GMT 2025 - 11.1K bytes - Click Count (0) -
cmd/speedtest.go
// complete in total time of 10s. if globalEndpoints.NEndpoints() < concurrency { concurrency = globalEndpoints.NEndpoints() } // Check if we have local disks per pool less than // the concurrency make sure we choose only the "start" // concurrency to be equal to the lowest number of // local disks per server. for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() { if localDiskCount < concurrency {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.2K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/ErrorReportingTestListener.java
// be explicitly safe here to avoid interleaving output from multiple test suites synchronized (this) { // make sure we've flushed everything to disk before reading eventWriter.flush(); System.err.println("\n\nSuite: " + suite);Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 10.7K bytes - Click Count (0) -
docs/en/docs/deployment/manually.md
When you install FastAPI, it comes with a production server, Uvicorn, and you can start it with the `fastapi run` command. But you can also install an ASGI server manually. Make sure you create a [virtual environment](../virtual-environments.md), activate it, and then you can install the server application. For example, to install Uvicorn: <div class="termy"> ```console
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 6.7K bytes - Click Count (0) -
internal/event/target/mqtt.go
return nil } func (target *MQTTTarget) init() error { return target.initOnce.Do(target.initMQTT) } func (target *MQTTTarget) initMQTT() error { args := target.args // Using hex here, to make sure we avoid 23 // character limit on client_id according to // MQTT spec. clientID := fmt.Sprintf("%x", time.Now().UnixNano()) options := mqtt.NewClientOptions(). SetClientID(clientID).
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
android/guava/src/com/google/common/base/internal/Finalizer.java
* finalizable references could be enqueued subsequently (at which point the class loader * would be resurrected by virtue of us having a strong reference to it), we should pretty * much just shut down and make sure we don't keep it alive any longer than necessary. */ return null; } try { return finalizableReferenceClass.getMethod("finalizeReferent"); } catch (NoSuchMethodException e) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
blocker.setOwner(Thread.currentThread()); if (compareAndSet(currentRunner, blocker)) { // Thread.interrupt can throw arbitrary exceptions due to the nio InterruptibleChannel API // This will make sure that tasks don't get stuck busy waiting. // Some of this is fixed in jdk11 (see https://bugs.openjdk.org/browse/JDK-8198692) but // not all. See the test cases for examples on how this can happen. try {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
docs/tr/docs/advanced/advanced-dependencies.md
Amaç, response'un ağ üzerinden taşınmasını beklerken gereğinden uzun süre resource tutmaktan kaçınmaktı. Bu değişiklik aynı zamanda şunu da ifade ediyordu: `StreamingResponse` döndürürseniz, `yield` kullanan dependency'nin çıkış kodu zaten çalışmış olurdu.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 07:53:17 GMT 2026 - 10K bytes - Click Count (0)