- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for inState (0.17 sec)
-
cmd/object-api-multipart_test.go
err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{}) if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } // Initiate Multipart Upload on the above created bucket. res, err := obj.NewMultipartUpload(context.Background(), bucket, object, opts) if err != nil { // Failed to create NewMultipartUpload, abort.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0) -
src/runtime/traceback.go
// move to the next frame, but that's both more awkward to use in a "for" // loop and is harder to implement because we have to do things differently // for the first frame. u.initAt(^uintptr(0), ^uintptr(0), ^uintptr(0), gp, flags) } func (u *unwinder) initAt(pc0, sp0, lr0 uintptr, gp *g, flags unwindFlags) { // Don't call this "g"; it's too easy get "g" and "gp" confused. if ourg := getg(); ourg == gp && ourg == ourg.m.curg {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
} listener.Close() // We're looking for a timeout during the handshake, so check that the // Listener actually accepted the connection to initiate it. (If the server // takes too long to accept the connection, we might cancel before the // underlying net.Conn is ever dialed — without ever attempting a // handshake.) lconn, ok := <-acceptc if ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if e, a := map[string][]types.UID{}, podWorkers.waitingToStartStaticPodsByFullname; !reflect.DeepEqual(e, a) { t.Fatalf("unexpected waiting static pods: %s", cmp.Diff(e, a)) } // initiate a sync with all pods remaining state := podWorkers.SyncKnownPods([]*v1.Pod{ newNamedPod("1-normal", "test1", "pod1", false), newNamedPod("2-static", "test1", "pod1", true),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/runtime/mprof.go
prof.stack[2] = 0 return } var nstk int gp := getg() sp := getcallersp() pc := getcallerpc() systemstack(func() { var u unwinder u.initAt(pc, sp, 0, gp, unwindSilentErrors|unwindJumpStack) nstk = 1 + tracebackPCs(&u, skip, prof.stack[1:]) }) if nstk < len(prof.stack) { prof.stack[nstk] = 0 } } func (prof *mLockProfile) store() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Errorf("timeout after %v", wait.ForeverTestTimeout) } } func RunTestWatcherTimeout(ctx context.Context, t *testing.T, store storage.Interface) { // initialRV is used to initate the watcher at the beginning of the world. podList := example.PodList{} options := storage.ListOptions{ Predicate: storage.Everything, Recursive: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
cmd/bucket-handlers.go
// ------------------------- // This operation lists in-progress multipart uploads. An in-progress // multipart upload is a multipart upload that has been initiated, // using the Initiate Multipart Upload request, but has not yet been // completed or aborted. This operation returns at most 1,000 multipart // uploads in the response.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrSSEMultipartEncrypted: { Code: "InvalidRequest", Description: "The multipart upload initiate requested encryption. Subsequent part requests must include the appropriate encryption parameters.", HTTPStatusCode: http.StatusBadRequest, }, ErrSSEEncryptedObject: { Code: "InvalidRequest",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
queueDispatcher.enqueueResponse(MockResponse(body = "call2 response")) queueDispatcher.enqueueResponse(MockResponse(body = "call1 response")) // We use a re-entrant dispatcher to initiate one HTTPS connection while the other is in flight. server.dispatcher = object : Dispatcher() { var requestCount = 0 override fun dispatch(request: RecordedRequest): MockResponse {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
cmd/test-utils_test.go
checkRespErr(rec, http.StatusOK) } else { // Multipart upload - each part is a new DummyDataGen // (so the part lengths are required to verify the // object when reading). // Initiate mp upload reqI, err := newTestSignedRequestV4(http.MethodPost, getNewMultipartURL("", bucketName, objectName), 0, nil, creds.AccessKey, creds.SecretKey, metadata) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0)