- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 1,644 for _all (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/metacache-entries.go
xl, err := entry.xlmeta() if err != nil { continue } objsValid++ // Add all valid to candidates. r.candidates = append(r.candidates, xl.versions) // We select the first object we find as a candidate and see if all match that. // This is to quickly identify if all agree. if selected == nil { selected = entry objsAgree = 1 continue }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 08 15:29:58 GMT 2024 - 24.1K bytes - Click Count (0) -
cmd/notification.go
} // ServiceFreeze freezes all S3 API calls when 'freeze' is true, // 'freeze' is 'false' would resume all S3 API calls again. // NOTE: once a tenant is frozen either two things needs to // happen before resuming normal operations. // - Server needs to be restarted 'mc admin service restart' // - 'freeze' should be set to 'false' for this call // to resume normal operations.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/AbstractMultimap.java
} @CanIgnoreReturnValue @Override public boolean putAll(@ParametricNullness K key, Iterable<? extends V> values) { checkNotNull(values); // make sure we only call values.iterator() once // and we only call get(key) if values is nonempty if (values instanceof Collection) { Collection<? extends V> valueCollection = (Collection<? extends V>) values;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 6.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
* until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read. * * Typical use loops over the parts in sequence: * * ```kotlin * val response: Response = call.execute() * val multipartReader = MultipartReader(response.body!!) * * multipartReader.use { * while (true) { * val part = multipartReader.nextPart() ?: break * process(part.headers, part.body) * }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 7.3K bytes - Click Count (0) -
android/guava/src/com/google/common/base/NullnessCasts.java
* types (or if the type is a non-variable type, like {@code String}), then code should almost * never use this method, preferring instead to call {@code requireNonNull} so as to benefit from * its runtime check. * * <p>An example use case for this method is in implementing an {@code Iterator<T>} whose {@code
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Aug 13 20:49:47 GMT 2025 - 3.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Callables.java
checkNotNull(callable); checkNotNull(listeningExecutorService); return () -> listeningExecutorService.submit(callable); } /** * Wraps the given callable such that for the duration of {@link Callable#call} the thread that is * running will have the given name. * * @param callable The callable to wrap * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 4.3K bytes - Click Count (0) -
guava/src/com/google/common/base/NullnessCasts.java
* types (or if the type is a non-variable type, like {@code String}), then code should almost * never use this method, preferring instead to call {@code requireNonNull} so as to benefit from * its runtime check. * * <p>An example use case for this method is in implementing an {@code Iterator<T>} whose {@code
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Aug 13 20:49:47 GMT 2025 - 3.3K bytes - Click Count (0) -
internal/disk/stat_windows.go
// _Out_opt_ PULARGE_INTEGER lpFreeBytesAvailable, // _Out_opt_ PULARGE_INTEGER lpTotalNumberOfBytes, // _Out_opt_ PULARGE_INTEGER lpTotalNumberOfFreeBytes // ); _, _, _ = GetDiskFreeSpaceEx.Call(uintptr(unsafe.Pointer(syscall.StringToUTF16Ptr(path))), uintptr(unsafe.Pointer(&lpFreeBytesAvailable)), uintptr(unsafe.Pointer(&lpTotalNumberOfBytes)), uintptr(unsafe.Pointer(&lpTotalNumberOfFreeBytes)))
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 4.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* for APIs like {@link #whenAllComplete whenAllComplete(...)}{@code .}{@link * FutureCombiner#call(Callable, Executor) call(...)}, where it is easy to use a new input from * the {@code call} implementation but forget to add it to the arguments of {@code * whenAllComplete}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
cmd/bucket-policy-handlers_test.go
} // Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler. // Call the ServeHTTP to execute the handler. apiRouter.ServeHTTP(recV4, reqV4) if recV4.Code != testCase.expectedRespStatus {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 32.9K bytes - Click Count (0)