- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 110 for Reset (0.22 sec)
-
cmd/callhome.go
case <-callhomeTimer.C: if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } performCallhome(ctx) // Reset the timer for next cycle. callhomeTimer.Reset(globalCallhomeConfig.FrequencyDur()) } } } func performCallhome(ctx context.Context) { deadline := 10 * time.Second // Default deadline is 10secs for callhome
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
internal/config/cache/remote_gen_test.go
m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeCondCheck Msgsize() is inaccurate") } vn := CondCheck{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } } func BenchmarkEncodeCondCheck(b *testing.B) { v := CondCheck{} var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 4.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/ProjectBuildingHelper.java
/** * Updates the context class loader such that the container will search the project realm when the model builder * injects the lifecycle bindings from the packaging in the next step. The context class loader is to be reset by * the project builder when the project is fully assembled. * * @param project The project whose class realm should be selected, must not be {@code null}. */
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/erasure-utils.go
if offset >= int64(len(block)) { // Decrement offset. offset -= int64(len(block)) continue } // Skip until offset. block = block[offset:] // Reset the offset for next iteration to read everything // from subsequent blocks. offset = 0 // We have written all the blocks, write the last remaining block. if write < int64(len(block)) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/StreamResetException.kt
import java.io.IOException /** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */ class StreamResetException( @JvmField val errorCode: ErrorCode,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 869 bytes - Viewed (0) -
cmd/bitrot-streaming.go
h hash.Hash shardSize int64 canClose *sync.WaitGroup } func (b *streamingBitrotWriter) Write(p []byte) (int, error) { if len(p) == 0 { return 0, nil } b.h.Reset() b.h.Write(p) hashBytes := b.h.Sum(nil) _, err := b.iow.Write(hashBytes) if err != nil { b.closeWithErr(err) return 0, err } n, err := b.iow.Write(p) if err != nil { b.closeWithErr(err)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/lock-rest-server.go
select { case <-ctx.Done(): return case <-lkTimer.C: globalLockServer.expireOldLocks(lockValidityDuration) // Reset the timer for next cycle. lkTimer.Reset(lockMaintenanceInterval) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
srcCtnt, srcOk := nextObject(srcCh) tgtCtnt, tgtOk := nextObject(tgtCh) var srcEOF, tgtEOF bool srcSha256 := sha256.New() tgtSha256 := sha256.New() for { srcSha256.Reset() tgtSha256.Reset() srcEOF = !srcOk tgtEOF = !tgtOk // No objects from source AND target: Finish if srcEOF && tgtEOF { break } if !srcEOF && srcCtnt.Err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/SocketPolicy.kt
DISCONNECT_DURING_REQUEST_BODY, DISCONNECT_DURING_RESPONSE_BODY, DO_NOT_READ_REQUEST_BODY, FAIL_HANDSHAKE, SHUTDOWN_INPUT_AT_END, SHUTDOWN_OUTPUT_AT_END, STALL_SOCKET_AT_START, NO_RESPONSE, RESET_STREAM_AT_START, EXPECT_CONTINUE, CONTINUE_ALWAYS,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
tests/test_dependency_normal_exceptions.py
@app.put("/user/{user_id}") def put_user(user_id: str, name: str = Body(), db: dict = Depends(get_database)): db[user_id] = name return {"message": "OK"} @pytest.fixture(autouse=True) def reset_state_and_db(): global fake_database global state fake_database = initial_fake_database.copy() state = initial_state.copy() client = TestClient(app) def test_dependency_gets_exception():
Python - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Feb 24 23:06:37 GMT 2024 - 1.9K bytes - Viewed (0)