- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 180 for resets (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
connection.writePingAndAwaitPong() // Ensure the GO_AWAY that resets stream2 has been received. val sink1 = stream1.getSink().buffer() val sink2 = stream2.getSink().buffer() sink1.writeUtf8("abc") assertFailsWith<IOException> { sink2.writeUtf8("abc") sink2.flush() }.also { expected -> assertThat(expected.message).isEqualTo("stream was reset: REFUSED_STREAM") } sink1.writeUtf8("def")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/runtime/mgc.go
ready(sweep.g, 0, true) } unlock(&sweep.lock) return false } // gcResetMarkState resets global state prior to marking (concurrent // or STW) and resets the stack scan state of all Gs. // // This is safe to do without the world stopped because any Gs created // during or after this will start out in the reset state. // // gcResetMarkState must be called on the system stack because it acquires
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
requestInfoFactory := &apirequest.RequestInfoFactory{APIPrefixes: sets.NewString("apis", "api"), GrouplessAPIPrefixes: sets.NewString("api")} longRunningRequestCheck := BasicLongRunningRequestCheck(sets.NewString("watch"), sets.NewString("proxy")) apfHandler := WithPriorityAndFairness(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { onExecute()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/binder_test.go
expectedEvents: []string{"Normal FailedBinding"}, errors: noerrors, test: testSyncClaim, }, { // syncClaim resets claim.Status to Pending when there is no // matching volume. name: "1-3 - reset to Pending", initialVolumes: newVolumeArray("volume1-3", "1Gi", "", "", v1.VolumeAvailable, v1.PersistentVolumeReclaimRetain, classEmpty),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 65.8K bytes - Viewed (0) -
src/runtime/mgcscavenge.go
// The assumptions around the controller have likely broken down. // Set a flag and reset. That's the safest thing to do. c.reset() c.errOverflow = true return c.min, false } } return output, true } // reset resets the controller state, except for controller error flags. func (c *piController) reset() { c.errIntegral = 0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:48:45 UTC 2024 - 52.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/setupapi_windows.go
} //sys SetupDiSetSelectedDriver(deviceInfoSet DevInfo, deviceInfoData *DevInfoData, driverInfoData *DrvInfoData) (err error) = setupapi.SetupDiSetSelectedDriverW // SetSelectedDriver method sets, or resets, the selected driver for a device information element or the selected class driver for a device information set. func (deviceInfoSet DevInfo) SetSelectedDriver(deviceInfoData *DevInfoData, driverInfoData *DrvInfoData) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 26 00:11:50 UTC 2022 - 67.2K bytes - Viewed (0) -
cmd/test-utils_test.go
resetGlobalConfig() // Reset global endpoints. resetGlobalEndpoints() // Reset global isErasure flag. resetGlobalIsErasure() // Reset global heal state resetGlobalHealState() // Reset globalIAMSys to `nil` resetGlobalIAMSys() } // Configure the server for the test run. func newTestConfig(bucketLocation string, obj ObjectLayer) (err error) { // Initialize server config.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
src/net/url/url_test.go
t.Errorf("error = %q; want substring %q", got, wantsub) } } func TestRejectControlCharacters(t *testing.T) { tests := []string{ "http://foo.com/?foo\nbar", "http\r://foo.com/", "http://foo\x7f.com/", } for _, s := range tests { _, err := Parse(s) const wantSub = "net/url: invalid control character in URL" if got := fmt.Sprint(err); !strings.Contains(got, wantSub) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:52:38 UTC 2024 - 52.1K bytes - Viewed (0) -
src/encoding/xml/marshal_test.go
var ( nameAttr = "Sarah" ageAttr = uint(12) contentsAttr = "lorem ipsum" empty = "" ) // Unless explicitly stated as such (or *Plain), all of the // tests below are two-way tests. When introducing new tests, // please try to make them two-way as well to ensure that // marshaling and unmarshaling are as symmetrical as feasible. var marshalTests = []struct { Value any ExpectXML string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 18:46:41 UTC 2024 - 66K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/css/manual.css
font-weight: 400; font-style: normal; src: url("https://assets.gradle.com/lato/fonts/lato-normal/lato-normal.woff2") format("woff2"), url("https://assets.gradle.com/lato/fonts/lato-normal/lato-normal.woff") format("woff"); } /* Lato (normal, italic) */ @font-face { font-display: swap; font-family: Lato; font-weight: 400; font-style: italic;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 25 05:15:02 UTC 2024 - 72.6K bytes - Viewed (0)