Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 373 for attempt (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top