- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 653 for uniq (0.01 sec)
-
internal/logger/logger.go
errorFmtFunc = f } // uniq swaps away duplicate elements in data, returning the size of the // unique set. data is expected to be pre-sorted, and the resulting set in // the range [0:size] will remain in sorted order. Uniq, following a // sort.Sort call, can be used to prepare arbitrary inputs for use as sets. func uniq(data sort.Interface) (size int) { p, l := 0, data.Len() if l <= 1 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12.4K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
// Only support UTC normalized timestamps. if ts.IsAdjustedToUTC { switch { case ts.Unit.IsSetNANOS(): duration = time.Duration(val) * time.Nanosecond case ts.Unit.IsSetMILLIS(): duration = time.Duration(val) * time.Millisecond case ts.Unit.IsSetMICROS(): duration = time.Duration(val) * time.Microsecond default:Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.5K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/InfoTest.java
import static org.mockito.Mockito.mock; import java.util.Date; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.mockito.Mock; /** * Unit tests for the {@link Info} implementations used by the SMB1 * protocol handling code. */ class InfoTest { // A tiny mock to illustrate Mockito interaction patterns. @MockRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt
internal fun String.indexOfFirstNonAsciiWhitespace( startIndex: Int = 0, endIndex: Int = length, ): Int { for (i in startIndex until endIndex) { when (this[i]) { '\t', '\n', '\u000C', '\r', ' ' -> Unit else -> return i } } return endIndex } /** * Decrements [endIndex] until `input[endIndex - 1]` is not ASCII whitespace. Stops at [startIndex]. */
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 10.1K bytes - Viewed (0) -
internal/rest/client.go
func exponentialBackoffWait(r *rand.Rand, unit, maxSleep time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt))
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 14.7K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/FileSizeFormat.java
format(builder, size, unit, false); } private void format(StringBuilder builder, long size, ScaleUnit unit, boolean omitSymbol) { if (size < 0L) { throw new IllegalArgumentException("file size cannot be negative: " + size); } if (unit == null) { unit = ScaleUnit.getScaleUnit(size); }
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Apr 16 10:09:21 UTC 2025 - 6.5K bytes - Viewed (0) -
cmd/admin-handlers_test.go
"testing" "time" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/auth" "github.com/minio/mux" ) // adminErasureTestBed - encapsulates subsystems that need to be setup for // admin-handler unit tests. type adminErasureTestBed struct { erasureDirs []string objLayer ObjectLayer router *mux.Router done context.CancelFunc }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (1) -
tests/customize_field_test.go
t.Fatalf("invalid create/update unix time: %#v", result) } if int(result.AutoUnixMilliCreateTime) != int(result.AutoUnixMilliUpdateTime) || result.AutoUnixMilliCreateTime == 0 || int(result.AutoUnixMilliCreateTime)/int(result.AutoUnixCreateTime) < 1e3 { t.Fatalf("invalid create/update unix milli time: %#v", result) }
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Sep 11 09:33:31 UTC 2020 - 6.9K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/replication/minio-replication-node.json
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Aug 04 01:46:49 UTC 2025 - 57.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency @SuppressWarnings("GoodTime") // should accept a java.time.Duration public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) { boolean interrupted = false; try { long remainingNanos = unit.toNanos(timeout);Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0)