}
	if prepares := numPrepares(t, db) - prepares0; prepares != 1 {
		t.Errorf("executed %d Prepare statements; want 1", prepares)
	}
}

func TestPoolExhaustOnCancel(t *testing.T) {
	if testing.Short() {
		t.Skip("long test")
	}

	max := 3
	var saturate, saturateDone sync.WaitGroup
	saturate.Add(max)
	saturateDone.Add(max)

	donePing := make(chan bool)
	state := 0

endTokenLength; private static String DEFAULT_BEGIN_TOKEN; private static String DEFAULT_END_TOKEN; public void InterpolationFilterR(java.io.Reader, java.util.Map, String, String); public void InterpolationFilterR(java.io.Reader, java.util.Map); public long skip(long) throws java.io.IOException; public int read(char[], int, int) throws java.io.IOException; public int read() throws java.io.IOException; static void <clinit>(); } org/codehaus/plexus/util/introspection/ClassMap$1.class package org.codehaus.pl...

endTokenLength; private static String DEFAULT_BEGIN_TOKEN; private static String DEFAULT_END_TOKEN; public void InterpolationFilterR(java.io.Reader, java.util.Map, String, String); public void InterpolationFilterR(java.io.Reader, java.util.Map); public long skip(long) throws java.io.IOException; public int read(char[], int, int) throws java.io.IOException; public int read() throws java.io.IOException; static void <clinit>(); } org/codehaus/plexus/util/introspection/ClassMap$1.class package org.codehaus.pl...

LineOrientedInterpol(java.io.Reader, java.util.Map, String, String); public void LineOrientedInterpol(java.io.Reader, java.util.Map); public int read() throws java.io.IOException; public int read(char[], int, int) throws java.io.IOException; public long skip(long) throws java.io.IOException; private void readAndInterpolateLi() throws java.io.IOException; private String readLine() throws java.io.IOException; private String replaceWithInterpola(String, java.util.Map); private java.util.Map evaluateExpre...

	if fetchErr != nil {
		if errors.IsNotFound(fetchErr) {
			klog.Warningf(volumeToDetach.GenerateMsgDetailed("Node not found on API server. DetachVolume will skip safe to detach check", ""))
			return nil
		}

		// On failure, return error. Caller will log and retry.
		return volumeToDetach.GenerateErrorDetailed("DetachVolume failed fetching node from API server", fetchErr)

    server.enqueue(mockResponse.build())

    // Make sure that calling skip() doesn't omit bytes from the cache.
    val request = Request.Builder().url(server.url("/")).build()
    val response1 = client.newCall(request).execute()
    val in1 = response1.body.source()
    assertThat(in1.readUtf8("I love ".length.toLong())).isEqualTo("I love ")
    in1.skip("puppies but hate ".length.toLong())

//		any trailing spaces and final newline) matches the
//		expression.
//
//	-skip=""
//		if non-empty, specifies a regular expression to suppress
//		directives whose full original source text (excluding
//		any trailing spaces and final newline) matches the
//		expression. If a directive matches both the -run and
//		the -skip arguments, it is skipped.
//
// It also accepts the standard build flags including -v, -n, and -x.

        resources: ["secrets", "configmaps", "serviceaccounts/token"]
      - group: authentication.k8s.io
        resources: ["tokenreviews"]
    omitStages:
      - "RequestReceived"
  # Get responses can be large; skip them.
  - level: Request
    verbs: ["get", "list", "watch"]
    resources: ${known_apis}
    omitStages:
      - "RequestReceived"
  # Default level for known APIs
  - level: RequestResponse

		nodeLister = corelisters.NewNodeLister(nodeIndexer)
		nodeHasSynced = func() bool { return true }
		klog.InfoS("Kubelet is running in standalone mode, will skip API server sync")
	}

	if kubeDeps.PodConfig == nil {
		var err error
		kubeDeps.PodConfig, err = makePodSourceConfig(kubeCfg, kubeDeps, nodeName, nodeHasSynced)
		if err != nil {
			return nil, err
		}

	// but that's not correct: If we keep using the connection,
	// the client is required to send the request body whether we
	// asked for it or not.
	//
	// We probably do want to skip reusing the connection in most cases,
	// however. If the client is offering a large request body that we
	// don't intend to use, then it's better to close the connection