// license that can be found in the LICENSE file.

package main

import (
	"runtime"
	"time"
)

func main() {
	c := make(chan bool, 1)
	go f1(c)
	<-c
	time.Sleep(10 * time.Millisecond)
	go f2(c)
	<-c
}

func f1(done chan bool) {
	defer func() {
		recover()
		done <- true
		runtime.Goexit() // left stack-allocated Panic struct on gp->panic stack
	}()
	panic("p")
}

}

var defaultLatencyBuckets = []time.Duration{
	10 * time.Millisecond,
	50 * time.Millisecond,
	100 * time.Millisecond,
	250 * time.Millisecond,
	500 * time.Millisecond,
	1000 * time.Millisecond, // 1s
	1500 * time.Millisecond,
	3000 * time.Millisecond,
	5000 * time.Millisecond,
	10000 * time.Millisecond, // 10s
}

// KMS is a connection to a key management system.

	work := NewDeadlineWorker(500 * time.Millisecond)

	err := work.Run(func() error {
		time.Sleep(600 * time.Millisecond)
		return nil
	})
	if err != context.DeadlineExceeded {
		t.Error("DeadlineWorker shouldn't be successful - should return context.DeadlineExceeded")
	}

	err = work.Run(func() error {
		time.Sleep(450 * time.Millisecond)
		return nil
	})
	if err != nil {

	ns.Create(ns1)
	s.AssertEmpty(t, time.Millisecond*10)

	ns.Create(ns2)
	s.AssertEmpty(t, time.Millisecond*10)

	ns1.Annotations = map[string]string{"foo": "bar"}
	ns.Update(ns1)
	s.AssertEmpty(t, time.Millisecond*10)

	ns2.Annotations = map[string]string{"foo": "bar"}
	ns.Update(ns2)
	s.AssertEmpty(t, time.Millisecond*10)

	ns1.Labels["bar"] = "foo"
	ns.Update(ns1)

	waitCmd.PersistentFlags().IntVar(&requestTimeoutMillis, "requestTimeoutMillis", 500, "number of milliseconds to wait for response")
	waitCmd.PersistentFlags().IntVar(&periodMillis, "periodMillis", 500, "number of milliseconds to wait between attempts")
	waitCmd.PersistentFlags().StringVar(&url, "url", "http://localhost:15021/healthz/ready", "URL to use in requests")

)

type T struct {
	ptr **int
	pad [120]byte
}

var things []interface{}

func main() {
	setup()
	runtime.GC()
	runtime.GC()
	time.Sleep(10*time.Millisecond)
	runtime.GC()
	runtime.GC()
	time.Sleep(10*time.Millisecond)
}

func setup() {
	var Ts []interface{}
	buf := make([]byte, 128)
	
	for i := 0; i < 10000; i++ {
		s := string(buf)
		t := &T{ptr: new(*int)}

package sleep

import (
	"testing"
	"time"

	"istio.io/istio/pkg/test/util/assert"
)

func TestUntil(t *testing.T) {
	c := make(chan struct{})
	assert.Equal(t, Until(c, time.Millisecond), true)

	go func() {
		time.Sleep(time.Millisecond * 50)
		close(c)
	}()
	assert.Equal(t, Until(c, time.Minute), false)

	if idle == 0 {
		idle = defaultTCPKeepAliveIdle
	}

	// The kernel expects milliseconds so round to next highest
	// millisecond.
	if idle > 0 {
		msecs := int(roundDurationUp(idle, time.Millisecond))
		err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPALIVE_THRESHOLD, msecs)
		runtime.KeepAlive(fd)
		if err != nil {

func testCacheExpiration(c ExpiringCache, evictExpired func(time.Time), t *testing.T) {
	now := time.Now()

	c.SetWithExpiration("EARLY", "123", 10*time.Millisecond)
	c.SetWithExpiration("LATER", "123", 20*time.Millisecond+123*time.Nanosecond)

	evictExpired(now)
	s := c.Stats()

	_, ok := c.Get("EARLY")
	if !ok {
		t.Errorf("Got no value, expected EARLY to be present")
	}

	// The first SIGHUP should be waiting for us on c.
	waitSig(t, c, syscall.Note("hangup"))
}

func TestStress(t *testing.T) {
	dur := 3 * time.Second
	if testing.Short() {
		dur = 100 * time.Millisecond
	}
	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(4))
	done := make(chan bool)
	finished := make(chan bool)
	go func() {
		sig := make(chan os.Signal, 1)
		Notify(sig, syscall.Note("alarm"))
		defer Stop(sig)