"format": "int64",

//
// specifies that the command "foo" represents the generator
// "go tool foo".
//
// Generate processes packages in the order given on the command line,
// one at a time. If the command line lists .go files from a single directory,
// they are treated as a single package. Within a package, generate processes the
// source files in a package in file name order, one at a time. Within

// rstAvoidanceDelay is the amount of time we sleep after closing the
// write side of a TCP connection before closing the entire socket.
// By sleeping, we increase the chances that the client sees our FIN
// and processes its final data before they process the subsequent RST
// from closing a connection with known unread data.
// This RST seems to occur mostly on BSD systems. (And Windows?)

nsumer(); public void consumeLine(String); public String getOutput(); } org/codehaus/plexus/util/cli/CommandLineUtils.class package org.codehaus.plexus.util.cli; public abstract synchronized class CommandLineUtils { private static java.util.Map processes; public void CommandLineUtils(); public static int executeCommandLine(Commandline, StreamConsumer, StreamConsumer) throws CommandLineException; public static int executeCommandLine(Commandline, java.io.InputStream, StreamConsumer, StreamConsumer)...

			}
			continue
		}
		klog.V(3).InfoS("Orphaned pod found, removing pod cgroups", "podUID", uid)
		// Destroy all cgroups of pod that should not be running,
		// by first killing all the attached processes to these cgroups.
		// We ignore errors thrown by the method, as the housekeeping loop would
		// again try to delete these unwanted pod cgroups
		go pcm.Destroy(val)
	}
}

nsumer(); public void consumeLine(String); public String getOutput(); } org/codehaus/plexus/util/cli/CommandLineUtils.class package org.codehaus.plexus.util.cli; public abstract synchronized class CommandLineUtils { private static java.util.Map processes; public void CommandLineUtils(); public static int executeCommandLine(Commandline, StreamConsumer, StreamConsumer) throws CommandLineException; public static int executeCommandLine(Commandline, java.io.InputStream, StreamConsumer, StreamConsumer)...

	oldDS, err = client.AppsV1().DaemonSets(oldDS.Namespace).Create(context.Background(), oldDS, metav1.CreateOptions{})
	if err != nil {
		t.Fatal(err)
	}

	// create of DS adds to queue, processes
	waitForQueueLength(1, "created DS")
	ok := dsc.processNextWorkItem(context.TODO())
	if !ok {
		t.Fatal("queue is shutting down")
	}

	err = validateSyncDaemonSets(manager, fakePodControl, 1, 0, 0)

*...

  fi
  iptables -w -t mangle -I OUTPUT -s 169.254.169.254 -j DROP

  # Log all metadata access not from approved processes.
  case "${METADATA_SERVER_FIREWALL_MODE:-off}" in
    log)
      echo "Installing metadata firewall logging rules"
      gce-metadata-fw-helper -I LOG "MetadataServerFirewallReject" !

// SyncTerminatingRuntimePod is expected to terminate running containers in a pod that we have no
// configuration for. Once this method returns without error, any remaining local state can be safely
// cleaned up by background processes in each subsystem. Unlike syncTerminatingPod, we lack
// knowledge of the full pod spec and so cannot perform lifecycle related operations, only ensure