- Sort Score
- Result 10 results
- Languages All
Results 531 - 540 of 1,494 for case1 (0.03 sec)
-
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 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 5.4K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/logging/impl/LogbackConfiguration.java
@Override public void setRootLoggerLevel(Level level) { ch.qos.logback.classic.Level value; switch (level) { case DEBUG: value = ch.qos.logback.classic.Level.DEBUG; break; case INFO: value = ch.qos.logback.classic.Level.INFO; break; default:
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.7K bytes - Viewed (0) -
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 } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/NullnessCasts.java
* analysis that that means "plain {@code T}" rather than the inferred type {@code @Nullable T}. * (Even if supported added {@code @NonNull}, that would not help, since the problem case * addressed by this method is the case in which {@code T} has parametric nullness -- and thus its * value may be legitimately {@code null}.) */ @SuppressWarnings("nullness") @ParametricNullness
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 10 20:36:34 UTC 2022 - 3.9K bytes - Viewed (0) -
internal/bucket/versioning/versioning.go
// Not supported yet // switch v.MFADelete { // case Enabled, Disabled: // default: // return Errorf("unsupported MFADelete state %s", v.MFADelete) // } switch v.Status { case Enabled: const maxExcludedPrefixes = 10 if len(v.ExcludedPrefixes) > maxExcludedPrefixes { return errTooManyExcludedPrefixes } case Suspended: if len(v.ExcludedPrefixes) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/sts-handlers.go
switch err { case openid.ErrTokenExpired: switch action { case clientGrants: writeSTSErrorResponse(ctx, w, ErrSTSClientGrantsExpiredToken, err) case webIdentity: writeSTSErrorResponse(ctx, w, ErrSTSWebIdentityExpiredToken, err) } return case auth.ErrInvalidDuration: writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 01:29:20 UTC 2024 - 33.9K bytes - Viewed (0) -
internal/once/singleton.go
// GetNonBlocking will return the singleton value or nil if not set yet. func (s *Singleton[T]) GetNonBlocking() *T { select { case <-s.set: return s.v default: return nil } } // IsSet will return whether the singleton has been set. func (s *Singleton[T]) IsSet() bool { select { case <-s.set: return true default: return false } } // Set the value and unblock all Get requests.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 952 bytes - Viewed (0) -
cmd/veeam-sos-api.go
var buf []byte switch object { case systemXMLObject: si := systemInfo{ ProtocolVersion: `"1.0"`, ModelName: "\"MinIO " + ReleaseTag + "\"", } si.ProtocolCapabilities.CapacityInfo = true // Default recommended block size with MinIO si.SystemRecommendations.KBBlockSize = 4096 buf = encodeResponse(&si) case capacityXMLObject: objAPI := newObjectLayerFn()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 00:34:56 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/event/target/webhook.go
// already present we can blindly use the // authToken as is instead of adding 'Bearer' tokens := strings.Fields(target.args.AuthToken) switch len(tokens) { case 2: req.Header.Set("Authorization", target.args.AuthToken) case 1: req.Header.Set("Authorization", "Bearer "+target.args.AuthToken) } req.Header.Set("Content-Type", "application/json") resp, err := target.httpClient.Do(req)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
src/main/java/jcifs/pac/kerberos/KerberosAuthData.java
List<KerberosAuthData> authorizations = new ArrayList<>(); switch ( authType ) { case KerberosConstants.AUTH_DATA_RELEVANT: authorizations = new KerberosRelevantAuthData(token, keys).getAuthorizations(); break; case KerberosConstants.AUTH_DATA_PAC: authorizations.add(new KerberosPacAuthData(token, keys)); break; default:
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.6K bytes - Viewed (0)