- Sort Score
- Result 10 results
- Languages All
Results 1021 - 1030 of 1,487 for Take (0.06 sec)
-
cmd/xl-storage_test.go
} volume := "success-vol" // Setup test environment. if err = xlStorage.MakeVol(t.Context(), volume); err != nil { t.Fatalf("Unable to create volume, %s", err) } // Create directory to make errIsNotRegular if err = os.Mkdir(slashpath.Join(path, "success-vol", "object-as-dir"), 0o777); err != nil { t.Fatalf("Unable to create directory, %s", err) } testCases := []struct { volume string
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 66K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt
if (!platform.isBouncyCastle()) { assertThat(recordedRequest.handshakeServerNames).containsExactly("cash.app") } } /** * Connect to [hostnameOrIpAddress] and return what was received. To fake an arbitrary hostname we * tell MockWebServer to act as a proxy. */ private fun requestToHostnameViaProxy(hostnameOrIpAddress: String): RecordedRequest { val heldCertificate = HeldCertificate
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 6.3K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/hash/HashStringBenchmark.java
static final int SAMPLES = 0x100; static final int SAMPLE_MASK = 0xFF; /** * Compute arrays of valid unicode text, and store it in 3 forms: byte arrays, Strings, and * StringBuilders (in a CharSequence[] to make it a little harder for the JVM). */ @BeforeExperiment void setUp() { long seed = 99; Random rnd = new Random(seed); strings = new String[SAMPLES]; for (int i = 0; i < SAMPLES; i++) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 5.3K bytes - Viewed (0) -
docs/iam/access-management-plugin.md
``` By default this plugin uses HTTP 1.x. To enable HTTP2 use the `MINIO_POLICY_PLUGIN_ENABLE_HTTP2` environment variable. ## Request and Response MinIO will make a `POST` request with a JSON body to the given plugin URL. If the auth token parameter is set, it will be sent as an authorization header. The JSON body structure can be seen from this sample:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Dec 13 22:28:48 UTC 2022 - 4.4K bytes - Viewed (1) -
internal/lock/lock_test.go
// try lock the unlocked file dupl, err := LockedOpenFile(f.Name(), os.O_WRONLY|os.O_CREATE, 0o600) if err != nil { t.Errorf("err = %v, want %v", err, nil) } // blocking on locked file locked := make(chan struct{}, 1) go func() { bl, blerr := LockedOpenFile(f.Name(), os.O_WRONLY, 0o600) if blerr != nil { t.Error(blerr) return } locked <- struct{}{} if blerr = bl.Close(); blerr != nil {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 3.7K bytes - Viewed (0) -
internal/grid/debug.go
hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid res.Hosts = hosts ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts { manager, err := NewManager(ctx, ManagerOptions{ Dialer: ConnectWS(dialer.DialContext,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 4.4K bytes - Viewed (0) -
internal/s3select/select_benchmark_test.go
) const charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789" func newRandString(length int) string { randSrc := rand.New(rand.NewSource(time.Now().UnixNano())) b := make([]byte, length) for i := range b { b[i] = charset[randSrc.Intn(len(charset))] } return string(b) } func genSampleCSVData(count int) []byte { buf := &bytes.Buffer{} csvWriter := csv.NewWriter(buf)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5K bytes - Viewed (0) -
cmd/object-api-utils_test.go
{name: "large", data: bytes.Repeat([]byte("hello, world"), 1000000), wantIdx: true}, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { buf := make([]byte, 100) // make small buffer to ensure multiple reads are required for large case r, idxCB := newS2CompressReader(bytes.NewReader(tt.data), int64(len(tt.data)), false) defer r.Close() var rdrBuf bytes.BufferRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 24.1K bytes - Viewed (0) -
schema/relationship.go
} if constraint.OnUpdate != "" { sql += " ON UPDATE " + constraint.OnUpdate } foreignKeys := make([]interface{}, 0, len(constraint.ForeignKeys)) for _, field := range constraint.ForeignKeys { foreignKeys = append(foreignKeys, clause.Column{Name: field.DBName}) } references := make([]interface{}, 0, len(constraint.References)) for _, field := range constraint.References {Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Nov 16 04:11:05 UTC 2025 - 23.1K bytes - Viewed (1) -
guava-tests/test/com/google/common/io/SourceSinkTester.java
/** * @param <S> the source or sink type * @param <T> the data type (byte[] or String) * @param <F> the factory type * @author Colin Decker */ @AndroidIncompatible // TODO(b/230620681): Make this available (even though we won't run it). @NullUnmarked public class SourceSinkTester<S, T, F extends SourceSinkFactory<S, T>> extends TestCase { static final String LOREM_IPSUM =
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 4.9K bytes - Viewed (0)