- Sort Score
- Num 10 results
- Language All
Results 711 - 720 of 1,092 for Khan (0.03 seconds)
-
android/guava/src/com/google/common/reflect/TypeResolver.java
@Override void visitClass(Class<?> fromClass) { if (to instanceof WildcardType) { return; // Okay to say Foo is <?> } // Can't map from a raw class to anything other than itself or a wildcard. // You can't say "assuming String is Integer". // And we don't support "assuming String is T"; user has to say "assuming T is String".Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 22:30:05 GMT 2025 - 25.3K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// run() on the same thread that called execute() - such as in a thread pool, and think // that it was happening inline. As a side benefit, avoids holding on to the Thread object // longer than necessary. submitting = null; } } @SuppressWarnings("ShortCircuitBoolean") @Override public void run() { Thread currentThread = Thread.currentThread();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
guava/src/com/google/common/primitives/Booleans.java
public static int hashCode(boolean value) { return Boolean.hashCode(value); } /** * Compares the two specified {@code boolean} values in the standard way ({@code false} is * considered less than {@code true}). The sign of the value returned is the same as that of * {@code ((Boolean) a).compareTo(b)}. * * <p><b>Note:</b> this method is now unnecessary and should be treated as deprecated; use the
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 25 15:01:23 GMT 2025 - 20.6K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
taskRunner.withLock { activeThreads-- startNextTask() } } } } } /** * This blocking queue hooks into a fake clock rather than using regular JVM timing for functions * like [poll]. It is only usable within task faker tasks. */ private inner class TaskFakerBlockingQueue<T>( val delegate: BlockingQueue<T>, ) : AbstractQueue<T>(),Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (0) -
cmd/batch-job-common-types.go
// inmemory: true # indicates if the archive must be staged locally or in-memory // compress: true # S2/Snappy compressed archive // smallerThan: 5MiB # create archive for all objects smaller than 5MiB // skipErrs: false # skips any source side read() errors // BatchJobSnowball describes the snowball feature when replicating objects from a local source to a remote target type BatchJobSnowball struct {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 7.9K bytes - Click Count (0) -
scan.go
if field == nil { continue } if len(joinFields) == 0 || len(joinFields[idx]) == 0 { db.AddError(field.Set(db.Statement.Context, reflectValue, values[idx])) } else { // joinFields count is larger than 2 when using join var isNilPtrValue bool var relValue reflect.Value // does not contain raw dbname nestedJoinSchemas := joinFields[idx][:len(joinFields[idx])-1] // current reflect valueCreated: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun May 25 07:40:40 GMT 2025 - 10.4K bytes - Click Count (0) -
internal/bucket/replication/replication.go
} } } return &config, nil } // Validate - validates the replication configuration func (c Config) Validate(bucket string, sameTarget bool) error { // replication config can't have more than 1000 rules if len(c.Rules) > 1000 { return errReplicationTooManyRules } // replication config should have at least one rule if len(c.Rules) == 0 { return errReplicationNoRule }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 8.9K bytes - Click Count (0) -
cmd/signature-v4-parser.go
if e != nil { return psv, ErrMalformedExpires } if preSignV4Values.Expires < 0 { return psv, ErrNegativeExpires } // Check if Expiry time is less than 7 days (value in seconds). if preSignV4Values.Expires.Seconds() > 604800 { return psv, ErrMaximumExpires } if preSignV4Values.Date.IsZero() || preSignV4Values.Date.Equal(timeSentinel) {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 10 18:57:35 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/event/target/webhook.go
id event.TargetID args WebhookArgs transport *http.Transport httpClient *http.Client store store.Store[event.Event] loggerOnce logger.LogOnce cancel context.CancelFunc cancelCh <-chan struct{} addr string // full address ip/dns with a port number, e.g. x.x.x.x:8080 } // ID - returns target ID. func (target *WebhookTarget) ID() event.TargetID { return target.id }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} } companion object { private val ONLY_HTTP1 = listOf(Protocol.HTTP_1_1) /** * The maximum number of bytes to enqueue. Rather than enqueueing beyond this limit we tear down * the web socket! It's possible that we're writing faster than the peer can read. */ private const val MAX_QUEUE_SIZE = 16L * 1024 * 1024 // 16 MiB. /**Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 21.6K bytes - Click Count (0)