expectedReason:      node.NodeUnreachablePodReason,
			description: "Node created long time ago, node controller posted Unknown for a " +
				"long period of time, the pod status must include reason for termination.",
		},
	}

	_, ctx := ktesting.NewTestContext(t)
	for _, item := range table {
		nodeController, _ := newNodeLifecycleControllerFromClient(
			ctx,
			item.fakeNodeHandler,
			testRateLimiterQPS,

	if err != nil {
		t.Fatalf("Error creating storage: %v", err)
	}
	destroyFunc := func() {
		dFunc()
		server.Terminate(t)
	}
	if hasCacheEnabled {
		config := cacherstorage.Config{
			Storage:        s,
			Versioner:      storage.APIObjectVersioner{},
			GroupResource:  schema.GroupResource{Resource: "pods"},

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
	data="/usr/local/google/home/mknyszek/work/go-1/src/syscall/zsyscall_linux_amd64.go"
String id=26
	data="syscall.Read"

description: A valid non-negative integer port number. type: integer protocol: description: The protocol exposed on the port. type: string targetPort: type: integer type: object tls: description: Set of TLS related options that will enable TLS termination on the sidecar for requests originating from outside the mesh. properties: caCertificates: description: REQUIRED if mode is `MUTUAL` or `OPTIONAL_MUTUAL`. type: string cipherSuites: description: 'Optional: If specified, only support the specified...

            "Called my toString",
            new AsyncCallable<String>() {
              @Override
              public ListenableFuture<String> call() throws Exception {
                // Make this executor terminate after this task so that the test can tell when
                // futureResult has received resultOfCombiner.
                executor.shutdown();
                callableBlocking.await();

            "Called my toString",
            new AsyncCallable<String>() {
              @Override
              public ListenableFuture<String> call() throws Exception {
                // Make this executor terminate after this task so that the test can tell when
                // futureResult has received resultOfCombiner.
                executor.shutdown();
                callableBlocking.await();

		return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
			connectStorage.receivedResponder.Error(apierrors.NewForbidden(schema.GroupResource{Resource: "simples"}, itemID, errors.New("you are terminated")))
		})
	}
	storage := map[string]rest.Storage{
		"simple":         &SimpleRESTStorage{},
		"simple/connect": connectStorage,
	}
	handler := handle(storage)

	ab.off += 8
}

// Put copies b into the buffer.
func (ab *AsmBuf) Put(b []byte) {
	copy(ab.buf[ab.off:], b)
	ab.off += len(b)
}

// PutOpBytesLit writes zero terminated sequence of bytes from op,
// starting at specified offset (e.g. z counter value).
// Trailing 0 is not written.
//
// Intended to be used for literal Z cases.

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="GC mark termination"
String id=22
	data="runtime.traceAdvance"
String id=23
	data="/usr/local/google/home/mknyszek/work/go-1/src/runtime/trace2.go"
String id=24
	data="runtime.(*traceAdvancerState).start.func1"

haracters-expected.png","kids":[],"cl_weight":0.0021801110659681613,"touches":3,"min_t":1229474548,"max_t":1238022568,"mean_t":1234567577},{"name":"bidi-european-terminators-expected.png","kids":[],"cl_weight":0.0021801110659681613,"touches":3,"min_t":1229474548,"max_t":1238022568,"mean_t":1234567577},{"name":"bidi-european-terminators-expected.checksum","kids":[],"cl_weight":0.0021801110659681613,"touches":3,"min_t":1229474548,"max_t":1238022568,"mean_t":1234567577},{"name":"bidi-LDB-2-formatti...