- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 134 for rebeat (5.53 sec)
-
docs/site-replication/run-multi-site-minio-idp.sh
exit_1 fi if [ "${enabled_minio1}" != "Enabled" ]; then echo "expected bucket to be mirrored with object-lock enabled, exiting..." exit_1 fi # "Test if most recent tag update is replicated" ./mc tag set minio2/newbucket "key=val1" if [ $? -ne 0 ]; then echo "expecting tag set to be successful. exiting.." exit_1 fi sleep 5
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 00:19:24 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
taskFaker.runTasks() } private fun forceConnectionsToExpire( pool: RealConnectionPool, expireTime: Long, ) { val idleTimeNanos = expireTime + pool.keepAliveDurationNs repeat(pool.connectionCount()) { pool.closeConnections(idleTimeNanos) } taskFaker.runTasks() } private fun connectHttp2( peer: MockHttp2Peer, realConnection: RealConnection,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
docs/en/docs/how-to/sql-databases-peewee.md
``` And in the file `sql_app/main.py` file, uncomment the body of the `async` dependency `reset_db_state()`: ```Python async def reset_db_state(): database.db._state._state.set(db_state_default.copy()) database.db._state.reset() ``` Terminate your running app and start it again. Repeat the same process with the 10 tabs. This time all of them will wait and you will get all the results without errors.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Jan 16 13:23:25 GMT 2024 - 23.6K bytes - Viewed (1) -
guava-tests/test/com/google/common/base/CharMatcherTest.java
assertTrue(matcher.matchesAllOf(s)); assertFalse(matcher.matchesNoneOf(s)); assertEquals("", matcher.removeFrom(s)); assertEquals(Strings.repeat("z", s.length()), matcher.replaceFrom(s, 'z')); assertEquals(Strings.repeat("ZZ", s.length()), matcher.replaceFrom(s, "ZZ")); assertEquals("", matcher.trimFrom(s)); assertEquals(s.length(), matcher.countIn(s)); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 30.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/CharMatcherTest.java
assertTrue(matcher.matchesAllOf(s)); assertFalse(matcher.matchesNoneOf(s)); assertEquals("", matcher.removeFrom(s)); assertEquals(Strings.repeat("z", s.length()), matcher.replaceFrom(s, 'z')); assertEquals(Strings.repeat("ZZ", s.length()), matcher.replaceFrom(s, "ZZ")); assertEquals("", matcher.trimFrom(s)); assertEquals(s.length(), matcher.countIn(s)); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/grid_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/generic-handlers.go
func setRequestLimitMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) // Reject unsupported reserved metadata first before validation. if containsReservedMetadata(r.Header) { if ok { tc.FuncName = "handler.ValidRequest" tc.ResponseRecorder.LogErrBody = true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
src/bytes/buffer_test.go
for _, growLen := range []int{0, 100, 1000, 10000, 100000} { for _, startLen := range []int{0, 100, 1000, 10000, 100000} { xBytes := Repeat(x, startLen) buf := NewBuffer(xBytes) // If we read, this affects buf.off, which is good to test. readBytes, _ := buf.Read(tmp) yBytes := Repeat(y, growLen) allocs := testing.AllocsPerRun(100, func() { buf.Grow(growLen) buf.Write(yBytes) })
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Apr 26 13:31:36 GMT 2024 - 18.6K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } var ( nilBytes []byte data = []byte("hello") fiveMBBytes = bytes.Repeat([]byte("a"), 5*humanize.MiByte) ) invalidMD5 := getMD5Hash([]byte("meh")) invalidMD5Header := md5Header([]byte("meh")) testCases := []struct { bucketName string objName string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 25.8K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_redirect.go
if valErr != nil { return nil, fmt.Errorf("annotation value error for value %s; annotationFound = %t: %v", "includeOutboundPorts", isFound, valErr) } // Add 15090 to sync with non-cni injection template // TODO: Revert below once https://github.com/istio/istio/pull/23037 or its follow up is merged. redir.excludeInboundPorts = strings.TrimSpace(redir.excludeInboundPorts)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0)