- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 34 for rootTask (0.14 sec)
-
internal/disk/root_disk.go
import "runtime" // IsRootDisk returns if diskPath belongs to root-disk, i.e the disk mounted at "/" func IsRootDisk(diskPath string, rootDisk string) (bool, error) { if runtime.GOOS == "windows" { // On windows this function is not implemented. return false, nil } return SameDisk(diskPath, rootDisk)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.1K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
if err != nil { b.Fatal(err) } } } func BenchmarkDecodeDiskInfoMsgp(b *testing.B) { v := DiskInfo{ Total: 1000, Free: 1000, Used: 1000, FSType: "xfs", RootDisk: true, Healing: true, Endpoint: "http://localhost:9001/tmp/drive1", MountPath: "/tmp/drive1", ID: "uuid", Error: "", } var buf bytes.Buffer msgp.Encode(&buf, &v)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 9.4K bytes - Viewed (0) -
platforms/core-runtime/build-profile/src/integTest/groovy/org/gradle/profile/ProfilingIntegrationTest.groovy
file('settings.gradle') << 'include "a", "b", "c"' buildFile << ''' allprojects { apply plugin: 'java' task fooTask task barTask } ''' when: executer.withArgument("--profile") succeeds("build", "fooTask", "-x", "barTask") then: def reportFile = findReport() Document document = Jsoup.parse(reportFile, null)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Dec 01 12:58:53 UTC 2023 - 3.4K bytes - Viewed (0) -
internal/http/transports.go
dialContext := s.DialContext if dialContext == nil { dialContext = DialContextWithLookupHost(s.LookupHost, NewInternodeDialContext(s.DialTimeout, s.TCPOptions)) } tlsClientConfig := tls.Config{ RootCAs: s.RootCAs, CipherSuites: s.CipherSuites, CurvePreferences: s.CurvePreferences, ClientSessionCache: tls.NewLRUClientSessionCache(tlsClientSessionCacheSize), }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter_test.go
// Add each resource to our ledger for tracking history // mark each of our resources as in flight so they are included in the report. r.AddInProgressResource(*res) } firstNoncePrefix := r.ledger.RootHash() connections := []string{ "conA", "conB", "conC", } // mark each fake connection as having acked version 1 of all resources for _, con := range connections { r.processEvent(con, "", firstNoncePrefix)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/history/impl/FileCollectionFingerprintSerializer.java
for (int i = 0; i < numberOfRoots; i++) { String absolutePath = stringInterner.intern(decoder.readString()); HashCode rootHash = hashCodeSerializer.read(decoder); builder.put(absolutePath, rootHash); } return builder.build(); } @Override public void write(Encoder encoder, FileCollectionFingerprint value) throws Exception {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:34 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl-integ-tests/src/integTest/kotlin/org/gradle/kotlin/dsl/integration/GradleApiExtensionsIntegrationTest.kt
fun `can use Gradle API generated extensions in buildSrc`() { withKotlinBuildSrc() withFile( "buildSrc/src/main/kotlin/foo/FooTask.kt", """ package foo import org.gradle.api.* import org.gradle.api.model.* import org.gradle.api.tasks.*
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 03 15:53:16 UTC 2023 - 9K bytes - Viewed (0) -
internal/config/etcd/etcd.go
// Default path prefix for all keys on etcd, other than CoreDNSPath. cfg.PathPrefix = env.Get(EnvEtcdPathPrefix, kvs.Get(PathPrefix)) if etcdSecure { cfg.TLS = &tls.Config{ RootCAs: rootCAs, } // This is only to support client side certificate authentication // https://coreos.com/etcd/docs/latest/op-guide/security.html etcdClientCertFile := env.Get(EnvEtcdClientCert, kvs.Get(ClientCert))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/model/disabled_ledger.go
return "", nil } func (d *DisabledLedger) Delete(key string) error { return nil } func (d *DisabledLedger) Get(key string) (string, error) { return "", nil } func (d *DisabledLedger) RootHash() string { return "" } func (d *DisabledLedger) GetPreviousValue(previousHash, key string) (result string, err error) { return "", errors.New("distribution tracking is disabled")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.3K bytes - Viewed (0) -
internal/event/target/mqtt.go
SetCleanSession(true). SetUsername(args.User). SetPassword(args.Password). SetMaxReconnectInterval(args.MaxReconnectInterval). SetKeepAlive(args.KeepAlive). SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}). AddBroker(args.Broker.String()) target.client = mqtt.NewClient(options) token := target.client.Connect() ok := token.WaitTimeout(reconnectInterval) if !ok { return store.ErrNotConnected
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0)