- Sort Score
- Num 10 results
- Language All
Results 1071 - 1080 of 1,810 for cause (0.05 seconds)
-
cmd/admin-heal-ops.go
// unconsumedTimer fires. select { // Check after a second case <-time.After(time.Second): h.mutex.Unlock() continue case <-h.ctx.Done(): h.mutex.Unlock() // discard result and return. return errHealStopSignalled // Timeout if no results consumed for too long. case <-unconsumedTimer.C: h.mutex.Unlock() return errHealIdleTimeout } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
assertEquals("An error occurred during the deferred computation.", e.getMessage()); } } // ============================================================ // Edge case tests for timeout handling // ============================================================ @Test public void test_getResponseTimeout() throws Exception {
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 21.1K bytes - Click Count (0) -
cmd/auth-handler.go
region := globalSite.Region() switch atype { case authTypeUnknown: return ErrSignatureVersionNotSupported case authTypeSignedV2, authTypePresignedV2: cred, owner, s3Err = getReqAccessKeyV2(r) case authTypeStreamingSigned, authTypePresigned, authTypeSigned, authTypeStreamingSignedTrailer: cred, owner, s3Err = getReqAccessKeyV4(r, region, serviceS3) case authTypeStreamingUnsignedTrailer:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/SneakyThrows.java
* throws} clause: Java forces us to handle an arbitrary {@link Throwable} from that method, * rather than just the {@link RuntimeException} or {@link Error} that should be possible. (And in * fact the static type of {@link Throwable} is occasionally justified even for a method with no * {@code throws} clause: Some such methods can in fact throw a checked exception (e.g., byCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 30 18:44:22 GMT 2024 - 2.4K bytes - Click Count (0) -
internal/bucket/bandwidth/monitor_gen.go
if err != nil { err = msgp.WrapError(err) return } switch msgp.UnsafeString(field) { case "LimitInBytesPerSecond": z.LimitInBytesPerSecond, err = dc.ReadInt64() if err != nil { err = msgp.WrapError(err, "LimitInBytesPerSecond") return } case "CurrentBandwidthInBytesPerSecond": z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64() if err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
cmd/api-response.go
case crypto.S3: m[xhttp.AmzServerSideEncryption] = xhttp.AmzEncryptionAES case crypto.S3KMS: m[xhttp.AmzServerSideEncryption] = xhttp.AmzEncryptionKMS m[xhttp.AmzServerSideEncryptionKmsID] = kmsKeyIDFromMetadata(metadata) if kmsCtx, ok := metadata[crypto.MetaContext]; ok { m[xhttp.AmzServerSideEncryptionKmsContext] = kmsCtx } case crypto.SSEC:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:19 GMT 2025 - 35K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java
switch (action) { case FILE_ACTION_ADDED: return DirectoryChangeType.FILE_ADDED; case FILE_ACTION_REMOVED: return DirectoryChangeType.FILE_REMOVED; case FILE_ACTION_MODIFIED: return DirectoryChangeType.FILE_MODIFIED; case FILE_ACTION_RENAMED_OLD_NAME: case FILE_ACTION_RENAMED_NEW_NAME:
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 13.7K bytes - Click Count (0) -
internal/kms/secret-key.go
var aead cipher.AEAD switch keyType { case kms.AES256: mac := hmac.New(sha256.New, s.key) mac.Write(iv) sealingKey := mac.Sum(nil) block, err := aes.NewCipher(sealingKey) if err != nil { return nil, err } aead, err = cipher.NewGCM(block) if err != nil { return nil, err } case kms.ChaCha20: sealingKey, err := chacha20.HChaCha20(s.key, iv)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Apr 21 16:23:51 GMT 2025 - 8.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessUserLocaleProcessProviderTest.java
// Setup mock request manager with mixed case // LocaleUtils.toLocale is strict about case - it will throw exception for invalid format RequestManager mockRequestManager = createMockRequestManager("En_Us"); // Execute OptionalThing<Locale> result = provider.findBusinessLocale(null, mockRequestManager); // Verify - invalid case format should return empty due to exceptionCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 11.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java
* For BoolQueryBuilder, adds as a should clause. * For DisMaxQueryBuilder, adds as a query. * * @param innerQueryBuilder the query builder to add * @return this instance for method chaining */ public DefaultQueryBuilder add(final QueryBuilder innerQueryBuilder) { switch (queryType) { case BOOL: ((BoolQueryBuilder) queryBuilder).should(innerQueryBuilder);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 6.6K bytes - Click Count (0)