- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 373 for attempt (0.14 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
makeSimpleCall() } /** * If the server returns a full response, it doesn't really matter if the HTTP/2 stream is reset. * Attempts to write the request body fails fast. */ @Test fun serverTruncatesRequestHttp2OnDuplexRequest() { enableProtocol(Protocol.HTTP_2) server.enqueue( MockResponse .Builder()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 9.4K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
@Override public long skip(long n) throws IOException { n = min(n, left); long skipped = in.skip(n); left -= skipped; return skipped; } } /** * Attempts to read enough bytes from the stream to fill the given byte array, with the same * behavior as {@link DataInput#readFully(byte[])}. Does not close the stream. * * @param in the input stream to read from.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
- Sometimes, the scheduler incorrectly placed a pod in the "unschedulable" queue instead of the "backoff" queue. This happened when some plugin previously declared the pod as "unschedulable" and then in a later attempt encounters some other error. Scheduling of that pod then got delayed by up to five minutes, after which periodic flushing moved the pod back into the "active" queue. ([#120334](https://github.com/kubernetes/kubernetes/pull/120334), [@pohly](https...
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Jul 17 07:48:22 UTC 2024 - 466.3K bytes - Viewed (2) -
android/guava/src/com/google/common/io/TempFileCreator.java
return tempDir; } } throw new IllegalStateException( "Failed to create directory within " + TEMP_DIR_ATTEMPTS + " attempts (tried " + baseName + "0 to " + baseName + (TEMP_DIR_ATTEMPTS - 1) + ')'); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/TreeMultiset.java
* {@code ClassCastException} for any elements {@code e1} and {@code e2} in the multiset. If the * user attempts to add an element to the multiset that violates this constraint (for example, the * user attempts to add a string element to a set whose elements are integers), the {@code * add(Object)} call will throw a {@code ClassCastException}. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.8K bytes - Viewed (0) -
cmd/local-locker.go
} defer l.getMutex()() for _, resource := range args.Resources { lri, ok := l.lockMap[resource] if ok && !isWriteLock(lri) { // Unless it is a write lock reject it. err = fmt.Errorf("unlock attempted on a read locked entity: %s", resource) continue } if ok { reply = l.removeEntry(resource, args, &lri) || reply } } return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
*/ ServiceManagerState(ImmutableCollection<Service> services) { this.numberOfServices = services.size(); servicesByState.putAll(NEW, services); } /** * Attempts to start the timer immediately prior to the service being started via {@link * Service#startAsync()}. */ void tryStartTiming(Service service) { monitor.enter(); try {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/util/ResourceUtil.java
} return getPath("WEB-INF/", "conf", names); } /** * Gets the path to configuration files, falling back to classpath resources if not found. * First attempts to find the file in the configuration directory, then searches the classpath. * * @param names the path components to append to the configuration directory
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 14.1K bytes - Viewed (0) -
docs/bucket/versioning/README.md
Duplicate delete markers are not created on MinIO buckets with versioning, if an application performs a soft delete on an object repeatedly - that object will only ever have a single DELETE marker for all such successive attempts. This is done to ensure that repeated soft deletes do not ever need multiple versions in the first place. > NOTE: Server side replication is supported for idempotent versions on delete marked objects. ### Motivation
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 12K bytes - Viewed (0) -
src/main/java/jcifs/util/SimpleCircuitBreaker.java
if (state.compareAndSet(State.HALF_OPEN, State.CLOSED)) { stateChangeTime.set(System.currentTimeMillis()); log.info("Circuit breaker {} closed after {} successful attempts", name, successes); } } } } /** * Handle failed call */ private void onFailure() { totalFailures.incrementAndGet();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 11.3K bytes - Viewed (0)