- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 4,460 for until (0.04 sec)
-
internal/http/listener.go
select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
tensorflow/c/eager/abstract_operation.h
// logic to refer to the specific device chosen. // // Example: If one calls `op->SetDeviceName("/device:GPU")`, the value // returned by DeviceName should be "/device:GPU:*" until a particular GPU is // chosen for the operation by the device placement logic in the // executor. After that, the value returned by DeviceName will be a full // device name such as "/job:localhost/replica:0/task:0/device:GPU:1".
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 7.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/url/-Url.kt
unicodeAllowed = unicodeAllowed, ) } internal fun String.percentDecode( pos: Int = 0, limit: Int = length, plusIsSpace: Boolean = false, ): String { for (i in pos until limit) { val c = this[i] if (c == '%' || c == '+' && plusIsSpace) { // Slow path: the character at i requires decoding! val out = Buffer() out.writeUtf8(this, pos, i)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 09 12:33:05 UTC 2024 - 7.3K bytes - Viewed (0) -
manifests/charts/UPDATING-CHARTS.md
``` ### Step 5. Create a PR using outputs from Steps 1 to 4 Your PR should pass all the checks if you followed these steps. ## Value deprecation - Values may be marked as deprecated, but may not be removed until a minimum of 2 releases after the PR marking them as such is merged.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 16:31:46 UTC 2024 - 4.8K bytes - Viewed (0) -
.github/DISCUSSION_TEMPLATE/questions.yml
required: true - type: checkboxes id: help attributes: label: Commit to Help description: | After submitting this, I commit to one of: * Read open questions until I find 2 where I can help someone and add a comment to help there. * I already hit the "watch" button in this repository to receive notifications and I commit to help at least 2 people that ask questions in the future.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Aug 03 15:59:41 UTC 2023 - 5.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/RepositorySystem.java
import org.apache.maven.settings.Server; import org.eclipse.aether.RepositorySystemSession; /** * @since 3.0-alpha * @deprecated Use {@link MavenRepositorySystem} if needed, or maven-resolver directly, until maven 4.x api is out */ @Deprecated public interface RepositorySystem { String DEFAULT_LOCAL_REPO_ID = MavenRepositorySystem.DEFAULT_LOCAL_REPO_ID; @SuppressWarnings("checkstyle:constantname")
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
// If the URI lacks a host (as in "http://</"), don't call the ProxySelector. val uri = url.toUri() if (uri.host == null) return immutableListOf(Proxy.NO_PROXY) // Try each of the ProxySelector choices until one connection succeeds. val proxiesOrNull = address.proxySelector.select(uri) if (proxiesOrNull.isNullOrEmpty()) return immutableListOf(Proxy.NO_PROXY) return proxiesOrNull.toImmutableList() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 7.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.collect.Sets.newConcurrentHashSet; import static java.util.Objects.requireNonNull; import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater; import static java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater; import com.google.common.annotations.GwtCompatible;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Interpolator.java
* under the License. */ package org.apache.maven.api.services; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.function.BiFunction; import java.util.function.Function; import org.apache.maven.api.Service; import org.apache.maven.api.annotations.Experimental;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Oct 17 09:25:53 UTC 2024 - 6.9K bytes - Viewed (0) -
helm-releases/minio-5.0.4.tgz
+e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 23 20:29:40 UTC 2022 - 20.3K bytes - Viewed (0)