objInfo.ETag = origETag
		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CopyObject)
		// Remove the transitioned object whose object version is being overwritten.
		os.Sweep()
	}
}

// PutObjectHandler - PUT Object
// ----------
// This implementation of the PUT operation adds an object to a bucket.

from the connection pool. nullable: true type: integer consecutiveLocalOrig: description: The number of consecutive locally originated failures before ejection occurs. nullable: true type: integer interval: description: Time interval between ejection sweep analysis. type: string maxEjectionPercent: description: Maximum % of hosts in the load balancing pool for the upstream service that can be ejected. format: int32 type: integer minHealthPercent: description: Outlier detection will be enabled as long...

String id=16
	data="preempted"
String id=17
	data="wait for debug call"
String id=18
	data="wait until GC ends"
String id=19
	data="sleep"
String id=20
	data="runtime.Gosched"
String id=21
	data="start trace"
String id=22
	data="GC sweep termination"
String id=23
	data="GC mark termination"
String id=24
	data="syscall.read"
String id=25

					// Make wake-up period small enough
					// for the sampling to be correct.
					sleep := forcegcperiod / 2
					if next-now < sleep {
						sleep = next - now
					}
					shouldRelax := sleep >= osRelaxMinNS
					if shouldRelax {
						osRelax(true)
					}
					syscallWake = notetsleep(&sched.sysmonnote, sleep)
					if shouldRelax {
						osRelax(false)
					}
					lock(&sched.lock)

String id=51
	data="runtime.traceLocker.GCSweepSpan"
String id=52
	data="/usr/local/google/home/mknyszek/work/go-1/src/runtime/trace2runtime.go"
String id=53
	data="runtime.(*sweepLocked).sweep"
String id=54
	data="/usr/local/google/home/mknyszek/work/go-1/src/runtime/mgcsweep.go"
String id=55
	data="runtime.(*mcentral).cacheSpan"
String id=56

		if mode == "top" && numRows == 2 {
			// cancel between Next and Scan is observed by Scan as err = context.Canceled.
			// The sleep here is only to make it more likely that the cancel will be observed.
			// If not, the test should still pass, like in "go" mode.
			cancel()
			time.Sleep(100 * time.Millisecond)
		}
		numRows++
		var s RawBytes
		err = r.Scan(&s)
		if numRows == 3 && err == context.Canceled {

		if !c.rd.IsZero() {
			// If the deadline falls in the middle of our sleep window, deduct
			// part of the sleep, then return a timeout.
			if remaining := time.Until(c.rd); remaining < cue {
				c.script[0] = cue - remaining
				time.Sleep(remaining)
				return 0, syscall.ETIMEDOUT
			}
		}
		c.script = c.script[1:]
		time.Sleep(cue)
		goto restart

	case string:
		n = copy(b, cue)

  until kubectl get volumesnapshotclasses.snapshot.storage.k8s.io
  do
    sleep 10
  done

  until kubectl get volumesnapshotcontents.snapshot.storage.k8s.io
  do
    sleep 10
  done

  until kubectl get volumesnapshots.snapshot.storage.k8s.io
  do
    sleep 10
  done

  echo "Wait until volume snapshot RBAC rules are installed"

			newLifecycleHandler:    makeExecHandler(),
			expectLifecycleHandler: makeExecHandler(),
		},
		// sleep -> sleep
		{
			gateEnabled:            false,
			oldLifecycleHandler:    makeSleepHandler(),
			newLifecycleHandler:    makeSleepHandler(),
			expectLifecycleHandler: makeSleepHandler(),
		},
		{
			gateEnabled:            true,
			oldLifecycleHandler:    makeSleepHandler(),

	//
	// The 1s sleep in the test allows GetDeletableResources and
	// gc.resyncMonitors to run ~5 times to ensure the changes to the
	// fakeDiscoveryClient are picked up.
	go gc.Sync(tCtx, fakeDiscoveryClient, 200*time.Millisecond)

	// Wait until the sync discovers the initial resources
	time.Sleep(1 * time.Second)