- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 815 for fslock (0.27 sec)
-
platforms/documentation/docs/src/snippets/java/javaGradlePlugin/kotlin/build.gradle.kts
plugins { `java-gradle-plugin` } // end::use-java-gradle-plugin-plugin[] // tag::gradle-plugin-block[] gradlePlugin { plugins { create("simplePlugin") { id = "org.gradle.sample.simple-plugin" implementationClass = "org.gradle.sample.SimplePlugin" } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 376 bytes - Viewed (0) -
cmd/kubeadm/app/util/pkiutil/pki_helpers.go
block := pem.Block{ Type: certutil.CertificateRequestBlockType, Bytes: csr.Raw, } return pem.EncodeToMemory(&block) } func parseCSRPEM(pemCSR []byte) (*x509.CertificateRequest, error) { block, _ := pem.Decode(pemCSR) if block == nil { return nil, errors.New("data doesn't contain a valid certificate request") } if block.Type != certutil.CertificateRequestBlockType {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 25.5K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue.go
} type basicWorkQueue struct { clock clock.Clock lock sync.Mutex queue map[types.UID]time.Time } var _ WorkQueue = &basicWorkQueue{} // NewBasicWorkQueue returns a new basic WorkQueue with the provided clock func NewBasicWorkQueue(clock clock.Clock) WorkQueue { queue := make(map[types.UID]time.Time) return &basicWorkQueue{queue: queue, clock: clock} } func (q *basicWorkQueue) GetWork() []types.UID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/StoppingDaemonIntegrationSpec.groovy
def "daemon process exits and client logs nice error message when daemon stopped"() { buildFile << """ task block { doLast { ${server.callFromBuild(UNBLOCK)} } } """ when: def blockingHandler = server.expectAndBlock(UNBLOCK) def build = executer.withTasks("block").start() blockingHandler.waitForAllPendingCalls() daemons.daemon.assertBusy()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.6K bytes - Viewed (0) -
src/syscall/syscall_freebsd.go
//sys Dup2(from int, to int) (err error) //sys Fchdir(fd int) (err error) //sys Fchflags(fd int, flags int) (err error) //sys Fchmod(fd int, mode uint32) (err error) //sys Fchown(fd int, uid int, gid int) (err error) //sys Flock(fd int, how int) (err error) //sys Fpathconf(fd int, name int) (val int, err error) //sys Fstat(fd int, stat *Stat_t) (err error) //sys Fstatat(fd int, path string, stat *Stat_t, flags int) (err error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:12:35 UTC 2023 - 8.7K bytes - Viewed (0) -
platforms/extensibility/plugin-use/src/integTest/groovy/org/gradle/plugin/use/SettingsScriptPluginIntegrationSpec.groovy
then: errorOutput.contains("plugins") where: settingScriptExtension | use '.gradle.kts' | "plugins { } \n plugins { }" } def "plugins block before a plugins management block - #settingScriptExtension"() { given: file("settings$settingScriptExtension") << use when: fails 'help' then: errorOutput.contains("plugins")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 22:36:52 UTC 2023 - 5.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tpu_parallel_execute_sink_resource_write.cc
results_to_remove_by_region.resize(num_regions); for (int i = 0; i < num_regions; ++i) { Block& block = parallel_execute.GetRegionBlockWithIndex(i); auto results = parallel_execute.GetRegionOutputs(i); auto& results_to_remove = results_to_remove_by_region[i]; results_to_remove.reserve(results.size()); Operation* terminator = block.getTerminator(); for (auto result : llvm::enumerate(results)) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 06 04:46:18 UTC 2022 - 6.6K bytes - Viewed (0) -
src/runtime/rwmutex_test.go
rwm.Init() for pb.Next() { rwm.RLock() rwm.RLock() rwm.RUnlock() rwm.RUnlock() rwm.Lock() rwm.Unlock() } }) } func benchmarkRWMutex(b *testing.B, localWork, writeRatio int) { var rwm RWMutex rwm.Init() b.RunParallel(func(pb *testing.PB) { foo := 0 for pb.Next() { foo++ if foo%writeRatio == 0 { rwm.Lock() rwm.Unlock() } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/security/mock.go
func (d *DirectSecretManager) GenerateSecret(resourceName string) (*SecretItem, error) { d.mu.RLock() defer d.mu.RUnlock() si, f := d.items[resourceName] if !f { return nil, fmt.Errorf("resource %v not found", resourceName) } return si, nil } func (d *DirectSecretManager) Set(resourceName string, secret *SecretItem) { d.mu.Lock() defer d.mu.Unlock() if secret == nil { delete(d.items, resourceName) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher.go
} w.mutex.Unlock() // Notify the handlers of the change. for _, h := range handlers { h.handler() } } // AddNetworksHandler registers a callback handler for changes to the mesh network config. func (w *internalNetworkWatcher) AddNetworksHandler(h func()) *WatcherHandlerRegistration { w.mutex.Lock() defer w.mutex.Unlock() handler := &WatcherHandlerRegistration{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 4.9K bytes - Viewed (0)