taskdef - Code Search

staging/src/k8s.io/apiserver/pkg/server/filters/routine.go

	"k8s.io/apiserver/pkg/endpoints/request"
)

type taskKeyType int

const taskKey taskKeyType = iota

type Task struct {
	Func func()
}

func WithTask(parent context.Context, t *Task) context.Context {
	return request.WithValue(parent, taskKey, t)
}

func TaskFrom(ctx context.Context) *Task {
	t, _ := ctx.Value(taskKey).(*Task)
	return t
}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Fri Feb 16 10:22:16 UTC 2024

- 1.9K bytes

- Viewed (0)

github.com/istio/istio

tools/bug-report/pkg/kubectlcmd/kubectlcmd.go

	// Limit the concurrency of running tasks.
	r.taskSem <- struct{}{}

	r.runningTasksMu.Lock()
	defer r.runningTasksMu.Unlock()
	log.Infof("STARTING %s", task)
	r.runningTasks.Insert(task)
}

func (r *Runner) removeRunningTask(task string) {
	defer func() {
		// Free up a slot for another running task.
		<-r.taskSem
	}()

	r.runningTasksMu.Lock()
	defer r.runningTasksMu.Unlock()

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Thu Nov 16 01:18:03 UTC 2023

- 7.2K bytes

- Viewed (0)

github.com/square/okhttp

native-image-tests/build.gradle.kts

import org.apache.tools.ant.taskdefs.condition.Os

plugins {
  id("com.palantir.graal")
  kotlin("jvm")
}

dependencies {
  implementation(libs.junit.jupiter.api)
  implementation(libs.junit.jupiter.engine)
  implementation(libs.junit.platform.console)
  implementation(libs.squareup.okio.fakefilesystem)

  implementation(projects.okhttp)
  implementation(projects.okhttpBrotli)
  implementation(projects.okhttpDnsoverhttps)

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Sat Jan 06 05:31:00 UTC 2024

- 1.6K bytes

- Viewed (0)

github.com/gradle/gradle

testing/distributions-integ-tests/src/integTest/groovy/org/gradle/SrcDistributionIntegrationSpec.groovy

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle

import org.apache.tools.ant.taskdefs.Expand
import org.gradle.api.logging.configuration.WarningMode
import org.gradle.integtests.fixtures.ToBeFixedForConfigurationCache
import org.gradle.internal.jvm.Jvm
import org.gradle.test.fixtures.file.TestFile

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Apr 04 07:21:38 UTC 2024

- 3.7K bytes

- Viewed (0)

github.com/golang/go

src/cmd/compile/internal/ssagen/phi.go

	priq := &s.priq
	q := s.q
	queued := s.queued
	queued.clear()
	hasPhi := s.hasPhi
	hasPhi.clear()
	hasDef := s.hasDef
	hasDef.clear()

	// Add defining blocks to priority queue.
	for _, b := range defs {
		priq.a = append(priq.a, b)
		hasDef.add(b.ID)
		if debugPhi {
			fmt.Printf("def of var%d in %s\n", n, b)
		}
	}
	heap.Init(priq)

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Nov 18 17:59:44 UTC 2022

- 15.2K bytes

- Viewed (0)

github.com/istio/istio

samples/ambient-argo/documentation/argo-reference-arch.dot

        istiod18[label="Istio 1.18.5 Control"]
        istiod19[label="Istio 1.19.3 Control"]
        ztunnelds[label="ztunnel"]
        cnids[label="cni"]
        extrads[label="prometheus, etc"]
        tagdef[label="tag default->1.18.5"]
        tagrap[label="tag rapid->1.19.3"]
        tagsta[label="tag stable->1.18.5"]
    }

    subgraph cluster_app {
        rankdir=TB
        node [style=filled];

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Sat Nov 04 01:54:50 UTC 2023

- 2.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/jvm/plugins-application/src/main/java/org/gradle/api/internal/plugins/StartScriptGenerator.java

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.gradle.api.internal.plugins;

import org.apache.tools.ant.taskdefs.Chmod;
import org.gradle.api.Action;
import org.gradle.api.UncheckedIOException;
import org.gradle.internal.IoActions;
import org.gradle.internal.os.OperatingSystem;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed Feb 28 23:38:57 UTC 2024

- 6.7K bytes

- Viewed (0)

github.com/gradle/gradle

subprojects/core/src/testFixtures/groovy/org/gradle/api/tasks/AntBuilderAwareUtil.groovy

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.gradle.api.tasks

import org.apache.tools.ant.taskdefs.MatchingTask
import org.apache.tools.ant.types.FileSet
import org.apache.tools.ant.types.Path
import org.apache.tools.ant.types.Resource
import org.apache.tools.ant.types.ResourceCollection
import org.gradle.api.AntBuilder

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Oct 28 15:32:09 UTC 2022

- 5K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/jvm/platform-jvm/src/test/groovy/org/gradle/api/java/archives/internal/DefaultManifestTest.groovy

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.api.java.archives.internal

import org.apache.tools.ant.taskdefs.Manifest
import org.apache.tools.ant.taskdefs.Manifest.Attribute
import org.gradle.api.Action
import org.gradle.api.internal.file.FileResolver
import org.gradle.api.internal.provider.DefaultProperty

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Sep 28 15:09:49 UTC 2023

- 15.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/runtimeshaded/RuntimeShadedJarCreatorTest.groovy

                                      'net/rubygrapefruit/platform/FileInfo',
                                      'org/codehaus/groovy/ant/Groovyc',
                                      'org/apache/tools/ant/taskdefs/Ant',
                                      'org/slf4j/Logger',
                                      'org/apache/commons/logging/Log',
                                      'org/apache/log4j/Logger',

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Wed May 22 13:39:49 UTC 2024

- 20.8K bytes

- Viewed (0)

Search Options